Versions in this module Expand all Collapse all v2 v2.0.0 Jul 9, 2021 Changes in this version + const DefaultGuarantees + const DropIfFull + const GuaranteedSend + var Done chan bool + var LoadFile = common.LoadFile + var ReloadChan chan bool + func Send(event MapStr) bool + func SendEvent(event Event) bool + func Stop() error + type BKBeat struct + Beat *beat.Beat + BeaterState BeaterState + Client *beat.Client + Done chan struct{} + Finished bool + LocalConfig *Config + func (bkb *BKBeat) Reload(localConfig *common.Config) + func (bkb *BKBeat) Run(b *beat.Beat) error + func (bkb *BKBeat) Stop() + type BeaterState int + const BeaterBeforeOpening + const BeaterFailToOpen + const BeaterRunning + const BeaterStoped + type ClientEventer = beat.ClientEventer + type Config = common.Config + func GetConfig() *Config + func GetRawConfig() *Config + func Init(beatName string, version string) (*Config, error) + func InitWithPublishConfig(beatName string, version string, pubConfig PublishConfig, ...) (*Config, error) + type Event = beat.Event + type EventMetadata = common.EventMetadata + type MapStr = common.MapStr + type MapStrPorinter = common.MapStrPointer + type ProcessingConfig = beat.ProcessingConfig + type Processor = beat.Processor + type ProcessorList = beat.ProcessorList + type PublishConfig = beat.ClientConfig + type PublishMode = beat.PublishMode
Go to main page