beater

package
v0.0.0-...-713bcf2 Latest Latest
Warning

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

Go to latest
Published: Mar 8, 2017 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeEvent

func MakeEvent(fields []string) common.MapStr

func New

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

New - Creates beater

Types

type DiskStats

type DiskStats struct {
	Major             int
	Minor             int
	Name              string
	ReadRequests      uint64 // Total number of reads completed successfully.
	ReadMerged        uint64 // Adjacent read requests merged in a single req.
	ReadSectors       uint64 // Total number of sectors read successfully.
	MsecRead          uint64 // Total number of ms spent by all reads.
	WriteRequests     uint64 // total number of writes completed successfully.
	WriteMerged       uint64 // Adjacent write requests merged in a single req.
	WriteSectors      uint64 // total number of sectors written successfully.
	MsecWrite         uint64 // Total number of ms spent by all writes.
	IosInProgress     uint64 // Number of actual I/O requests currently in flight.
	MsecTotal         uint64 // Amount of time during which ios_in_progress >= 1.
	MsecWeightedTotal uint64 // Measure of recent I/O completion time and backlog.
}

type Iobeat

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

func (*Iobeat) CollectIOStats

func (bt *Iobeat) CollectIOStats(statfile string) ([]common.MapStr, error)

CollectIOStats - Collects from the specified file

func (*Iobeat) Run

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

Run - Gathers and sends stats

func (*Iobeat) Stop

func (bt *Iobeat) Stop()

Stop - Cleanup on exit

Jump to

Keyboard shortcuts

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