pubsub

Documentation

Index

• type PubSub
• type Publisher
• type Subscriber
• type Subscription

Types

type PubSub

type PubSub interface {
	Publisher
	Subscriber
}

type Publisher

type Publisher interface {
	Publish(ctx context.Context, topic string, message []byte) error
}

type Subscriber

type Subscriber interface {
	Subscribe(ctx context.Context, topic string) (Subscription, error)
}

type Subscription

type Subscription interface {
	Messages(ctx context.Context) <-chan []byte
	Cancel(ctx context.Context) error
}