summary

Documentation

Index

• type Echo
  • func NewEcho(predicate logentry.Predicate) (e *Echo)
  • func (e *Echo) NumberOfLinesAfterSummarizeAsyncCompleted() int
  • func (e *Echo) String() string
  • func (e *Echo) StringAfterSummarizeAsyncCompleted() string
  • func (e *Echo) Summarize(entries <-chan logentry.LogEntry)
  • func (e *Echo) SummarizeAsync(entries <-chan logentry.LogEntry)
• type GrokCounter
  • func NewGrokCounter(patternsByName map[string]string, predicate logentry.Predicate) (tc *GrokCounter)
  • func NewGrokCounterWithLanguageTag(locale language.Tag, patternsByName map[string]string, ...) (tc *GrokCounter)
  • func NewGrokCounterWithLocale(locale string, patternsByName map[string]string, predicate logentry.Predicate) (tc *GrokCounter)
  • func (tc *GrokCounter) String() string
  • func (tc *GrokCounter) StringAfterSummarizeAsyncCompleted() string
  • func (tc *GrokCounter) Summarize(entries <-chan logentry.LogEntry)
  • func (tc *GrokCounter) SummarizeAsync(entries <-chan logentry.LogEntry)
• type Multiplexer
  • func NewMultiplexer() *Multiplexer
  • func (m *Multiplexer) AddSummarizer(s Summarizer)
  • func (m *Multiplexer) StringAfterSummarizeAsyncCompleted() string
  • func (m *Multiplexer) Summarize(channels []chan logentry.LogEntry, entries <-chan logentry.LogEntry)
  • func (m *Multiplexer) SummarizeAsync(entries <-chan logentry.LogEntry)
• type Summarizer
• type TagCounter
  • func NewTagCounter(predicate logentry.Predicate) (tc *TagCounter)
  • func NewTagCounterWithLanguageTag(locale language.Tag, predicate logentry.Predicate) (tc *TagCounter)
  • func NewTagCounterWithLocale(locale string, predicate logentry.Predicate) (tc *TagCounter)
  • func (tc *TagCounter) String() string
  • func (tc *TagCounter) StringAfterSummarizeAsyncCompleted() string
  • func (tc *TagCounter) Summarize(entries <-chan logentry.LogEntry)
  • func (tc *TagCounter) SummarizeAsync(entries <-chan logentry.LogEntry)

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)