Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Broker ¶
type Broker struct {
// contains filtered or unexported fields
}
BrokerWrapper is a struct that wrap the broker provider (gcp, rabbitmq, etc) and handle with message encode/decode
func (*Broker) GracefulStop ¶
GracefulStop graceful stop all subscriptions
func (*Broker) Init ¶
func (b *Broker) Init(opts *InitOptions)
type BrokerProvider ¶
type InitOptions ¶
type SubscribeHandler ¶
Click to show internal directories.
Click to hide internal directories.