broker

type Broker interface {
	// Open establish connection to the target server.
	Open(ctx context.Context) error
	// Publish publish the message to the target topic.
	Publish(ctx context.Context, topic string, m *Message, opts ...PublishOption) error
	// Subscribe subscribe to the topic to consume messages.
	Subscribe(ctx context.Context, topic string, h Handler, opts ...SubscribeOption) (Subscriber, error)
	// Close flush all in-flight messages and close underlying connection.
	// Close allows a context to control the duration
	// of a flush/close call. This context should be non-nil.
	// If a deadline is not set, a default deadline of 5s will be applied.
	Close(context.Context) error
}

type Event interface {
	Topic() string
	Message() *Message
	Ack() error
}

type Handler = func(Event) error

type Message struct {
	Header map[string]string `` /* 153-byte string literal not displayed */
	Body   []byte            `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type PublishOption func(*PublishOptions)

type PublishOptions struct {
}

type SubscribeOption func(*SubscribeOptions)

type SubscribeOptions struct {
	// AutoAck defaults to true. When a handler returns
	// with a nil error the message is acked.
	AutoAck bool
	// Subscribers with the same queue name
	// will create a shared subscription where each
	// receives a subset of messages.
	Queue string
}

type Subscriber interface {
	Topic() string
	Unsubscribe() error
}