beater

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 15, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func FinishCube

func FinishCube(bt *Cubebeat, cubeInput *config.CubeInput, err error) error

func InitCube

func InitCube(cubeInput *config.CubeInput, bt *Cubebeat) error

func New

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

func NewConnection

func NewConnection(cubeInput *config.CubeInput)

func ParseData

func ParseData(input string) (output map[string]interface{}, err error)

func ProcessCube

func ProcessCube(bt *Cubebeat, cubeInput *config.CubeInput) error

func ReloadCube

func ReloadCube(cubeInput *config.CubeInput)

func RunProcessCubes

func RunProcessCubes(bt *Cubebeat) (err error)

Types

type Cubebeat

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

func (*Cubebeat) Run

func (bt *Cubebeat) Run(b *beat.Beat) (err error)

func (*Cubebeat) Stop

func (bt *Cubebeat) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL