Documentation ¶
Index ¶
- func Broker(ctx context.Context, config *configs.Config) error
- func Default() broker2.Broker
- func New(opts ...Option) (broker2.Broker, error)
- func NewWithConfig(ctx context.Context, cfg *Config, opts ...Option) (broker2.Broker, error)
- func SetBroker(b broker2.Broker)
- type Config
- type Option
- type Options
- type Type
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewWithConfig ¶
Types ¶
type Option ¶
type Option func(options *Options)
func WithBroker ¶
func WithDefaultGroup ¶
func WithTopicPrefix ¶
func WithTracer ¶
Click to show internal directories.
Click to hide internal directories.