beater

Documentation

Index

• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type Commandbeat
  • func (bt *Commandbeat) Run(b *beat.Beat) error
  • func (bt *Commandbeat) Stop()
• type Publisher

Functions

func New

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

New creates new beater

Types

type Commandbeat

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

Commandbeat represents the client for commandbeat

func (*Commandbeat) Run

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

Run starts the commandbeat application. This function blocks until Stop() call.

func (*Commandbeat) Stop

func (bt *Commandbeat) Stop()

Stop stops the application.

type Publisher

type Publisher interface {
	Publish(spec *commandSpec, v common.MapStr)
}

Publisher is a interface responsible for publishing events to anywhere.