subscriber

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

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

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)
}