beater

Documentation

Index

• func BuildEventstreamEvent(e []byte) beat.Event
• func BuildStatusEvents(body []byte) []beat.Event
• func FloatToTimestamp(stamp float64) time.Time
• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type Eventstream
  • func NewEventstream(bt *Icingabeat, cfg config.Config) *Eventstream
  • func (es *Eventstream) Run() error
  • func (es *Eventstream) Stop()
• type Icingabeat
  • func (bt *Icingabeat) Run(b *beat.Beat) error
  • func (bt *Icingabeat) Stop()
• type Statuspoller
  • func NewStatuspoller(bt *Icingabeat, cfg config.Config) *Statuspoller
  • func (sp *Statuspoller) Run() error
  • func (sp *Statuspoller) Stop()

Functions

func BuildEventstreamEvent

func BuildEventstreamEvent(e []byte) beat.Event

BuildEventstreamEvent ...

func BuildStatusEvents

func BuildStatusEvents(body []byte) []beat.Event

BuildStatusEvents ...

func FloatToTimestamp

func FloatToTimestamp(stamp float64) time.Time

FloatToTimestamp ...

func New

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

New beater

Types

type Eventstream

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

Eventstream type

func NewEventstream

func NewEventstream(bt *Icingabeat, cfg config.Config) *Eventstream

NewEventstream ...

func (*Eventstream) Run

func (es *Eventstream) Run() error

Run evenstream receiver

func (*Eventstream) Stop

func (es *Eventstream) Stop()

Stop eventstream receiver

type Icingabeat

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

Icingabeat type

func (*Icingabeat) Run

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

Run Icingabeat

func (*Icingabeat) Stop

func (bt *Icingabeat) Stop()

Stop Icingabeat

type Statuspoller

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

Statuspoller type

func NewStatuspoller

func NewStatuspoller(bt *Icingabeat, cfg config.Config) *Statuspoller

NewStatuspoller ...

func (*Statuspoller) Run

func (sp *Statuspoller) Run() error

Run evenstream receiver

func (*Statuspoller) Stop

func (sp *Statuspoller) Stop()

Stop statuspoller