recvs

Dec 3, 2019

Changes in this version

type FluentdRecv

+ func (r *FluentdRecv) ProcessMsg(msg *libs.FluentMsg)

type FluentdRecvCfg

+ ConcatorBufSize int

+ ConcatorWait time.Duration

+ LBKey string

+ NFork int

type RsyslogCfg

+ RewriteTags map[string]string

+ Tag string

+ TimeShift time.Duration

Oct 8, 2019

Changes in this version

type FluentdRecvCfg

+ OriginRewriteTagKey string

Sep 5, 2019

Changes in this version

type KafkaCfg

+ ReconnectInterval time.Duration

+ func NewKafkaCfg() *KafkaCfg

Aug 28, 2019

Changes in this version

type FluentdRecv

+ func (r *FluentdRecv) Concat(ctx *concatCtx, msg *libs.FluentMsg) (newMsg *libs.FluentMsg)

type FluentdRecvCfg

+ ConcatCfg map[string]interface{}

+ ConcatMaxLen int

+ type PendingMsg struct

Aug 15, 2019

Changes in this version

+ const RandomValOperator

type KafkaCfg

+ IsJSONFormat bool

+ JSONTagKey string

May 23, 2019

Changes in this version

+ func GetKafkaRewriteTag(rewriteTag, env string) string

+ func NewRsyslogSrv(addr string) (*syslog.Server, syslog.LogPartsChannel)

+ type AcceptorRecvItf interface

+ GetName func() string

+ Run func()

+ SetAsyncOutChan func(chan<- *libs.FluentMsg)

+ SetCounter func(libs.CounterIft)

+ SetMsgPool func(*sync.Pool)

+ SetSyncOutChan func(chan<- *libs.FluentMsg)

+ type BaseRecv struct

+ func (r *BaseRecv) SetAsyncOutChan(outchan chan<- *libs.FluentMsg)

+ func (r *BaseRecv) SetCounter(counter libs.CounterIft)

+ func (r *BaseRecv) SetMsgPool(msgPool *sync.Pool)

+ func (r *BaseRecv) SetSyncOutChan(outchan chan<- *libs.FluentMsg)

+ type FluentdRecv struct

+ func NewFluentdRecv(cfg *FluentdRecvCfg) *FluentdRecv

+ func (r *FluentdRecv) GetName() string

+ func (r *FluentdRecv) Run()

+ func (r *FluentdRecv) SendMsg(msg *libs.FluentMsg)

+ type FluentdRecvCfg struct

+ Addr string

+ IsRewriteTagFromTagKey bool

+ Name string

+ TagKey string

+ type HTTPRecv struct

+ func NewHTTPRecv(cfg *HTTPRecvCfg) *HTTPRecv

+ func (r *HTTPRecv) BadRequest(ctx iris.Context, msg string)

+ func (r *HTTPRecv) GetName() string

+ func (r *HTTPRecv) HTTPLogHandler(ctx iris.Context)

+ func (r *HTTPRecv) Run()

+ type HTTPRecvCfg struct

+ Env string

+ HTTPSrv *iris.Application

+ MaxAllowedAheadSec time.Duration

+ MaxAllowedDelaySec time.Duration

+ MaxBodySize int64

+ MsgKey string

+ Name string

+ OrigTag string

+ Path string

+ SigKey string

+ SigSalt []byte

+ TSRegexp *regexp.Regexp

+ Tag string

+ TagKey string

+ TimeFormat string

+ TimeKey string

+ type KafkaCfg struct

+ Brokers []string

+ Group string

+ IsJsonFormat bool

+ JsonTagKey string

+ KMsgPool *sync.Pool

+ Meta map[string]interface{}

+ MsgKey string

+ NConsumer int

+ Name string

+ RewriteTag string

+ Tag string

+ TagKey string

+ Topics []string

+ type KafkaCommitCfg struct

+ IntervalDuration time.Duration

+ IntervalNum int

+ type KafkaRecv struct

+ func NewKafkaRecv(cfg *KafkaCfg) *KafkaRecv

+ func (r *KafkaRecv) GetName() string

+ func (r *KafkaRecv) Run()

+ type RsyslogCfg struct

+ Addr string

+ Env string

+ MsgKey string

+ Name string

+ NewTimeFormat string

+ NewTimeKey string

+ TagKey string

+ TimeKey string

+ type RsyslogRecv struct

+ func NewRsyslogRecv(cfg *RsyslogCfg) *RsyslogRecv

+ func (r *RsyslogRecv) GetName() string

+ func (r *RsyslogRecv) Run()