beater

Documentation

Index

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

Functions

func New

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

New creates a beat

Types

type Nsqbeat

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

Nsqbeat struct

func (*Nsqbeat) Run

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

Run starts nsq consumer and publishs messages to beat

func (*Nsqbeat) Stop

func (bt *Nsqbeat) Stop()

Stop gracefully shutdown