NewFluentdRecv create new FluentdRecv.

NewHTTPRecv return new HTTPRecv.

RandomValOperator set this val in meta will replaced by random string.

FluentdRecv recv for fluentd format.

FluentdRecvCfg configuration of FluentdRecv.

HTTPRecv recv for HTTP.

HTTPRecvCfg is the configuration for HTTPRecv.

KafkaCfg kafka client configuration Args: IsJSONFormat: unmarshal json into `msg.Message` MsgKey: put kafka msg body into `msg.Message[MsgKey]` TagKey: set tag into `msg.Message[TagKey]` Name: name of this recv plugin KMsgPool: sync.Pool for `*utils.kafka.KafkaMsg` Meta: add new field and value into `msg.Message` JSONTagKey: load tag from kafka message(only work when IsJSONFormat is true) RewriteTag: rewrite `msg.Tag`, `msg.Message["tag"]` will keep origin value ReconnectInterval: restart consumer periodically */.

PendingMsg is the message wait tobe concatenate.

RsyslogRecv.