concator

Jan 15, 2020

Changes in this version

type JournalCfg

+ GCIntervalSec time.Duration

type ProducerCfg

+ DistributeKey string

Jan 14, 2020

Changes in this version

type JournalCfg

+ ChildJournalDataInchanLen int

+ ChildJournalIDInchanLen int

+ CommitIDChanLen int

Sep 5, 2019

Changes in this version

type Journal

+ func (j *Journal) CloseTag(tag string) error

type JournalCfg

+ CommittedIDTTL time.Duration

Aug 28, 2019

Changes in this version

type JournalCfg

+ IsCompress bool

Jun 4, 2019

Changes in this version

+ const IntervalToStartingLegacy

type ProducerCfg

+ NFork int

May 28, 2019

Changes in this version

type AcceptorCfg

+ MaxRotateID int64

type Journal

+ func (j *Journal) LoadMaxID() (int64, error)

May 23, 2019

Changes in this version

+ var Server = iris.New()

+ func RunServer(addr string)

+ func StringListContains(ls []string, v string) bool

+ type Acceptor struct

+ func NewAcceptor(cfg *AcceptorCfg, recvs ...recvs.AcceptorRecvItf) *Acceptor

+ func (a *Acceptor) GetAsyncOutChan() chan *libs.FluentMsg

+ func (a *Acceptor) GetSyncOutChan() chan *libs.FluentMsg

+ func (a *Acceptor) Run()

+ type AcceptorCfg struct

+ AsyncOutChanSize int

+ Journal *Journal

+ MaxRotateId int64

+ MsgPool *sync.Pool

+ SyncOutChanSize int

+ type ConcatorFactoryItf interface

+ MessageChan func() chan *libs.FluentMsg

+ Spawn func(string, string, *regexp.Regexp) chan<- *libs.FluentMsg

+ type Controllor struct

+ func NewControllor() *Controllor

+ func (c *Controllor) Run()

+ type Dispatcher struct

+ func NewDispatcher(cfg *DispatcherCfg) *Dispatcher

+ func (d *Dispatcher) GetOutChan() chan *libs.FluentMsg

+ func (d *Dispatcher) Run()

+ type DispatcherCfg struct

+ InChan chan *libs.FluentMsg

+ NFork int

+ OutChanSize int

+ TagPipeline *tagFilters.TagPipeline

+ type Journal struct

+ func NewJournal(cfg *JournalCfg) *Journal

+ func (j *Journal) ConvertMsg2Buf(msg *libs.FluentMsg, data *map[string]interface{})

+ func (j *Journal) DumpMsgFlow(msgPool *sync.Pool, dumpChan, skipDumpChan chan *libs.FluentMsg) chan *libs.FluentMsg

+ func (j *Journal) GetCommitChan() chan<- int64

+ func (j *Journal) GetOutChan() chan *libs.FluentMsg

+ func (j *Journal) LoadMaxId() (int64, error)

+ func (j *Journal) ProcessLegacyMsg(msgPool *sync.Pool, msgChan, dumpChan chan *libs.FluentMsg) (maxId int64, err error)

+ type JournalCfg struct

+ BufDirPath string

+ BufSizeBytes int64

+ CommitIdChanLen int

+ JournalOutChanLen int

+ MsgPool *sync.Pool

+ type Producer struct

+ func NewProducer(cfg *ProducerCfg, senders ...senders.SenderItf) *Producer

+ func (p *Producer) DiscardMsg(pmsg *ProducerPendingDiscardMsg)

+ func (p *Producer) Run()

+ func (p *Producer) RunMsgCollector(nSenderForTagMap *sync.Map, discardChan chan *libs.FluentMsg)

+ type ProducerCfg struct

+ CommitChan chan<- int64

+ DiscardChanSize int

+ InChan chan *libs.FluentMsg

+ MsgPool *sync.Pool

+ type ProducerPendingDiscardMsg struct

+ Count int

+ IsCommit bool

+ Msg *libs.FluentMsg