Versions in this module Expand all Collapse all v0 v0.0.5 Mar 12, 2026 v0.0.4 Jul 25, 2025 v0.0.3 Jun 6, 2025 v0.0.2 Jan 22, 2022 v0.0.1 Oct 17, 2020 Changes in this version + type Consumer interface + Run func(ctx context.Context, messageChan chan message) error + type Digger struct + Processors []Processor + SourceConsumer Consumer + func (d *Digger) Run(ctx context.Context) error + type FileConsumer struct + Paths []string + Recursive bool + func (f *FileConsumer) Run(ctx context.Context, messageChan chan message) error + type KafkaConsumer struct + Address string + MaxBytes int + MinBytes int + Offset int64 + Partitions []kafka.Partition + Since time.Duration + Topic string + Until time.Duration + func (k *KafkaConsumer) Run(ctx context.Context, messageChan chan message) error + type LiveStats struct + func NewLiveStats(config LiveStatsConfig) (*LiveStats, error) + func (l *LiveStats) Process(ctx context.Context, messageObj message) error + func (l *LiveStats) Stop() error + func (l *LiveStats) Summary() string + type LiveStatsConfig struct + Filter string + K int + Numeric bool + PathsStr string + PrintMissing bool + ProtoTypes []string + Raw bool + RawExtended bool + SortByName bool + type Processor interface + Process func(context.Context, message) error + Stop func() error + Summary func() string + type S3Consumer struct + Bucket string + NumWorkers int + Prefixes []string + S3Client *s3.S3 + func (s *S3Consumer) Run(ctx context.Context, messageChan chan message) error
Go to main page