Documentation
¶
Index ¶
- type Module
- func (m *Module) CancelSubscription(topic string)
- func (m *Module) Close()
- func (m *Module) GetKey(ctx context.Context, key string) (string, error)
- func (m *Module) RenewKeyTTLOnMatch(ctx context.Context, key, value string, t time.Duration) error
- func (m *Module) Send(ctx context.Context, topic string, value interface{}) error
- func (m *Module) SendAck(ctx context.Context, replyTo string, ack bool) error
- func (m *Module) SetKeyIfNotExists(ctx context.Context, key, value string, t time.Duration) (bool, error)
- func (m *Module) Subscribe(ctx context.Context, topic string) (<-chan *redis.Message, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Module ¶
type Module struct {
// contains filtered or unexported fields
}
Module deals with pub sub related activities
func (*Module) CancelSubscription ¶
CancelSubscription cancels an active subscription
func (*Module) Close ¶
func (m *Module) Close()
Close closes the redis client along with the active subscriptions on it
func (*Module) RenewKeyTTLOnMatch ¶
RenewKeyTTLOnMatch renews the ttl of the key if it exists & its value matches
Source Files
Click to show internal directories.
Click to hide internal directories.