publisher

Documentation

Index

• Variables
• type Message
• type Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithMetrics(registerer metrics.Registerer) Option
• type Publisher
  • func NewPublisher(topic *pubsub.Topic, opts ...Option) Publisher

Variables

var (
	ErrBadMessage = errors.New("publisher: bad message")
)

Types

type Message

type Message interface {
	GetId() string
	protoiface.MessageV1
}

type Option

type Option func(*options)

func WithLogger

func WithLogger(logger *zap.Logger) Option

func WithMetrics

func WithMetrics(registerer metrics.Registerer) Option

type Publisher

type Publisher interface {
	Publish(ctx context.Context, msg Message) error
	PublishMulti(ctx context.Context, messages []Message) map[string]error
	Stop()
}

func NewPublisher

func NewPublisher(topic *pubsub.Topic, opts ...Option) Publisher