broker

type Broker interface {
	Options() Options
	NewPublisher(topic string, opts ...PublishOption) (pub Publisher, err error)
	NewSubscriber(subscription string, hdlr Handler, opts ...SubscribeOption) (sub Subscriber, err error)
	Start() error
	Shutdown() error
}

type Handler func(context.Context, event.Event) cloudevents.Result

type Option func(*Options)

type Options struct {
	Name string

	// Alternative options
	Context context.Context
}

type PublishOption func(*PublishOptions)

type PublishOptions struct {
	// publishes msg to the topic asynchronously if set to true.
	// Default false. i.e., publishes synchronously(blocking)
	Async bool
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Publisher interface {
	Publish(ctx context.Context, event event.Event) error
	Stop()
}

type SubscribeOption func(*SubscribeOptions)

type SubscribeOptions struct {
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Subscriber interface {
	Start()
	Stop()
}