nagflux

Documentation

Index

• type DumpfileCollector
  • func NewDumpfileCollector(jobs chan interface{}, dumpFile string) *DumpfileCollector
  • func (dump *DumpfileCollector) Stop()
• type FileCollector
  • func NewNagfluxFileCollector(results chan interface{}, folder string) *FileCollector
  • func (nfc *FileCollector) Stop()

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 interface{}, dumpFile string) *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 chan interface{}, folder string) *FileCollector

NewNagfluxFileCollector constructor, which also starts the collector.

func (*FileCollector) Stop

func (nfc *FileCollector) Stop()

Stop stops the Collector.