maddy

 1package pubsub
 2
 3import "context"
 4
 5type PubSub interface {
 6	Subscribe(ctx context.Context, key string) error
 7	Unsubscribe(ctx context.Context, key string) error
 8	Publish(key, payload string) error
 9	Listener() chan Msg
10	Close() error
11}