beater

Documentation

Index

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

Functions

func New

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

New creates an instance of cloudpubsubbeat.

Types

type Cloudpubsubbeat

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

Cloudpubsubbeat configuration.

func (*Cloudpubsubbeat) Run

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

Run starts cloudpubsubbeat.

func (*Cloudpubsubbeat) Stop

func (bt *Cloudpubsubbeat) Stop()

Stop stops cloudpubsubbeat.