subscriber

Documentation

Index

• Variables
• type NewSubscriberFunc
• type Options
• type Subscriber

Variables

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

Types

type NewSubscriberFunc

type NewSubscriberFunc func(opts *Options) (Subscriber, error)

type Options

type Options struct {
	Name     string
	Config   interface{}
	Logger   logger.Logger
	Callback func()
}

type Subscriber

type Subscriber interface {
	Connect(ctx context.Context) (err error)
	Disconnect(ctx context.Context) (err error)
	Subscribe(ctx context.Context) (err error)
	Unsubscribe(ctx context.Context) (err error)
}