processors

type EntryEncoder interface {
	Encode(*entry.Entry) error
	Reset(io.Writer)
}

type Forwarder struct {
	ForwarderConfig
	sync.Mutex
	// contains filtered or unexported fields
}

type ForwarderConfig struct {
	Target                   string
	Protocol                 string
	Delimiter                string
	Format                   string
	Tag                      []string
	Regex                    []string
	Source                   []string
	Timeout                  uint //timeout in seconds for a write
	Buffer                   uint //number of entries in flight (basically channel buffer size)
	Non_Blocking             bool
	Insecure_Skip_TLS_Verify bool
}

type GzipDecompressor struct {
	GzipDecompressorConfig
	// contains filtered or unexported fields
}

type GzipDecompressorConfig struct {
	Passthrough_Non_Gzip bool
}

type JsonArraySplitConfig struct {
	Passthrough_Misses bool
	Extraction         string
	Force_JSON_Object  bool
}

type JsonArraySplitter struct {
	JsonArraySplitConfig
	// contains filtered or unexported fields
}

type JsonExtractConfig struct {
	Passthrough_Misses bool
	Strict_Extraction  bool
	Force_JSON_Object  bool
	Extractions        string
}

type JsonExtractor struct {
	JsonExtractConfig
	// contains filtered or unexported fields
}

type JsonFilter struct {
	JsonFilterConfig
	// contains filtered or unexported fields
}

type JsonFilterConfig struct {
	// what to do when an entry matches: "pass" or "drop"
	Match_Action string

	// "and" or "or", specifying that either *all* fields must match or that *any* field will be sufficient
	Match_Logic string

	// each Field-Filter consists of the field to match, a comma, and the path to the file containing possible values, e.g. "foo.bar,/tmp/values"
	Field_Filter []string
}

type Processor interface {
	Process(*entry.Entry) ([]*entry.Entry, error) //process an data item potentially setting a tag
	Close() error                                 //give the processor a chance to tide up
}

type ProcessorConfig map[string]*config.VariableConfig

type ProcessorSet struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type RegexExtractConfig struct {
	Passthrough_Misses bool
	Regex              string
	Template           string
}

type RegexExtractor struct {
	RegexExtractConfig
	// contains filtered or unexported fields
}

type RegexRouteConfig struct {
	Regex            string
	Route_Extraction string
	Route            []string
	Drop_Misses      bool
}

type RegexRouter struct {
	RegexRouteConfig
	// contains filtered or unexported fields
}

type RegexTimestamp struct {
	RegexTimestampConfig
	// contains filtered or unexported fields
}

type RegexTimestampConfig struct {
	Regex                     string // the regular expression to apply to the data
	TS_Match_Name             string // the submatch which contains the timestamp
	Timestamp_Format_Override string
	Timezone_Override         string
	Assume_Local_Timezone     bool
}

type SetAllocator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Tagger interface {
	NegotiateTag(name string) (entry.EntryTag, error)
	LookupTag(entry.EntryTag) (string, bool)
}