tagFilters

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

type ConcatorCfg struct {
	MsgKey,
	Identifier string
	Regexp *regexp.Regexp
}

type ConcatorFactCfg struct {
	NFork, MaxLen int
	LBKey         string
	Plugins       map[string]*ConcatorCfg
}

type ConcatorFactory struct {
	*BaseTagFilterFactory
	*ConcatorFactCfg
	// contains filtered or unexported fields
}

type ParserFact struct {
	*BaseTagFilterFactory
	*ParserFactCfg
	// contains filtered or unexported fields
}

type ParserFactCfg struct {
	NFork           int
	Name, LBKey     string
	Tags            []string
	Env, MsgKey     string
	Regexp          *regexp.Regexp
	MsgPool         *sync.Pool
	IsRemoveOrigLog bool
	Add             map[string]map[string]string
	ParseJsonKey,
	MustInclude string
	TimeKey,
	TimeFormat,
	NewTimeKey,
	AppendTimeZone,
	NewTimeFormat string
	ReservedTimeKey bool
}

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

type TagFilterFactoryItf interface {
	IsTagSupported(string) bool
	Spawn(context.Context, string, chan<- *libs.FluentMsg) chan<- *libs.FluentMsg // Spawn(tag, outChan) inChan
	GetName() string

	SetMsgPool(*sync.Pool)
	SetWaitCommitChan(chan<- *libs.FluentMsg)
	SetDefaultIntervalChanSize(int)
	DiscardMsg(*libs.FluentMsg)
}

type TagPipeline struct {
	*TagPipelineCfg
	TagFilterFactoryItfs []TagFilterFactoryItf
	// contains filtered or unexported fields
}

type TagPipelineCfg struct {
	InternalChanSize int
	MsgPool          *sync.Pool
	WaitCommitChan   chan<- *libs.FluentMsg
}

type TagPipelineItf interface {
	Spawn(context.Context, string, chan<- *libs.FluentMsg) (chan<- *libs.FluentMsg, error)
}