Method List
-
#acknowledge_entry RedisIPC::Stream::Commands
-
#add_callback RedisIPC::Stream::Consumer
-
#add_to_stream RedisIPC::Stream::Commands
-
#available_consumer_names RedisIPC::Stream::Commands
-
channel RedisIPC::Channel
-
#check_for_entries RedisIPC::Stream::Consumer
-
#check_for_entries RedisIPC::Stream::Dispatcher
-
#check_for_entries RedisIPC::Stream::Ledger::Consumer
-
#claim_entry RedisIPC::Stream::Commands
-
#clear_available_consumers RedisIPC::Stream::Commands
-
#connect RedisIPC::Stream
-
connect RedisIPC::Channel
-
#connected? RedisIPC::Stream
-
connected? RedisIPC::Channel
-
#consumer_available? RedisIPC::Stream::Commands
-
#consumer_info RedisIPC::Stream::Commands
-
#create_consumer RedisIPC::Stream::Commands
-
#create_group RedisIPC::Stream::Commands
-
#delete_consumer RedisIPC::Stream::Commands
-
#delete_entry RedisIPC::Stream::Ledger
-
#delete_entry RedisIPC::Stream::Commands
-
#delete_stream RedisIPC::Stream::Commands
-
#destroy_group RedisIPC::Stream::Commands
-
#disconnect RedisIPC::Stream
-
disconnect RedisIPC::Channel
-
#entries_size RedisIPC::Stream::Commands
-
#entry? RedisIPC::Stream::Ledger
-
event RedisIPC::Channel
-
#execute RedisIPC::Channel::Event
-
#expired? RedisIPC::Stream::Ledger::Entry
-
#fetch_entry RedisIPC::Stream::Ledger
-
from_redis RedisIPC::Stream::Entry
-
#fulfill_request RedisIPC::Stream
-
fulfilled RedisIPC::Response
-
#fulfilled RedisIPC::Stream::Entry
-
#fulfilled? RedisIPC::Stream::Entry
-
group RedisIPC::Channel
-
#group_name RedisIPC::Channel::Event
-
#group_name RedisIPC::Stream::Commands
-
inherited RedisIPC::Channel
-
#initialize RedisIPC::Stream
-
#initialize RedisIPC::Channel::Event
-
#initialize RedisIPC::Stream::Entry
-
#initialize RedisIPC::Stream::Ledger::Entry
-
#initialize RedisIPC::Stream::Ledger
-
#initialize RedisIPC::Stream::Commands::ConsumerProxy
-
#initialize RedisIPC::Stream::Commands
-
#initialize RedisIPC::Stream::Consumer
-
#initialize RedisIPC::Stream::Dispatcher
-
#initialize RedisIPC::Stream::Ledger::Consumer
-
#inspect RedisIPC::Stream::Consumer
-
#instance_id RedisIPC::Channel::Event
-
#instance_id RedisIPC::Stream::Commands
-
#listen RedisIPC::Stream::Consumer
-
#listen RedisIPC::Stream::Dispatcher
-
#listening? RedisIPC::Stream::Consumer
-
#logger RedisIPC::Stream::Commands
-
#make_consumer_available RedisIPC::Stream::Commands
-
#make_consumer_unavailable RedisIPC::Stream::Commands
-
#name RedisIPC::Stream::Consumer
-
#next_pending_entry RedisIPC::Stream::Commands
-
#next_reclaimed_entry RedisIPC::Stream::Commands
-
#next_unread_entry RedisIPC::Stream::Commands
-
#on_error RedisIPC::Stream
-
on_error RedisIPC::Channel
-
#on_request RedisIPC::Stream
-
#options RedisIPC::Stream::Ledger
-
#params RedisIPC::Channel::Event
-
#pending? RedisIPC::Stream::Entry
-
#prune_consumers RedisIPC::Stream::Commands
-
#read_from_stream RedisIPC::Stream::Commands
-
#redis RedisIPC::Stream
-
#redis RedisIPC::Stream::Consumer
-
#redis_pool RedisIPC::Stream::Commands
-
#reject_request RedisIPC::Stream
-
rejected RedisIPC::Response
-
#rejected RedisIPC::Stream::Entry
-
#rejected? RedisIPC::Stream::Entry
-
#send_to_group RedisIPC::Stream
-
#shutdown RedisIPC::Stream::Commands
-
#source_group RedisIPC::Channel::Event
-
#stop_listening RedisIPC::Stream::Consumer
-
#store_entry RedisIPC::Stream::Ledger
-
stream RedisIPC::Channel
-
#stream_name RedisIPC::Channel::Event
-
#stream_name RedisIPC::Stream::Commands
-
#to_h RedisIPC::Stream::Entry
-
trigger_event RedisIPC::Channel