beater

Documentation

Index

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

Functions

func New

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

Creates beater

Types

type IndexRiverFunc

type IndexRiverFunc func(b *beat.Beat, cmd *RedisCmd) error

type Mysqlbeat

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

func (*Mysqlbeat) Run

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

func (*Mysqlbeat) Stop

func (bt *Mysqlbeat) Stop()

type RedisCmd

type RedisCmd struct {
	Cmd   string `json:"cmd"`
	Index string `json:"index"`
	Type  string `json:"type"`
	ID    string `json:"id"`
	Doc   string `json:"doc"`
}