nagflux

Documentation

Index

• func GenDumpfileName(filename string, ending data.Target) string
• type DumpfileCollector
  • func NewDumpfileCollector(jobs chan collector.Printable, dumpFile string, target data.Target, ...) *DumpfileCollector
  • func (dump *DumpfileCollector) Stop()
• type FileCollector
  • func NewNagfluxFileCollector(results collector.ResultQueues, folder string, fieldSeparator rune) *FileCollector
  • func (nfc *FileCollector) Stop()
• type Printable
  • func (p Printable) PrintForElasticsearch(version, index string) string
  • func (p Printable) PrintForInfluxDB(version string) string

Functions

func GenDumpfileName

func GenDumpfileName(filename string, ending data.Target) string

GenDumpfileName returns the name of an dumpfile

Types

type DumpfileCollector

type DumpfileCollector struct {
	IsRunning bool
	// contains filtered or unexported fields
}

DumpfileCollector collects queries from old runs, which could not been completed.

func NewDumpfileCollector

func NewDumpfileCollector(jobs chan collector.Printable, dumpFile string, target data.Target, fileBufferSize int) *DumpfileCollector

NewDumpfileCollector constructor, which also starts the collector

func (*DumpfileCollector) Stop

func (dump *DumpfileCollector) Stop()

Stop stops the Collector.

type FileCollector

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

FileCollector provides a interface to nagflux, in which you could insert influxdb queries.

func NewNagfluxFileCollector

func NewNagfluxFileCollector(results collector.ResultQueues, folder string, fieldSeparator rune) *FileCollector

NewNagfluxFileCollector constructor, which also starts the collector.

func (*FileCollector) Stop

func (nfc *FileCollector) Stop()

Stop stops the Collector.

type Printable

type Printable struct {
	collector.Filterable
	Table     string
	Timestamp string
	// contains filtered or unexported fields
}

Printable converts from nagfluxfile format to X

func (Printable) PrintForElasticsearch

func (p Printable) PrintForElasticsearch(version, index string) string

PrintForElasticsearch prints in the elasticsearch json format

func (Printable) PrintForInfluxDB

func (p Printable) PrintForInfluxDB(version string) string

PrintForInfluxDB prints the data in influxdb lineformat