Versions in this module Expand all Collapse all v0 v0.2.0 Dec 1, 2022 v0.1.0 Dec 1, 2022 Changes in this version + func PrepareTopics(brokers []string) + func Run(ctx context.Context, brokers []string) func() error + type Counters struct + Received int + Sent int + type CountersCodec struct + func (c *CountersCodec) Decode(data []byte) (interface{}, error) + func (c *CountersCodec) Encode(value interface{}) ([]byte, error)
Go to main page