Versions in this module Expand all Collapse all v0 v0.0.2 Jan 2, 2024 v0.0.1 Dec 19, 2023 Changes in this version + var Factories = []func(config config.Config, control Controller) (topic string, listener Listener, err error) + func Start(ctx context.Context, config config.Config, control Controller) (err error) + type Consumer struct + func NewConsumer(ctx context.Context, broker string, groupid string, topic string, ...) (consumer *Consumer, err error) + type Controller interface + DeleteUser func(userId string) error + type Listener func(msg []byte) (err error) + func UsersListenerFactory(config config.Config, control Controller) (topic string, listener Listener, err error) + type UserCommandMsg struct + Command string + Id string