publisher

Documentation

Index

• Variables
• type NewPublisherFunc
• type Options
• type Publisher

Variables

var (
	Providers = map[string]NewPublisherFunc{}
)

Types

type NewPublisherFunc

type NewPublisherFunc func(opts *Options) (Publisher, error)

type Options

type Options struct {
	Name   string
	Config interface{}
	Logger logger.Logger
}

type Publisher

type Publisher interface {
	Connect(ctx context.Context) (err error)
	Disconnect(ctx context.Context) (err error)
	Publish(ctx context.Context, payload []byte) (err error)
}