beat

Documentation

Index

• Constants
• Variables
• func Send(event MapStr) bool
• func SendEvent(event Event) bool
• func Stop() error
• type BKBeat
  • func (bkb *BKBeat) Reload(localConfig *common.Config)
  • func (bkb *BKBeat) Run(b *beat.Beat) error
  • func (bkb *BKBeat) Stop()
• type BeaterState
• type ClientEventer
• type 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
• type EventMetadata
• type MapStr
• type MapStrPorinter
• type ProcessingConfig
• type Processor
• type ProcessorList
• type PublishConfig
• type PublishMode

Constants

const DefaultGuarantees = beat.DefaultGuarantees

const DropIfFull = beat.DropIfFull

const GuaranteedSend = beat.GuaranteedSend

Variables

var Done chan bool

var LoadFile = common.LoadFile

LoadFile

var ReloadChan chan bool

ReloadChan indicates developers to reload config when new config is ready

Functions

func Send

func Send(event MapStr) bool

Send sends a mapstr event

func SendEvent

func SendEvent(event Event) bool

SendEvent sends a Event type event

func Stop

func Stop() error

Stop stops the beat

Types

type BKBeat

type BKBeat struct {
	Beat        *beat.Beat
	Client      *beat.Client
	LocalConfig *Config
	BeaterState BeaterState
	Finished    bool
	Done        chan struct{}
}

BKBeat

func (*BKBeat) Reload

func (bkb *BKBeat) Reload(localConfig *common.Config)

Reload

func (*BKBeat) Run

func (bkb *BKBeat) Run(b *beat.Beat) error

Run

func (*BKBeat) Stop

func (bkb *BKBeat) Stop()

Stop

type BeaterState

type BeaterState int

BeaterState is beater's state

const (
	BeaterBeforeOpening BeaterState = iota
	BeaterFailToOpen
	BeaterRunning
	BeaterStoped
)

type ClientEventer

type ClientEventer = beat.ClientEventer

type Config

type Config = common.Config

Config

func GetConfig

func GetConfig() *Config

GetConfig fetch the config instance of user's beat

func GetRawConfig

func GetRawConfig() *Config

func Init

func Init(beatName string, version string) (*Config, error)

Init initializes user's beat

func InitWithPublishConfig

func InitWithPublishConfig(beatName string, version string, pubConfig PublishConfig, settings instance.Settings) (*Config, error)

InitWithPublishConfig initializes user's beat with user specified publish config

type Event

type Event = beat.Event

type EventMetadata

type EventMetadata = common.EventMetadata

type MapStr

type MapStr = common.MapStr

type MapStrPorinter

type MapStrPorinter = common.MapStrPointer

type ProcessingConfig

type ProcessingConfig = beat.ProcessingConfig

type Processor

type Processor = beat.Processor

type ProcessorList

type ProcessorList = beat.ProcessorList

type PublishConfig

type PublishConfig = beat.ClientConfig

type PublishMode

type PublishMode = beat.PublishMode