Versions in this module Expand all Collapse all v0 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