processors

type Base struct {
	Send                  PacketSender
	NewPacket             PacketBuilder
	Logger                Logger
	Memory                Memory
	WebHook               WebHook
	Store                 IStore
	ConfigWorkingLocation string
	DataLocation          string
	PipelineUUID          string
	Name                  string
	Label                 string
}

type CommonOptions struct {
	// If this filter is successful, add any arbitrary fields to this event.
	AddField map[string]interface{} `mapstructure:"add_field"`

	// If this filter is successful, add arbitrary tags to the event. Tags can be dynamic
	// and include parts of the event using the %{field} syntax.
	AddTag []string `mapstructure:"add_tag"`

	// Add a type field to all events handled by this input
	Type string `mapstructure:"type"`

	// If this filter is successful, remove arbitrary fields from this event. Example:
	// ` kv {
	// `   remove_field => [ "foo_%{somefield}" ]
	// ` }
	RemoveField []string `mapstructure:"remove_field"`

	// If this filter is successful, remove arbitrary tags from the event. Tags can be dynamic and include parts of the event using the %{field} syntax.
	// Example:
	// ` kv {
	// `   remove_tag => [ "foo_%{somefield}" ]
	// ` }
	// If the event has field "somefield" == "hello" this filter, on success, would remove the tag foo_hello if it is present. The second example would remove a sad, unwanted tag as well.
	RemoveTag []string `mapstructure:"remove_tag"`

	// Log each event produced by the processor (usefull while building or debugging a pipeline)
	Trace bool `mapstructure:"trace"`
}

type ICodec interface {
	GetName() string
	GetOptions() map[string]interface{}
	GetRole() string
}

type IPacket interface {
	Message() string
	Fields() *mxj.Map

	SetMessage(string)
	SetFields(map[string]interface{})

	Clone() IPacket
}

type IStore interface {
	Get(string, string) ([]byte, error) // Get(key, bucket)
	Set(string, string, []byte) error   // Set(key, bucket, value)
	Delete(string, string) error        // Delete(key, bucket)
	Has(string, string) (bool, error)   // Has(key, bucket)
}

type Logger interface {
	Debug(args ...interface{})
	Debugf(format string, args ...interface{})
	Debugln(args ...interface{})

	Error(args ...interface{})
	Errorf(format string, args ...interface{})
	Errorln(args ...interface{})

	Fatal(args ...interface{})
	Fatalf(format string, args ...interface{})
	Fatalln(args ...interface{})

	Info(args ...interface{})
	Infof(format string, args ...interface{})
	Infoln(args ...interface{})

	Panic(args ...interface{})
	Panicf(format string, args ...interface{})
	Panicln(args ...interface{})

	Print(args ...interface{})
	Printf(format string, args ...interface{})
	Println(args ...interface{})

	Warn(args ...interface{})
	Warnf(format string, args ...interface{})
	Warning(args ...interface{})
	Warningf(format string, args ...interface{})
	Warningln(args ...interface{})
	Warnln(args ...interface{})
}

type Memory interface {
	Set(name string, value interface{})
	Get(name string) (interface{}, bool)
	Delete(name string)
	Items() map[string]interface{}
}

type PacketBuilder func(map[string]interface{}) IPacket

type PacketSender func(IPacket, ...int) bool

type Processor interface {
	B() *Base
	Configure(ProcessorContext, map[string]interface{}) error
	Start(IPacket) error
	Tick(IPacket) error
	Receive(IPacket) error
	Stop(IPacket) error
	Doc() *doc.Processor
	MaxConcurent() int
	SetPipelineUUID(string)
	SetProcessorIdentifiers(string, string)
}

type ProcessorContext interface {
	Log() Logger
	PacketSender() PacketSender
	PacketBuilder() PacketBuilder
	Memory() Memory
	WebHook() WebHook
	ConfigWorkingLocation() string
	DataLocation() string
	Store() IStore
}

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

type SinceDBOptions struct {
	Identifier    string
	WriteInterval int
	Storage       IStore
}

type WebHook interface {
	Add(string, http.HandlerFunc)
	AddShort(string, http.HandlerFunc)
	Unregister()
}