Documentation ¶
Index ¶
- Variables
- func Database(s string) pubsub.Option
- func IdleCheckFrequency(t time.Duration) pubsub.Option
- func IdleTimeout(t time.Duration) pubsub.Option
- func New(opts ...pubsub.Option) (*connection, error)
- func NewPublisher(conn *connection) (pubsub.Publisher, error)
- func NewSubscriber(conn *connection, channel string) (pubsub.Subscriber, error)
- func PoolTimeout(t time.Duration) pubsub.Option
- func Poolsize(ii int) pubsub.Option
Constants ¶
This section is empty.
Variables ¶
View Source
var ( Config = &redisConfig{ done: make(chan struct{}), } )
Functions ¶
func NewPublisher ¶
func NewSubscriber ¶
func NewSubscriber(conn *connection, channel string) (pubsub.Subscriber, error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.