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 + var Table goka.Table = goka.GroupTable(group) + func PrepareTopics(brokers []string) + func Run(ctx context.Context, brokers []string) func() error + type MessageListCodec struct + func (c *MessageListCodec) Decode(data []byte) (interface{}, error) + func (c *MessageListCodec) Encode(value interface{}) ([]byte, error)
Go to main page