Versions in this module Expand all Collapse all v0 v0.0.5 Dec 23, 2023 v0.0.2 Dec 23, 2023 Changes in this version + type Controller struct + func NewController(hosts []string, options ...ControllerOption) *Controller + func (c *Controller) Publish(ctx context.Context, channel string, um extensions.BrokerMessage) error + func (c *Controller) Subscribe(ctx context.Context, channel string) (extensions.BrokerChannelSubscription, error) + type ControllerOption func(controller *Controller) + func WithGroupID(groupID string) ControllerOption + func WithLogger(logger extensions.Logger) ControllerOption + func WithMaxBytes(maxBytes int) ControllerOption + func WithPartition(partition int) ControllerOption
Go to main page