class Cable::RedisBackend
- Cable::RedisBackend
- Cable::BackendCore
- Reference
- Object
Defined in:
backend/redis/backend.crInstance Method Summary
- #close_publish_connection
- #close_subscribe_connection
-
#open_subscribe_connection(channel)
internal pub/sub
- #ping_redis_publish
-
#ping_redis_subscribe
since @server.redis_subscribe connection is called on a block loop we basically cannot call ping outside of the block instead, we just spin up another new redis connection then publish a special channel/message broadcast the @server.redis_subscribe picks up this special combination and calls ping on the block loop for us
- #publish_connection : Redis::Client
-
#publish_message(stream_identifier : String, message : String)
external pub/sub
- #redis_publish : Redis::Client
-
#redis_subscribe : Redis::Connection
connection management
-
#subscribe(stream_identifier : String)
channel management
-
#subscribe_connection : Redis::Connection
connection management
- #unsubscribe(stream_identifier : String)
Instance methods inherited from class Cable::BackendCore
close_publish_connection
close_publish_connection,
close_subscribe_connection
close_subscribe_connection,
open_subscribe_connection(channel)
open_subscribe_connection,
ping_redis_publish
ping_redis_publish,
ping_redis_subscribe
ping_redis_subscribe,
publish_connection
publish_connection,
publish_message(stream_identifier : String, message : String)
publish_message,
subscribe(stream_identifier : String)
subscribe,
subscribe_connection
subscribe_connection,
unsubscribe(stream_identifier : String)
unsubscribe
Instance Method Detail
def ping_redis_subscribe
#
since @server.redis_subscribe connection is called on a block loop we basically cannot call ping outside of the block instead, we just spin up another new redis connection then publish a special channel/message broadcast the @server.redis_subscribe picks up this special combination and calls ping on the block loop for us