beater

Documentation

Index

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

Functions

func New

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

New creates an instance of zmqbeat.

Types

type Zmqbeat

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

Zmqbeat configuration.

func (*Zmqbeat) Run

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

Run starts zmqbeat.

func (*Zmqbeat) Stop

func (bt *Zmqbeat) Stop()

Stop stops zmqbeat.