recvs

type AcceptorRecvItf interface {
	SetSyncOutChan(chan<- *libs.FluentMsg)
	SetAsyncOutChan(chan<- *libs.FluentMsg)
	SetMsgPool(*sync.Pool)
	SetCounter(libs.CounterIft)
	Run(context.Context)
	GetName() string
}

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

type FluentdRecv struct {
	*BaseRecv
	*FluentdRecvCfg
	// contains filtered or unexported fields
}

type FluentdRecvCfg struct {
	Name,

	Addr,

	TagKey,

	LBKey string

	// NFork fork concators
	NFork,
	ConcatorBufSize int
	ConcatorWait time.Duration

	// if IsRewriteTagFromTagKey, set `msg.Tag = msg.Message[OriginRewriteTagKey]`
	IsRewriteTagFromTagKey bool
	OriginRewriteTagKey    string

	ConcatMaxLen int
	ConcatCfg    map[string]interface{}
}

type HTTPRecv struct {
	*BaseRecv
	*HTTPRecvCfg
}

type HTTPRecvCfg struct {
	HTTPSrv     *gin.Engine
	MaxBodySize int64
	// Name: recv name
	// Path: url endpoint
	Name, Path, Env string

	// Tag: set `msg.Tag = Tag`
	// OrigTag & TagKey: set `msg.Message[TagKey] = OrigTag`
	OrigTag, Tag, TagKey, MsgKey string

	// TSRegexp: validate time string
	// TimeKey: load time string from `msg.Message[TimeKey].(string)`
	// TimeFormat: `time.Parse(ts, TimeFormat)`
	TimeKey, TimeFormat string
	TSRegexp            *regexp.Regexp

	// SigKey: load signature from `msg.Message[SigKey].([]byte)`
	// SigSalt: calculate signature by `md5(ts + SigSalt)`
	SigKey  string
	SigSalt []byte

	MaxAllowedDelaySec, MaxAllowedAheadSec time.Duration
}

type KafkaCfg struct {
	KafkaCommitCfg
	Topics, Brokers                  []string
	Group, Tag, MsgKey, TagKey, Name string
	NConsumer                        int
	KMsgPool                         *sync.Pool
	Meta                             map[string]interface{}
	IsJSONFormat                     bool
	JSONTagKey                       string
	RewriteTag                       string
	ReconnectInterval                time.Duration
}

type KafkaCommitCfg struct {
	IntervalNum      int
	IntervalDuration time.Duration
}

type KafkaRecv struct {
	BaseRecv
	*KafkaCfg
}

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

type RsyslogCfg struct {
	RewriteTags map[string]string
	TimeShift   time.Duration
	Name, Addr, TagKey, MsgKey,
	Tag,
	NewTimeFormat, TimeKey, NewTimeKey string
}

type RsyslogRecv struct {
	*BaseRecv
	*RsyslogCfg
}