beater

Documentation

Index

• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type Camsbeat
  • func (bt *Camsbeat) Close() error
  • func (bt *Camsbeat) DirectKafkaSend(urlValue string, objectId string, accountId string)
  • func (bt *Camsbeat) OutputConfigSend(urlValue string, objectId string, accountId string)
  • func (bt *Camsbeat) Run(b *beat.Beat) error
  • func (bt *Camsbeat) Stop()

Functions

func New

func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)

Creates beater

Types

type Camsbeat

type Camsbeat struct {
	// contains filtered or unexported fields
}

func (*Camsbeat) Close

func (bt *Camsbeat) Close() error

func (*Camsbeat) DirectKafkaSend

func (bt *Camsbeat) DirectKafkaSend(urlValue string, objectId string, accountId string)

func (*Camsbeat) OutputConfigSend

func (bt *Camsbeat) OutputConfigSend(urlValue string, objectId string, accountId string)

func (*Camsbeat) Run

func (bt *Camsbeat) Run(b *beat.Beat) error

func (*Camsbeat) Stop

func (bt *Camsbeat) Stop()