tact

type Blacklist map[string]struct{}

type Collector struct {
	Name     string
	GetData  GetDataFn
	EventOps *EventOps
	Joins    []*Join
	PostOps  PostEventOpsFn
}

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

type DeltaOps struct {
	KeyField      string        // Field to use as unique key
	Rate          bool          // Wetheter or not to do rate calculations over time delta
	TTL           time.Duration // TTL of cached data
	Blacklist     Blacklist     // Fields to ignore in delta, can be nil
	RateBlacklist Blacklist     // Fields to exclude from rate calculations, can be nil
}

type EventOps struct {
	Round        int               // The precision for float fields
	FieldTypes   []*rexon.Value    // The Fields:Type for conversion
	FieldRenames map[string]string // The Fields:Name for renaming
	Delta        *DeltaOps
}

type GetDataFn func(ctx *Context) (events <-chan []byte)

type Join struct {
	Name          string        // Collector name eg. `/aix/config/lvm`
	TTL           time.Duration // TTL when using cache
	JoinFields    []string      // Field names for possible matches to join, it will successfully return on first match
	JoinOnFields  []string      // Field name from the events of called Collector to join on
	IncludeFields []string      // Fields to include from the events of called collector
}

type Node struct {
	HostName    string            `json:"hostname,omitempty"`
	NetAddr     string            `json:"netaddr,omitempty"`
	Type        string            `json:"type,omitempty"`
	SSHPort     string            `json:"ssh_port,omitempty"`
	SSHUser     string            `json:"ssh_user,omitempty"`
	SSHPassword string            `json:"ssh_password,omitempty"`
	SSHKey      []byte            `json:"ssh_key,omitempty"`
	APIURL      string            `json:"api_url,omitempty"`
	APIUser     string            `json:"api_user,omitempty"`
	APIPassword string            `json:"api_password,omitempty"`
	DBUser      string            `json:"db_user,omitempty"`
	DBPassword  string            `json:"db_password,omitempty"`
	DBPort      string            `json:"db_port,omitempty"`
	LogFiles    map[string]string `json:"files,omitempty"`
}

type PostEventOpsFn func([]byte) (out []byte, err error)