Method List

Classes Methods Files

Search:

#_active NATS::KeyWatcher
#_dseq NATS::KeyWatcher
#_fork NATS::ForkTracker
#_hb_task NATS::KeyWatcher
#_init_done NATS::KeyWatcher
#_sseq NATS::KeyWatcher
#_sub NATS::KeyWatcher
#_updates NATS::KeyWatcher
#_watcher_cond NATS::KeyWatcher
#account_info NATS::JetStream::Manager
#ack NATS::JetStream::Msg::AckMethods
#ack_floor NATS::JetStream::API
#ack_floor NATS::JetStream::API::ConsumerInfo
#ack_policy NATS::JetStream::API
#ack_policy NATS::JetStream::API::ConsumerConfig
#ack_sync NATS::JetStream::Msg::AckMethods
#ack_wait NATS::JetStream::API
#ack_wait NATS::JetStream::API::ConsumerConfig
#add NATS::Service::Groups
#add NATS::Service::Endpoints
#add NATS::Services
#add_consumer NATS::JetStream::Manager
#add_stream NATS::JetStream::Manager
after_fork NATS::Client
#allow_direct NATS::JetStream::API::StreamConfig
#allow_rollup_hdrs NATS::JetStream::API::StreamConfig
#average_processing_time NATS::Service::Stats
#backoff NATS::JetStream::API::ConsumerConfig
#basic NATS::Service::Status
#bucket NATS::KeyValue::Entry
#bucket NATS::KeyValue::BucketStatus
#bucket NATS::KeyValue::API::KeyValueConfig
#bytes NATS::JetStream::API::StreamState
#bytes NATS::JetStream::API
#call NATS::Rails::Reloader
#call NATS::Service::Callbacks
#callback NATS::Subscription
#callbacks NATS::Service
#callbacks NATS::Service::Callbacks
#client NATS::Service
#client NATS::Services
#close NATS::IO::Socket
#close NATS::Client
#closed NATS::Subscription
#closed? NATS::Client
#closed? NATS::IO::Socket
#cluster NATS::JetStream::API::ConsumerInfo
#cluster NATS::JetStream::API
#code NATS::Service::ErrorWrapper
#code NATS::JetStream::Error::APIError
#concurrency_semaphore NATS::Subscription
#config NATS::JetStream::API
#config NATS::JetStream::API::StreamCreateResponse
#config NATS::JetStream::API::StreamConfig
#config NATS::JetStream::API::ConsumerInfo
#config NATS::JetStream::API::StreamInfo
#connect NATS::IO::Socket
#connect NATS::IO::WebSocket
#connect NATS::Client
connect NATS
#connected? NATS::Client
#connected_server NATS::Client
#connecting? NATS::Client
#consumer NATS::JetStream::Msg::Metadata
#consumer NATS::JetStream::Msg::Ack::SequencePair
#consumer NATS::JetStream::Error::APIError
#consumer NATS::JetStream::JS::Sub
#consumer_count NATS::JetStream::API
#consumer_count NATS::JetStream::API::StreamState
#consumer_info NATS::JetStream::Manager
#consumer_seq NATS::JetStream::API::SequenceInfo
#consumer_seq NATS::JetStream::API
#create NATS::KeyValue
#create_key_value NATS::KeyValue::Manager
#created NATS::JetStream::API::ConsumerInfo
#created NATS::JetStream::API::StreamConfig
#created NATS::JetStream::API
#created NATS::JetStream::API::StreamCreateResponse
#created NATS::KeyValue::Entry
#created NATS::JetStream::API::StreamInfo
#data NATS::Msg
#data NATS::Service::ErrorWrapper
#data NATS::JetStream::API::RawStreamMsg
default_reloader NATS::Client
#delete NATS::KeyValue
#delete_consumer NATS::JetStream::Manager
#delete_key_value NATS::KeyValue::Manager
#delete_stream NATS::JetStream::Manager
#deliver_group NATS::JetStream::API::ConsumerConfig
#deliver_policy NATS::JetStream::API::ConsumerConfig
#deliver_policy NATS::JetStream::API
#deliver_subject NATS::JetStream::API::ConsumerConfig
#delivered NATS::JetStream::API::ConsumerInfo
#delivered NATS::JetStream::API
#delta NATS::KeyValue::Entry
#deny_delete NATS::JetStream::API::StreamConfig
#deny_purge NATS::JetStream::API::StreamConfig
#description NATS::Service
#description NATS::JetStream::API::ConsumerConfig
#description NATS::JetStream::API::StreamConfig
#description NATS::Service::ErrorWrapper
#description NATS::JetStream::Error::APIError
#description NATS::KeyValue::API::KeyValueConfig
#did_create NATS::JetStream::API::StreamConfig
#did_create NATS::JetStream::API
#did_create NATS::JetStream::API::StreamCreateResponse
#direct NATS::KeyValue::API::KeyValueConfig
#discard NATS::JetStream::API
#discard NATS::JetStream::API::StreamConfig
#disconnected? NATS::Client
#discovered_servers NATS::Client
#dispatch NATS::Subscription
#domain NATS::JetStream::API::StreamInfo
#domain NATS::JetStream::Msg::Metadata
#domain= NATS::JetStream::PubAck
#drain NATS::Client
#drained NATS::Subscription
#draining? NATS::Client
#duplicate= NATS::JetStream::PubAck
#duplicate_window NATS::JetStream::API
#duplicate_window NATS::JetStream::API::StreamConfig
#durable_name NATS::JetStream::API
#durable_name NATS::JetStream::API::ConsumerConfig
#each NATS::Utils::List
#each NATS::KeyWatcher
#endpoint NATS::Service::Request
#endpoints NATS::Service
#endpoints NATS::Service::Group
#enqueue_processing NATS::Subscription
#entry NATS::KeyValue::KeyNotFoundError
#err_code NATS::JetStream::Error::APIError
#error NATS::Service::Request
#error NATS::Service::Stats
#filter_subject NATS::JetStream::API::ConsumerConfig
#filter_subjects NATS::JetStream::API::ConsumerConfig
#find_stream_name_by_subject NATS::JetStream::Manager
#first_seq NATS::JetStream::API
#first_seq NATS::JetStream::API::StreamState
#first_ts NATS::JetStream::API::StreamState
#flow_control NATS::JetStream::API::ConsumerConfig
#flush NATS::Client
#force_reconnect NATS::Client
from_msg NATS::Service::Request
#future NATS::Subscription
#get NATS::KeyValue
#get_last_msg NATS::JetStream::Manager
#get_msg NATS::JetStream::Manager
#groups NATS::Service::Group
#groups NATS::Service
#header NATS::Msg
#headers NATS::JetStream::API::RawStreamMsg
#headers_only NATS::JetStream::API::ConsumerConfig
#history NATS::KeyValue
#history NATS::KeyValue::BucketStatus
#history NATS::KeyValue::API::KeyValueConfig
#id NATS::Service
#idle_heartbeat NATS::JetStream::API::ConsumerConfig
#in_progress NATS::JetStream::Msg::AckMethods
#inactive_threshold NATS::JetStream::API::ConsumerConfig
#info NATS::Service
#info NATS::Service::Status
#initialize NATS::Utils::List
#initialize NATS::Protocol::Parser
#initialize NATS::KeyValue::API::KeyValueConfig
#initialize NATS::JetStream::API::StreamConfig
#initialize NATS::Service::Request
#initialize NATS::JetStream::API::SequenceInfo
#initialize NATS::IO::Socket
#initialize NATS::Service::Endpoint
#initialize NATS::JetStream::API::StreamInfo
#initialize NATS::KeyValue::KeyNotFoundError
#initialize NATS::JetStream
#initialize NATS::IO::WebSocket
#initialize NATS::KeyValue::KeyWrongLastSequenceError
#initialize NATS::JetStream::API::RawStreamMsg
#initialize NATS::KeyValue::BucketStatus
#initialize NATS::Service::Status
#initialize NATS::Client
#initialize NATS::Services
#initialize NATS::JetStream::JS::Sub
#initialize NATS::Rails::Reloader
#initialize NATS::JetStream::Error::ConsumerNotFound
#initialize NATS::Service::Monitoring
#initialize NATS::JetStream::Error::BadRequest
#initialize NATS::Service
#initialize NATS::JetStream::Error::NotFound
#initialize NATS::Subscription
#initialize NATS::Msg
#initialize NATS::JetStream::API::StreamState
#initialize NATS::JetStream::Error::APIError
#initialize NATS::KeyWatcher
#initialize NATS::KeyValue::Entry
#initialize NATS::JetStream::Msg::Metadata
#initialize NATS::Service::Callbacks
#initialize NATS::JetStream::API::ConsumerConfig
#initialize NATS::KeyValue
#initialize NATS::NUID
#initialize NATS::JetStream::Error::ServiceUnavailable
#initialize NATS::JetStream::API::StreamCreateResponse
#initialize NATS::JetStream::API::ConsumerInfo
#initialize NATS::Service::Stats
#initialize NATS::Service::Group
#initialize NATS::Service::ErrorWrapper
#initialize NATS::JetStream::Error::StreamNotFound
#initialize NATS::JetStream::Error::ServerError
#insert NATS::Utils::List
#inspect NATS::Service::Request
#inspect NATS::Subscription
#inspect NATS::Rails::Reloader
#inspect NATS::Msg
is_valid_key NATS::KeyValue
#jetstream NATS::Client
#js NATS::JetStream::JS::Sub
#jsi NATS::Subscription
#key NATS::KeyValue::Entry
#key_value NATS::KeyValue::Manager
#keys NATS::KeyValue
#last_active NATS::JetStream::API::SequenceInfo
#last_error NATS::Client
#last_error NATS::Service::Stats
#last_seq NATS::JetStream::API
#last_seq NATS::JetStream::API::StreamState
#last_ts NATS::JetStream::API::StreamState
#max NATS::Subscription
#max_ack_pending NATS::JetStream::API
#max_ack_pending NATS::JetStream::API::ConsumerConfig
#max_age NATS::JetStream::API
#max_age NATS::JetStream::API::StreamConfig
#max_batch NATS::JetStream::API::ConsumerConfig
#max_bytes NATS::JetStream::API::ConsumerConfig
#max_bytes NATS::KeyValue::API::KeyValueConfig
#max_bytes NATS::JetStream::API
#max_bytes NATS::JetStream::API::StreamConfig
#max_consumers NATS::JetStream::API::StreamConfig
#max_consumers NATS::JetStream::API
#max_deliver NATS::JetStream::API::ConsumerConfig
#max_deliver NATS::JetStream::API
#max_expires NATS::JetStream::API::ConsumerConfig
#max_msg_size NATS::JetStream::API::StreamConfig
#max_msg_size NATS::JetStream::API
#max_msgs NATS::JetStream::API::StreamConfig
#max_msgs NATS::JetStream::API
#max_msgs_per_subject NATS::JetStream::API
#max_msgs_per_subject NATS::JetStream::API::StreamConfig
#max_value_size NATS::KeyValue::API::KeyValueConfig
#max_waiting NATS::JetStream::API::ConsumerConfig
#max_waiting NATS::JetStream::API
#mem_storage NATS::JetStream::API::ConsumerConfig
#message NATS::Service::ErrorWrapper
#messages NATS::JetStream::API::StreamState
#messages NATS::JetStream::API
#metadata NATS::JetStream::API::ConsumerConfig
#metadata NATS::Service
#metadata NATS::JetStream::Msg::AckMethods
#metadata NATS::JetStream::API::StreamConfig
#metadata NATS::Service::Endpoint
#mirror NATS::JetStream::API::StreamConfig
#mirror_direct NATS::JetStream::API::StreamConfig
#monitoring NATS::Service
#nak NATS::JetStream::Msg::AckMethods
#name NATS::Service
#name NATS::Service::Endpoint
#name NATS::Service::Group
#name NATS::JetStream::API::ConsumerInfo
#name NATS::JetStream::API::StreamConfig
#name NATS::JetStream::API
#name NATS::JetStream::API::ConsumerConfig
#nc NATS::JetStream
#nc NATS::Msg
#nc NATS::Subscription
#new_inbox NATS::Client
next NATS::NUID
#next NATS::NUID
#next_msg NATS::Subscription
nil? NATS::Service::Validator
#nms NATS::JetStream::JS::Sub
#no_ack NATS::JetStream::API::StreamConfig
#now NATS::MonotonicTime
#num_ack_pending NATS::JetStream::API
#num_ack_pending NATS::JetStream::API::ConsumerInfo
#num_delivered NATS::JetStream::Msg::Metadata
#num_errors NATS::Service::Stats
#num_pending NATS::JetStream::API
#num_pending NATS::JetStream::Msg::Metadata
#num_pending NATS::JetStream::API::ConsumerInfo
#num_redelivered NATS::JetStream::API
#num_redelivered NATS::JetStream::API::ConsumerInfo
#num_replicas NATS::JetStream::API::ConsumerConfig
#num_replicas NATS::JetStream::API
#num_replicas NATS::JetStream::API::StreamConfig
#num_requests NATS::Service::Stats
#num_waiting NATS::JetStream::API
#num_waiting NATS::JetStream::API::ConsumerInfo
#old_request NATS::Client
#on_close NATS::Client
#on_disconnect NATS::Client
#on_error NATS::Client
#on_reconnect NATS::Client
#on_stats NATS::Service
#on_stop NATS::Service
#op NATS::KeyValue::KeyNotFoundError
#operation NATS::KeyValue::Entry
#opt_start_seq NATS::JetStream::API::ConsumerConfig
#opt_start_time NATS::JetStream::API::ConsumerConfig
#options NATS::Client
#opts NATS::JetStream
#parent NATS::Utils::List
#parse NATS::Protocol::Parser
#pending NATS::Subscription
#pending NATS::KeyWatcher
#pending_bytes_limit NATS::Subscription
#pending_msgs_limit NATS::Subscription
#pending_queue NATS::Subscription
#pending_size NATS::Subscription
#placement NATS::KeyValue::API::KeyValueConfig
#placement NATS::JetStream::API::StreamConfig
#prefix NATS::JetStream
#prefix NATS::Service::Monitoring
#process NATS::Subscription
#processing_concurrency= NATS::Subscription
#processing_time NATS::Service::Stats
#publish NATS::JetStream
#publish NATS::Client
#publish_msg NATS::Client
#pull_subscribe NATS::JetStream
#purge NATS::KeyValue
#push_bound NATS::JetStream::API::ConsumerInfo
#put NATS::KeyValue
#queue NATS::Subscription
#queue NATS::Service::Endpoint
#queue NATS::Service::Group
#queue NATS::Service
#randomize_prefix! NATS::NUID
#rate_limit_bps NATS::JetStream::API::ConsumerConfig
#read NATS::IO::Socket
#read NATS::IO::WebSocket
#read_line NATS::IO::WebSocket
#read_line NATS::IO::Socket
#received NATS::Subscription
#received NATS::KeyWatcher
#reconnecting? NATS::Client
#record NATS::Service::Stats
#register NATS::Service::Callbacks
#reloader NATS::Client
#replay_policy NATS::JetStream::API
#replay_policy NATS::JetStream::API::ConsumerConfig
#replicas NATS::KeyValue::API::KeyValueConfig
#reply NATS::Msg
#republish NATS::KeyValue::API::KeyValueConfig
#republish NATS::JetStream::API::StreamConfig
#request NATS::Client
#request_msg NATS::Client
#reset NATS::Service::Stats
#reset NATS::Service::Endpoint
#reset NATS::Service
#reset! NATS::Protocol::Parser
#respond NATS::Msg
#respond_msg NATS::Msg
#respond_with_error NATS::Service::Request
#response NATS::Subscription
#retention NATS::JetStream::API::StreamConfig
#retention NATS::JetStream::API
#revision NATS::KeyValue::Entry
#sample_freq NATS::JetStream::API::ConsumerConfig
#sealed NATS::JetStream::API::StreamConfig
#seq NATS::JetStream::API::RawStreamMsg
#seq NATS::JetStream::Error::APIError
#seq= NATS::JetStream::PubAck
#sequence NATS::JetStream::Msg::Metadata
#sequence NATS::JetStream::API::RawStreamMsg
#server_info NATS::Client
#server_pool NATS::Client
#service NATS::Service::Status
#service NATS::Service::Group
#service NATS::Service::Endpoint
#service NATS::Service
#service NATS::Service::Monitoring
#service NATS::Service::Callbacks
#services NATS::Client
#setup_tls! NATS::IO::WebSocket
#setup_tls! NATS::IO::Socket
#sid NATS::Subscription
since NATS::MonotonicTime
#socket NATS::IO::WebSocket
#socket NATS::IO::Socket
#sources NATS::JetStream::API::StreamConfig
#started_at NATS::Service::Status
#state NATS::JetStream::API::StreamInfo
#state NATS::JetStream::API::StreamConfig
#state NATS::JetStream::API
#state NATS::JetStream::API::StreamCreateResponse
#stats NATS::Service::Status
#stats NATS::Client
#stats NATS::Service
#stats NATS::Service::Endpoint
#status NATS::Client
#status NATS::Service
#status NATS::KeyValue
#stop NATS::Service::Monitoring
#stop NATS::KeyWatcher
#stop NATS::Service
#stop NATS::Service::Endpoint
#stopped NATS::Service::Monitoring
#stopped? NATS::Service::Endpoint
#stopped? NATS::Service
#stopped? NATS::Service::Monitoring
#storage NATS::KeyValue::API::KeyValueConfig
#storage NATS::JetStream::API
#storage NATS::JetStream::API::StreamConfig
#stream NATS::JetStream::Msg::Metadata
#stream NATS::JetStream::Error::APIError
#stream NATS::JetStream::PubAck
#stream NATS::JetStream::JS::Sub
#stream NATS::JetStream::Msg::Ack::SequencePair
#stream_info NATS::KeyValue::BucketStatus
#stream_info NATS::JetStream::Manager
#stream_name NATS::JetStream::API
#stream_name NATS::JetStream::API::ConsumerInfo
#stream_seq NATS::JetStream::API
#stream_seq NATS::JetStream::API::SequenceInfo
#sub NATS::Msg
#subject NATS::Subscription
#subject NATS::Service::Group
#subject NATS::Service
#subject NATS::Msg
#subject NATS::Service::Endpoint
#subject NATS::JetStream::API::RawStreamMsg
#subjects NATS::JetStream::API
#subjects NATS::JetStream::API::StreamConfig
#subscribe NATS::JetStream
#subscribe NATS::Client
#subscription_executor NATS::Client
#take NATS::KeyWatcher
#term NATS::JetStream::Msg::AckMethods
#timestamp NATS::JetStream::Msg::Metadata
#to_s NATS::KeyValue::InvalidKeyError
#to_s NATS::KeyValue::NoKeysFoundError
#to_s NATS::KeyValue::KeyDeletedError
#to_s NATS::KeyValue::KeyWrongLastSequenceError
#to_s NATS::KeyValue::KeyHistoryTooLargeError
#to_s NATS::KeyValue::KeyNotFoundError
#to_s NATS::JetStream::Error::APIError
#ttl NATS::KeyValue::API::KeyValueConfig
#ttl NATS::KeyValue::BucketStatus
#type NATS::JetStream::API::ConsumerInfo
#type NATS::JetStream::API::StreamConfig
#type NATS::JetStream::API::StreamCreateResponse
#type NATS::JetStream::API::StreamInfo
#type NATS::JetStream::API
#unsubscribe NATS::Subscription
#update NATS::KeyValue
#update_stream NATS::JetStream::Manager
#updates NATS::KeyWatcher
#uri NATS::Client
valid? NATS::Service::Validator
validate NATS::Service::Validator
#validate_keys NATS::KeyValue::API::KeyValueConfig
#value NATS::KeyValue::Entry
#values NATS::KeyValue::BucketStatus
#version NATS::Service
#wait_for_msgs_cond NATS::Subscription
#watch NATS::KeyValue
#watchall NATS::KeyValue
with_nats_timeout NATS::MonotonicTime
#write NATS::IO::WebSocket
#write NATS::IO::Socket