segment

package

v0.1.5 Latest Latest Go to latest Published: Oct 30, 2020 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	// contains filtered or unexported fields
}

func New(cfg Config) *Client

func (c *Client) Brokers(ctx context.Context) (result []types.Broker, err error)

func (c *Client) ConsumerGroups(ctx context.Context) (result []types.ConsumerGroup, err error)

func (c *Client) Offsets(ctx context.Context) (result []types.Offset, err error)

func (c *Client) OffsetsForConsumerGroups(ctx context.Context) (result []types.Offset, err error)

func (c *Client) Topics(ctx context.Context) (result []types.Topic, err error)

type Config struct {
	Broker        string
	SASLUsername  string
	SASLPassword  string
	SALSMechanism string
	TLSEnabled    bool
}