beater

Documentation

Index

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

Constants

const (
	ServiceName = "pubsubbeat"
)

Functions

func New

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

Types

type Pubsubbeat

type Pubsubbeat struct {
	StopChan chan struct{}
	// contains filtered or unexported fields
}

func (*Pubsubbeat) Run

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

func (*Pubsubbeat) Stop

func (bt *Pubsubbeat) Stop()