operator

Sep 9, 2021

Changes in this version

type Builder

+ SetID func(string)

Jun 22, 2021

Changes in this version

type Builder

+ BuildsMultipleOps func() bool

type Operator

+ GetOutputIDs func() []string

+ SetOutputIDs func([]string)

May 11, 2021

Changes in this version

+ type Persister interface

+ Delete func(context.Context, string) error

+ Get func(context.Context, string) ([]byte, error)

+ Set func(context.Context, string, []byte) error

+ func NewScopedPersister(s string, p Persister) Persister

Feb 2, 2021

Changes in this version

+ var DefaultRegistry = NewRegistry()

+ func Lookup(configType string) (func() Builder, bool)

+ func Register(operatorType string, newBuilder func() Builder)

+ func RegisterPlugin(pluginName string, newBuilder func() Builder)

+ type BuildContext struct

+ Database database.Database

+ DefaultOutputIDs []string

+ Logger *logger.Logger

+ Namespace string

+ Parameters map[string]interface{}

+ PluginDepth int

+ func NewBuildContext(db database.Database, lg *zap.SugaredLogger) BuildContext

+ func (bc BuildContext) Copy() BuildContext

+ func (bc BuildContext) PrependNamespace(id string) string

+ func (bc BuildContext) WithDefaultOutputIDs(ids []string) BuildContext

+ func (bc BuildContext) WithIncrementedDepth() BuildContext

+ func (bc BuildContext) WithSubNamespace(namespace string) BuildContext

+ type Builder interface

+ Build func(BuildContext) ([]Operator, error)

+ ID func() string

+ Type func() string

+ type Config struct

+ func (c *Config) UnmarshalJSON(bytes []byte) error

+ func (c *Config) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (c Config) MarshalJSON() ([]byte, error)

+ func (c Config) MarshalYAML() (interface{}, error)

+ type Operator interface

+ CanOutput func() bool

+ CanProcess func() bool

+ ID func() string

+ Logger func() *zap.SugaredLogger

+ Outputs func() []Operator

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

+ SetOutputs func([]Operator) error

+ Start func() error

+ Stop func() error

+ Type func() string

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Lookup(configType string) (func() Builder, bool)

+ func (r *Registry) Register(operatorType string, newBuilder func() Builder)

+ func (r *Registry) RegisterPlugin(pluginName string, newBuilder func() Builder)