Versions in this module Expand all Collapse all v0 v0.0.3 Nov 7, 2024 v0.0.2 Nov 7, 2024 Changes in this version type Cluster + Kraft bool v0.0.1 Jul 20, 2023 Changes in this version + var ErrBrokerAlreadyStarted = errors.New("broker already started") + var ErrBrokerNotConnected = errors.New("broker not connected") + var ErrBrokerWasNotStarted = errors.New("broker was not started") + type Cluster struct + Brokers int + HealthProbe bool + Topics []string + func (c *Cluster) BrokerAddresses() []string + func (c *Cluster) Start(ctx context.Context) error + func (c *Cluster) Stop(ctx context.Context) error
Go to main page