Versions in this module Expand all Collapse all v1 v1.1.0 Feb 23, 2023 Changes in this version + type Event interface + Data func() []byte + Name func() string + func NewAllRequestsDeletedEvent() Event + func NewRequestDeletedEvent(requestID string) Event + func NewRequestRegisteredEvent(requestID string) Event + type InMemory struct + func NewInMemory() *InMemory + func (ps *InMemory) Close() error + func (ps *InMemory) Publish(channelName string, event Event) error + func (ps *InMemory) Subscribe(channelName string, channel chan<- Event) error + func (ps *InMemory) Unsubscribe(channelName string, channel chan Event) error + type Publisher interface + Publish func(channelName string, event Event) error + type Redis struct + func NewRedis(ctx context.Context, rdb *redis.Client) *Redis + func (ps *Redis) Close() error + func (ps *Redis) Publish(channelName string, event Event) error + func (ps *Redis) Subscribe(channelName string, channel chan<- Event) error + func (ps *Redis) Unsubscribe(channelName string, channel chan Event) error + type Subscriber interface + Subscribe func(channelName string, channel chan<- Event) error + Unsubscribe func(channelName string, channel chan Event) error