pubsub

Documentation

Index

• Variables
• type Message
• type PubSubPublisher
  • func NewPublisher(ctx context.Context, cfg *config.PubSub) (*PubSubPublisher, error)
  • func (p *PubSubPublisher) AsyncPublish(ctx context.Context, msg Message) PublishResult
  • func (p *PubSubPublisher) Close() error
• type PublishResult
• type Publisher

Variables

var Set = wire.NewSet(
	wire.Bind(new(Publisher), new(*PubSubPublisher)),
	NewPublisher,
)

Types

type Message

type Message struct {
	Data        []byte
	Attributes  map[string]string
	OrderingKey string
}

type PubSubPublisher

type PubSubPublisher struct {
	// contains filtered or unexported fields
}

PubSubPublisher is a publisher for Google Cloud Pub/Sub.

func NewPublisher

func NewPublisher(ctx context.Context, cfg *config.PubSub) (*PubSubPublisher, error)

NewPublisher creates a new publisher.

func (*PubSubPublisher) AsyncPublish

func (p *PubSubPublisher) AsyncPublish(ctx context.Context, msg Message) PublishResult

Publish publishes a message to the topic.

func (*PubSubPublisher) Close

func (p *PubSubPublisher) Close() error

Close closes the publisher.

type PublishResult

type PublishResult interface {
	Ready() <-chan struct{}
	Get(ctx context.Context) (serverID string, err error)
}

PublishResult is an interface for pubsub.PublishResult.

type Publisher

type Publisher interface {
	AsyncPublish(ctx context.Context, msg Message) PublishResult
}

Pulisher is an interface for PubSub Publisher.