Versions in this module Expand all Collapse all v0 v0.1.35 Aug 9, 2026 v0.1.34 Aug 3, 2026 Changes in this version + type Aggregator struct + func NewAggregator(topic string) *Aggregator + func (a *Aggregator) Add(msg api.Message) + func (a *Aggregator) Count() int64 + func (a *Aggregator) Result() api.TopicAnalysisResult + type ConsumeFunc func(ctx context.Context, topic string, flags api.ConsumeFlags, ...) error + type Registry struct + func NewRegistry(consume ConsumeFunc) *Registry + func (reg *Registry) Cancel(topic string) error + func (reg *Registry) Get(topic string) (*api.TopicAnalysis, error) + func (reg *Registry) Start(ctx context.Context, topic string, totalOffsets int64) error
Go to main page