beater

Documentation

Index

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

Functions

func New

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

New creates and instance of condorbeat.

Types

type Checkpoint

type Checkpoint map[string]time.Time

type Condorbeat

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

func (*Condorbeat) Run

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

Run starts condorbeat.

func (*Condorbeat) Stop

func (bt *Condorbeat) Stop()

Stop stops condorbeat.