pubsub

Documentation

Index

• Variables
• type PubSub
• type Subscriber

Variables

var ErrUnsubscribed = errors.New("unsubscribed")

Types

type PubSub

type PubSub interface {
	Subscribe(_ context.Context, topic string) (Subscriber, error)
	Publish(_ context.Context, topic string, payload []byte) error
}

type Subscriber

type Subscriber interface {
	Unsubscribe(context.Context) error

	// Returns ErrUnsubscribed if unsubscribed.
	Consume(context.Context) ([]byte, error)
}