beater

package

v0.0.0-...-1620ce9 Latest Latest Go to latest Published: Oct 16, 2018 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func Convert(i interface{}) interface{}

recursive function to deal with Yaml data

func Counter(bt *Lustrebeat, t string, counter uint64)

func GetIBCounters(path string, valuelist map[string]struct{}) (result map[string]uint64, err error)

func GetNetIOCs(valuelist map[string]struct{}) (result []net.IOCountersStat, err error)

func GetNumberVal(s string) (v uint64, ok bool)

func GetStatsFile1(s string) (result map[string]interface{}, err error)

func GetValFiles(statsdir string, valuelist map[string]struct{}) (result map[string]uint64, err error)

func GetZfsPoolIofile(s string) (result map[string]uint64, err error)

func GetZfsStatfile(s string) (result map[string]uint64, err error)

func JobStat(bt *Lustrebeat, s string) (err error)

func List2Set(ss []string) (mm map[string]struct{})

func MakeLustreTagsE(s string) (fs string, object string, client string, ok bool)

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

Creates beater

func PublishZpool(bt *Lustrebeat, v string) (err error)

func PublishZstats(bt *Lustrebeat, s string, listzstats map[string]struct{}) (err error)

type LustreStatsRecordLong struct {
	Metric  string
	Samples uint64
	//Unit    string
	Min uint64
	Max uint64
	Sum uint64
}

type LustreStatsRecordShort struct {
	Metric  string
	Samples uint64
}

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

boilerplate

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

boilerplate function

func (bt *Lustrebeat) Stop()