beater

Documentation

Index

• func MakeEvent(fields []string) common.MapStr
• func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
• type DiskStats
• type Iobeat
  • func (bt *Iobeat) CollectIOStats(statfile string) ([]common.MapStr, error)
  • func (bt *Iobeat) Run(b *beat.Beat) error
  • func (bt *Iobeat) Stop()

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