multiline

Jul 12, 2026

Changes in this version

type Entry

+ Texts []string

type Option

+ func WithoutText() Option

Jul 12, 2026

Changes in this version

type Aggregator

+ func (a *Aggregator[T]) Bytes() int

+ func (a *Aggregator[T]) Len() int

+ func (a *Aggregator[T]) Pending(key string) bool

type Entry

+ When time.Time

Jul 5, 2026

Changes in this version

+ type Aggregator struct

+ func New[T any](emit Emitter[T], opts ...Option) *Aggregator[T]

+ func (a *Aggregator[T]) Add(ctx context.Context, key, line string, data T) error

+ func (a *Aggregator[T]) AddAt(ctx context.Context, key, line string, when time.Time, data T) error

+ func (a *Aggregator[T]) Flush(ctx context.Context, key string) error

+ func (a *Aggregator[T]) FlushBefore(ctx context.Context, t time.Time) error

+ func (a *Aggregator[T]) Stop(ctx context.Context) error

+ type Emitter func(ctx context.Context, entry Entry[T]) error

+ type Entry struct

+ Data T

+ Key string

+ Lines int

+ Match string

+ Text string

+ Truncated bool

+ type Matcher interface

+ Format func(index int) string

+ Step func(line string, active []int) (next []int, accepted int)

+ type Option func(*config)

+ func WithClock(now func() time.Time) Option

+ func WithMatcher(matcher Matcher) Option

+ func WithMaxBytes(n int) Option

+ func WithMaxGroups(n int) Option

+ func WithMaxLines(n int) Option