pubsubinterfaces

Documentation

Index

• type Message
• type Pubsubber
• type Subscription

Types

type Message

type Message interface {
	GetData() []byte
}

PubsubMessage is the equivalent of a *pubsub.Message

type Pubsubber

type Pubsubber interface {
	Publish(topic string, data []byte) error
	Subscribe(topic string) (Subscription, error)
}

Pubsubber is ther interface needed for a client to a *pubsub.Pubsub

type Subscription

type Subscription interface {
	Next(context.Context) (Message, error)
	Cancel()
}

PubsubSubscription is the equivalent of a *pubsub.Subscription