collector

Documentation

Index

• Constants
• type Client
• type ClientType
• type Collector
  • func New(client Client, logger *outputs.TmpWriter, statePath string) (*Collector, error)
  • func (i *Collector) Exit()
  • func (i *Collector) Poll(pollSeconds int, pollOffset int, resultsChannel chan<- string, ...)
  • func (i *Collector) Start(scheduleTime int, pollOffset int, resultsChannel chan<- string, ...)
  • func (i *Collector) Stream(scheduleTime int, resultsChannel chan<- string, ctx context.Context)
• type State
  • func (p *State) Load() error
  • func (p *State) Save()

Constants

const ClientTypePoll = ClientType(1)

const ClientTypeStream = ClientType(2)

Types

type Client

type Client interface {
	Poll(timestamp time.Time, resultsChannel chan<- string, pollOffset int) (count int, currentTimestamp time.Time, err error)
	Stream(streamChannel chan<- string) (cancelFunc func(), err error)
	ClientType() ClientType
	Exit() error
}

type ClientType

type ClientType int

type Collector

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

func New

func New(client Client, logger *outputs.TmpWriter, statePath string) (*Collector, error)

func (*Collector) Exit

func (i *Collector) Exit()

func (*Collector) Poll

func (i *Collector) Poll(pollSeconds int, pollOffset int, resultsChannel chan<- string, ctx context.Context)

func (*Collector) Start

func (i *Collector) Start(scheduleTime int, pollOffset int, resultsChannel chan<- string, ctx context.Context)

func (*Collector) Stream

func (i *Collector) Stream(scheduleTime int, resultsChannel chan<- string, ctx context.Context)

type State

type State struct {
	Path string
	Data data
}

func (*State) Load

func (p *State) Load() error

Restore state

func (*State) Save

func (p *State) Save()

Save state