Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisSubscriber ¶
type RedisSubscriber struct {
// contains filtered or unexported fields
}
RedisSubscriber contains information about Redis pubsub connection
func NewRedisSubscriber ¶
func NewRedisSubscriber(node *node.Node, url string, channel string) RedisSubscriber
NewRedisSubscriber returns new RedisSubscriber struct
func (*RedisSubscriber) Start ¶
func (s *RedisSubscriber) Start() error
Start connects to Redis and subscribes to the pubsub channel
Click to show internal directories.
Click to hide internal directories.