beat

Documentation

Index

• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type Redisbeat
  • func (rb *Redisbeat) Cleanup(b *beat.Beat) error
  • func (rb *Redisbeat) Run(b *beat.Beat) error
  • func (rb *Redisbeat) Stop()

Functions

func New

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

Types

type Redisbeat

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

func (*Redisbeat) Cleanup

func (rb *Redisbeat) Cleanup(b *beat.Beat) error

func (*Redisbeat) Run

func (rb *Redisbeat) Run(b *beat.Beat) error

func (*Redisbeat) Stop

func (rb *Redisbeat) Stop()

Stop is triggered on exit, closing the done channel and redis pool