pipeline

package

Go to main page

Versions in this module

v0

v0.2.2

Dec 7, 2021

v0.2.1

Dec 7, 2021

v0.2.0

Dec 6, 2021

Changes in this version

+ const DefaultAvgInputEventSize

+ const DefaultEventTimeout

+ const DefaultMaxInputEventSize

+ const DefaultWaitForPanicTimeout

type Pipeline

+ func (p *Pipeline) SetupHTTPHandlers(mux *http.ServeMux)

type PluginStaticInfo

+ Endpoints map[string]func(http.ResponseWriter, *http.Request)

type Settings

+ AvgEventSize int

+ EventTimeout time.Duration

+ MaxEventSize int

v0.1.12

Sep 1, 2021

Changes in this version

type ActionPluginStaticInfo

+ MatchInvert bool

type InputPluginController

+ UseSpread func()

type Pipeline

+ func (p *Pipeline) UseSpread()

v0.1.11

Jul 16, 2021

v0.1.7

Nov 13, 2020

Changes in this version

type InputPluginController

+ SuggestDecoder func(t decoder.DecoderType)

type OutputPluginController

+ Error func(err string)

type Pipeline

+ func (p *Pipeline) Error(err string)

+ func (p *Pipeline) SuggestDecoder(t decoder.DecoderType)

type PluginStaticInfo

+ AdditionalActions []string

type Settings

+ IsStrict bool

v0.1.2

Mar 6, 2020

Changes in this version

+ const DefaultAvgLogSize

+ const DefaultCapacity

+ const DefaultFieldValue

+ const DefaultJSONNodePoolSize

+ const DefaultMaintenanceInterval

+ const DefaultStreamField

+ const DefaultStreamName

+ func ByteToStringUnsafe(b []byte) string

+ func NewProcessor(metricsHolder *metricsHolder, activeCounter *atomic.Int32, output OutputPlugin, ...) *processor

+ func ParseFormatName(formatName string) (string, error)

+ func ParseLevel(level string) int

+ func StringToByteUnsafe(s string) []byte

+ func TrimSpaceFunc(r rune) bool

+ type ActionPlugin interface

+ Do func(*Event) ActionResult

+ Start func(config AnyConfig, params *ActionPluginParams)

+ Stop func()

+ type ActionPluginController interface

+ Commit func(event *Event)

+ Propagate func(event *Event)

+ type ActionPluginInfo struct

+ type ActionPluginParams struct

+ Controller ActionPluginController

+ Logger *zap.SugaredLogger

+ type ActionPluginStaticInfo struct

+ MatchConditions MatchConditions

+ MatchMode MatchMode

+ MetricLabels []string

+ MetricName string

+ type ActionResult int

+ const ActionCollapse

+ const ActionDiscard

+ const ActionHold

+ const ActionPass

+ type AnyConfig interface

+ type AnyPlugin interface

+ type Batch struct

+ Events []*Event

+ type Batcher struct

+ func NewBatcher(pipelineName string, outputType string, outFn BatcherOutFn, ...) *Batcher

+ func (b *Batcher) Add(event *Event)

+ func (b *Batcher) Start()

+ func (b *Batcher) Stop()

+ type BatcherMaintenanceFn func(*WorkerData)

+ type BatcherOutFn func(*WorkerData, *Batch)

+ type Event struct

+ Buf []byte

+ Offset int64

+ Root *insaneJSON.Root

+ SeqID uint64

+ Size int

+ SourceID SourceID

+ SourceName string

+ func (e *Event) Encode(outBuf []byte) ([]byte, int)

+ func (e *Event) IsIgnoreKind() bool

+ func (e *Event) IsRegularKind() bool

+ func (e *Event) IsTimeoutKind() bool

+ func (e *Event) IsUnlockKind() bool

+ func (e *Event) SetIgnoreKind()

+ func (e *Event) SetTimeoutKind()

+ func (e *Event) SetUnlockKind()

+ func (e *Event) StreamNameBytes() []byte

+ func (e *Event) String() string

+ func (e *Event) SubparseJSON(json []byte) (*insaneJSON.Node, error)

+ type InputPlugin interface

+ Commit func(*Event)

+ Start func(config AnyConfig, params *InputPluginParams)

+ Stop func()

+ type InputPluginController interface

+ DisableStreams func()

+ In func(sourceID SourceID, sourceName string, offset int64, data []byte, ...) uint64

+ type InputPluginInfo struct

+ type InputPluginParams struct

+ Controller InputPluginController

+ Logger *zap.SugaredLogger

+ type MatchCondition struct

+ Field string

+ Regexp *regexp.Regexp

+ Value string

+ type MatchConditions []MatchCondition

+ type MatchMode int

+ const MatchModeAnd

+ const MatchModeOr

+ const MatchModeUnknown

+ type OutputPlugin interface

+ Out func(*Event)

+ Start func(config AnyConfig, params *OutputPluginParams)

+ Stop func()

+ type OutputPluginController interface

+ Commit func(event *Event)

+ type OutputPluginInfo struct

+ type OutputPluginParams struct

+ Controller OutputPluginController

+ Logger *zap.SugaredLogger

+ type Pipeline struct

+ Name string

+ Procs []*processor

+ func New(name string, settings *Settings, registry *prometheus.Registry, ...) *Pipeline

+ func (p *Pipeline) AddAction(info *ActionPluginStaticInfo)

+ func (p *Pipeline) Commit(event *Event)

+ func (p *Pipeline) DisableParallelism()

+ func (p *Pipeline) DisableStreams()

+ func (p *Pipeline) EnableEventLog()

+ func (p *Pipeline) GetEventLogItem(index int) string

+ func (p *Pipeline) GetEventsTotal() int

+ func (p *Pipeline) GetInput() InputPlugin

+ func (p *Pipeline) GetOutput() OutputPlugin

+ func (p *Pipeline) In(sourceID SourceID, sourceName string, offset int64, bytes []byte, ...) uint64

+ func (p *Pipeline) SetInput(info *InputPluginInfo)

+ func (p *Pipeline) SetOutput(info *OutputPluginInfo)

+ func (p *Pipeline) Start()

+ func (p *Pipeline) Stop()

+ type PluginDefaultParams struct

+ PipelineName string

+ PipelineSettings *Settings

+ type PluginFactory func() (AnyPlugin, AnyConfig)

+ type PluginKind string

+ const PluginKindAction

+ const PluginKindInput

+ const PluginKindOutput

+ type PluginRuntimeInfo struct

+ ID string

+ Plugin AnyPlugin

+ type PluginStaticInfo struct

+ Config AnyConfig

+ Factory PluginFactory

+ Type string

+ type Settings struct

+ AntispamThreshold int

+ AvgLogSize int

+ Capacity int

+ Decoder string

+ MaintenanceInterval time.Duration

+ StreamField string

+ type SourceID uint64

+ type StreamName string

+ type WorkerData interface

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