helper

package

Go to main page

Versions in this module

v0

v0.29.1

Apr 15, 2022

v0.29.0

Apr 11, 2022

v0.28.0

Mar 28, 2022

Changes in this version

type Flusher

+ func (f *Flusher) SplitFunc(splitFunc bufio.SplitFunc) bufio.SplitFunc

+ func (f *Flusher) UpdateDataChangeTime(length int)

type ParserConfig

+ ScopeNameParser *ScopeNameParser

type ParserOperator

+ ScopeNameParser *ScopeNameParser

+ type ScopeNameParser struct

+ ParseFrom entry.Field

+ PreserveTo *entry.Field

+ func NewScopeNameParser() ScopeNameParser

+ func (p *ScopeNameParser) Parse(ent *entry.Entry) error

v0.27.2

Mar 17, 2022

v0.27.1

Mar 16, 2022

v0.27.0

Mar 10, 2022

v0.26.0

Feb 25, 2022

v0.25.0

Feb 21, 2022

v0.24.0

Dec 21, 2021

v0.23.0

Nov 30, 2021

Changes in this version

type Flusher

+ func (f *Flusher) Flush()

v0.22.0

Oct 5, 2021

Changes in this version

+ func SplitNone(maxLogSize int) bufio.SplitFunc

v0.21.0

Sep 9, 2021

Changes in this version

type BasicConfig

+ func (c *BasicConfig) SetID(id string)

v0.20.0

Jul 27, 2021

Changes in this version

+ type Flusher struct

+ func NewFlusher(forcePeriod Duration) *Flusher

+ func (f *Flusher) CheckAndFlush()

+ func (f *Flusher) Flushed()

+ func (f *Flusher) ForceFlushed()

+ func (f *Flusher) ShouldFlush() bool

+ type FlusherConfig struct

+ Period Duration

+ func NewFlusherConfig() FlusherConfig

+ func (c *FlusherConfig) Build() *Flusher

+ type Multiline struct

+ Force *Flusher

+ SplitFunc bufio.SplitFunc

+ type Splitter struct

+ Flusher *Flusher

+ SplitFunc bufio.SplitFunc

+ func (s *Splitter) CheckAndFlush()

+ func (s *Splitter) Flushed()

+ type SplitterConfig struct

+ Flusher FlusherConfig

+ Multiline MultilineConfig

+ func NewSplitterConfig() SplitterConfig

+ func (c *SplitterConfig) Build(encoding encoding.Encoding, flushAtEOF bool) (*Splitter, error)

v0.19.0

Jun 22, 2021

Changes in this version

+ type IPResolver struct

+ func NewIpResolver() *IPResolver

+ func (r *IPResolver) GetHostFromIp(ip string) (host string)

+ func (r *IPResolver) Stop()

type OutputConfig

+ func (c OutputConfig) BuildsMultipleOps() bool

type OutputOperator

+ func (o *OutputOperator) GetOutputIDs() []string

+ func (o *OutputOperator) SetOutputIDs(opIDs []string)

type WriterConfig

+ func (c WriterConfig) BuildsMultipleOps() bool

type WriterOperator

+ func (w *WriterOperator) GetOutputIDs() []string

+ func (w *WriterOperator) SetOutputIDs(opIds []string)

v0.18.0

May 11, 2021

Changes in this version

+ func NewLineEndSplitFunc(re *regexp.Regexp, flushAtEOF bool) bufio.SplitFunc

+ func NewLineStartSplitFunc(re *regexp.Regexp, flushAtEOF bool) bufio.SplitFunc

+ func NewNewlineSplitFunc(encoding encoding.Encoding, flushAtEOF bool) (bufio.SplitFunc, error)

+ type Encoding struct

+ Encoding encoding.Encoding

+ func (e *Encoding) Decode(msgBuf []byte) (string, error)

+ type EncodingConfig struct

+ Encoding string

+ func NewEncodingConfig() EncodingConfig

+ func (c EncodingConfig) Build(context operator.BuildContext) (Encoding, error)

+ type MultilineConfig struct

+ LineEndPattern string

+ LineStartPattern string

+ func NewMultilineConfig() MultilineConfig

+ func (c MultilineConfig) Build(context operator.BuildContext, encoding encoding.Encoding, flushAtEOF bool) (bufio.SplitFunc, error)

v0.17.0

Apr 7, 2021

Changes in this version

+ func UnmarshalMapstructure(input interface{}, result interface{}) error

type ByteSize

+ func (h *ByteSize) UnmarshalText(text []byte) (err error)

type ParserConfig

+ TraceParser *TraceParser

type ParserOperator

+ TraceParser *TraceParser

+ type SpanIdConfig struct

+ ParseFrom *entry.Field

+ PreserveTo *entry.Field

+ type TLSServerConfig struct

+ func NewTLSServerConfig(setting *configtls.TLSServerSetting) *TLSServerConfig

+ func (t *TLSServerConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type TraceFlagsConfig struct

+ ParseFrom *entry.Field

+ PreserveTo *entry.Field

+ type TraceIdConfig struct

+ ParseFrom *entry.Field

+ PreserveTo *entry.Field

+ type TraceParser struct

+ SpanId *SpanIdConfig

+ TraceFlags *TraceFlagsConfig

+ TraceId *TraceIdConfig

+ func NewTraceParser() TraceParser

+ func (t *TraceParser) Parse(entry *entry.Entry) error

+ func (t *TraceParser) Validate(context operator.BuildContext) error

v0.16.0

Mar 8, 2021

Changes in this version

+ func JSONUnmarshalerHook() mapstructure.DecodeHookFunc

+ type Attributer struct

+ func (l *Attributer) Attribute(e *entry.Entry) error

+ type AttributerConfig struct

+ Attributes map[string]ExprStringConfig

+ func NewAttributerConfig() AttributerConfig

+ func (c AttributerConfig) Build() (Attributer, error)

v0.15.1

Mar 1, 2021

Changes in this version

type ParserOperator

+ func (p *ParserOperator) ProcessWithCallback(ctx context.Context, entry *entry.Entry, parse ParseFunction, ...) error

v0.15.0

Feb 25, 2021

v0.14.0

Feb 2, 2021

Changes in this version

+ const DropOnError

+ const EpochKey

+ const GotimeKey

+ const HTTP2xx

+ const HTTP3xx

+ const HTTP4xx

+ const HTTP5xx

+ const NativeKey

+ const SendOnError

+ const StrptimeKey

+ var OffsetsBucket = []byte(`offsets`)

+ func GetExprEnv(e *entry.Entry) map[string]interface

+ func PutExprEnv(e map[string]interface{})

+ type BasicConfig struct

+ OperatorID string

+ OperatorType string

+ func NewBasicConfig(operatorID, operatorType string) BasicConfig

+ func (c BasicConfig) Build(context operator.BuildContext) (BasicOperator, error)

+ func (c BasicConfig) ID() string

+ func (c BasicConfig) Type() string

+ type BasicOperator struct

+ OperatorID string

+ OperatorType string

+ func (p *BasicOperator) ID() string

+ func (p *BasicOperator) Logger() *zap.SugaredLogger

+ func (p *BasicOperator) Start() error

+ func (p *BasicOperator) Stop() error

+ func (p *BasicOperator) Type() string

+ type ByteSize int64

+ func (h *ByteSize) UnmarshalJSON(raw []byte) error

+ func (h *ByteSize) UnmarshalYAML(unmarshal func(interface{}) error) error

+ type Duration struct

+ func NewDuration(t time.Duration) Duration

+ func (d *Duration) Raw() time.Duration

+ func (d *Duration) UnmarshalJSON(raw []byte) error

+ func (d *Duration) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (d Duration) MarshalJSON() ([]byte, error)

+ func (d Duration) MarshalYAML() (interface{}, error)

+ type ExprString struct

+ SubExprs []*vm.Program

+ SubStrings []string

+ func (e *ExprString) Render(env map[string]interface{}) (string, error)

+ type ExprStringConfig string

+ func (e ExprStringConfig) Build() (*ExprString, error)

+ type HostIdentifier struct

+ func (h *HostIdentifier) Identify(entry *entry.Entry)

+ type HostIdentifierConfig struct

+ IncludeHostname bool

+ IncludeIP bool

+ func NewHostIdentifierConfig() HostIdentifierConfig

+ func (c HostIdentifierConfig) Build() (HostIdentifier, error)

+ type Identifier struct

+ func (i *Identifier) Identify(e *entry.Entry) error

+ type IdentifierConfig struct

+ Resource map[string]ExprStringConfig

+ func NewIdentifierConfig() IdentifierConfig

+ func (c IdentifierConfig) Build() (Identifier, error)

+ type InputConfig struct

+ WriteTo entry.Field

+ func NewInputConfig(operatorID, operatorType string) InputConfig

+ func (c InputConfig) Build(context operator.BuildContext) (InputOperator, error)

+ type InputOperator struct

+ WriteTo entry.Field

+ func (i *InputOperator) CanProcess() bool

+ func (i *InputOperator) NewEntry(value interface{}) (*entry.Entry, error)

+ func (i *InputOperator) Process(ctx context.Context, entry *entry.Entry) error

+ type Labeler struct

+ func (l *Labeler) Label(e *entry.Entry) error

+ type LabelerConfig struct

+ Labels map[string]ExprStringConfig

+ func NewLabelerConfig() LabelerConfig

+ func (c LabelerConfig) Build() (Labeler, error)

+ type OutputConfig struct

+ func NewOutputConfig(operatorID, operatorType string) OutputConfig

+ func (c OutputConfig) Build(context operator.BuildContext) (OutputOperator, error)

+ type OutputIDs []string

+ func NewOutputIDsFromArray(array []interface{}) (OutputIDs, error)

+ func NewOutputIDsFromInterface(value interface{}) (OutputIDs, error)

+ func (o *OutputIDs) UnmarshalJSON(bytes []byte) error

+ func (o *OutputIDs) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (o OutputIDs) WithNamespace(bc operator.BuildContext) OutputIDs

+ type OutputOperator struct

+ func (o *OutputOperator) CanOutput() bool

+ func (o *OutputOperator) CanProcess() bool

+ func (o *OutputOperator) Outputs() []operator.Operator

+ func (o *OutputOperator) SetOutputs(operators []operator.Operator) error

+ type ParseFunction = func(interface{}) (interface{}, error)

+ type ParserConfig struct

+ ParseFrom entry.Field

+ ParseTo entry.Field

+ PreserveTo *entry.Field

+ SeverityParserConfig *SeverityParserConfig

+ TimeParser *TimeParser

+ func NewParserConfig(operatorID, operatorType string) ParserConfig

+ func (c ParserConfig) Build(context operator.BuildContext) (ParserOperator, error)

+ type ParserOperator struct

+ ParseFrom entry.Field

+ ParseTo entry.Field

+ PreserveTo *entry.Field

+ SeverityParser *SeverityParser

+ TimeParser *TimeParser

+ func (p *ParserOperator) ParseWith(ctx context.Context, entry *entry.Entry, parse ParseFunction) error

+ func (p *ParserOperator) ProcessWith(ctx context.Context, entry *entry.Entry, parse ParseFunction) error

+ type Persister interface

+ Get func(string) []byte

+ Load func() error

+ Set func(string, []byte)

+ Sync func() error

+ type ScopedBBoltPersister struct

+ func NewScopedDBPersister(db database.Database, scope string) *ScopedBBoltPersister

+ func (p *ScopedBBoltPersister) Get(key string) []byte

+ func (p *ScopedBBoltPersister) Load() error

+ func (p *ScopedBBoltPersister) Set(key string, val []byte)

+ func (p *ScopedBBoltPersister) Sync() error

+ type SeverityParser struct

+ Mapping severityMap

+ ParseFrom entry.Field

+ PreserveTo *entry.Field

+ func (p *SeverityParser) Parse(ent *entry.Entry) error

+ type SeverityParserConfig struct

+ Mapping map[interface{}]interface{}

+ ParseFrom *entry.Field

+ PreserveTo *entry.Field

+ Preset string

+ func NewSeverityParserConfig() SeverityParserConfig

+ func (c *SeverityParserConfig) Build(context operator.BuildContext) (SeverityParser, error)

+ type TimeParser struct

+ Layout string

+ LayoutType string

+ Location string

+ ParseFrom *entry.Field

+ PreserveTo *entry.Field

+ func NewTimeParser() TimeParser

+ func (t *TimeParser) IsZero() bool

+ func (t *TimeParser) Parse(entry *entry.Entry) error

+ func (t *TimeParser) Validate(context operator.BuildContext) error

+ type TransformFunction = func(*entry.Entry) error

+ type TransformerConfig struct

+ IfExpr string

+ OnError string

+ func NewTransformerConfig(operatorID, operatorType string) TransformerConfig

+ func (c TransformerConfig) Build(context operator.BuildContext) (TransformerOperator, error)

+ type TransformerOperator struct

+ IfExpr *vm.Program

+ OnError string

+ func (t *TransformerOperator) CanProcess() bool

+ func (t *TransformerOperator) HandleEntryError(ctx context.Context, entry *entry.Entry, err error) error

+ func (t *TransformerOperator) ProcessWith(ctx context.Context, entry *entry.Entry, transform TransformFunction) error

+ func (t *TransformerOperator) Skip(ctx context.Context, entry *entry.Entry) (bool, error)

+ type WriterConfig struct

+ OutputIDs OutputIDs

+ func NewWriterConfig(operatorID, operatorType string) WriterConfig

+ func (c WriterConfig) Build(bc operator.BuildContext) (WriterOperator, error)

+ type WriterOperator struct

+ OutputIDs OutputIDs

+ OutputOperators []operator.Operator

+ func (w *WriterOperator) CanOutput() bool

+ func (w *WriterOperator) Outputs() []operator.Operator

+ func (w *WriterOperator) SetOutputs(operators []operator.Operator) error

+ func (w *WriterOperator) Write(ctx context.Context, e *entry.Entry)

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