summary

package
v0.0.0-...-584518c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 20, 2022 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Echo

type Echo struct {
	// contains filtered or unexported fields
}

func NewEcho

func NewEcho(predicate logentry.Predicate) (e *Echo)

func (*Echo) NumberOfLinesAfterSummarizeAsyncCompleted

func (e *Echo) NumberOfLinesAfterSummarizeAsyncCompleted() int

func (*Echo) String

func (e *Echo) String() string

func (*Echo) StringAfterSummarizeAsyncCompleted

func (e *Echo) StringAfterSummarizeAsyncCompleted() string

func (*Echo) Summarize

func (e *Echo) Summarize(entries <-chan logentry.LogEntry)

func (*Echo) SummarizeAsync

func (e *Echo) SummarizeAsync(entries <-chan logentry.LogEntry)

type GrokCounter

type GrokCounter struct {
	// contains filtered or unexported fields
}

func NewGrokCounter

func NewGrokCounter(patternsByName map[string]string, predicate logentry.Predicate) (tc *GrokCounter)

func NewGrokCounterWithLanguageTag

func NewGrokCounterWithLanguageTag(locale language.Tag, patternsByName map[string]string, predicate logentry.Predicate) (tc *GrokCounter)

func NewGrokCounterWithLocale

func NewGrokCounterWithLocale(locale string, patternsByName map[string]string, predicate logentry.Predicate) (tc *GrokCounter)

func (*GrokCounter) String

func (tc *GrokCounter) String() string

func (*GrokCounter) StringAfterSummarizeAsyncCompleted

func (tc *GrokCounter) StringAfterSummarizeAsyncCompleted() string

func (*GrokCounter) Summarize

func (tc *GrokCounter) Summarize(entries <-chan logentry.LogEntry)

func (*GrokCounter) SummarizeAsync

func (tc *GrokCounter) SummarizeAsync(entries <-chan logentry.LogEntry)

type Multiplexer

type Multiplexer struct {
	Summarizers []Summarizer
}

func NewMultiplexer

func NewMultiplexer() *Multiplexer

func (*Multiplexer) AddSummarizer

func (m *Multiplexer) AddSummarizer(s Summarizer)

func (*Multiplexer) StringAfterSummarizeAsyncCompleted

func (m *Multiplexer) StringAfterSummarizeAsyncCompleted() string

func (*Multiplexer) Summarize

func (m *Multiplexer) Summarize(channels []chan logentry.LogEntry, entries <-chan logentry.LogEntry)

func (*Multiplexer) SummarizeAsync

func (m *Multiplexer) SummarizeAsync(entries <-chan logentry.LogEntry)

type Summarizer

type Summarizer interface {
	SummarizeAsync(entries <-chan logentry.LogEntry)
	StringAfterSummarizeAsyncCompleted() string
}

type TagCounter

type TagCounter struct {
	// contains filtered or unexported fields
}

func NewTagCounter

func NewTagCounter(predicate logentry.Predicate) (tc *TagCounter)

func NewTagCounterWithLanguageTag

func NewTagCounterWithLanguageTag(locale language.Tag, predicate logentry.Predicate) (tc *TagCounter)

func NewTagCounterWithLocale

func NewTagCounterWithLocale(locale string, predicate logentry.Predicate) (tc *TagCounter)

func (*TagCounter) String

func (tc *TagCounter) String() string

func (*TagCounter) StringAfterSummarizeAsyncCompleted

func (tc *TagCounter) StringAfterSummarizeAsyncCompleted() string

func (*TagCounter) Summarize

func (tc *TagCounter) Summarize(entries <-chan logentry.LogEntry)

func (*TagCounter) SummarizeAsync

func (tc *TagCounter) SummarizeAsync(entries <-chan logentry.LogEntry)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL