pubsub

Documentation

Overview

Provides a super minimal publish/subscribe interface with backend implementations for different providers

Index

• type CompletePublisher
• type Message
• type Publisher
• type Subscriber

Types

type CompletePublisher

type CompletePublisher interface {
	PublishUntilComplete(context.Context, []byte, map[string]string) error
}

A CompletePublisher takes some data and publishes it on a topic and returns errors, if any

type Message

type Message interface {
	Data() []byte
	Attrs() map[string]string
	Ack()
	Nack()
	EnrichContext(context.Context) context.Context
}

A Message is a pubsub message to be consumed by a Worker

type Publisher

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

A Publisher takes some data and publishes it on a topic

type Subscriber

type Subscriber interface {
	Subscribe(context.Context) (<-chan Message, error)
}

A Subscriber streams a channel of Message