agent

type IndexedResults struct {
	// Name is the measure name.
	Name string `json:"name"`

	// Results is an 2-dimensional array of all results for this indexed measure
	// with the index as first dimension and the oid as second dimension.
	Results [][]Result `json:"metrics"`

	// ToInflux tells wether this measure is exported to influxDB
	ToInflux bool `json:"to_influx,omitempty"`

	// ToKafka tells wether this measure is exported to kafka
	ToKafka bool `json:"to_kafka,omitempty"`

	// ToProm tells wether this measure is exported to prometheus
	ToProm bool `json:"to_prom,omitempty"`

	// ToNats tells wether this measure is exported to NATS
	ToNats bool `json:"to_nats,omitempty"`

	// LabelsOnly tells wether the measure is label-only
	LabelsOnly bool `json:"labels_only,omitempty"`
}

type InfluxClient struct {
	// Host is the influx server address
	Host string

	// User is the influx authentication user
	User string

	// Password is the user password
	Password string

	// Database is the influx measurements database
	Database string

	// RetentionPolicy is the retention policy applied to measures
	RetentionPolicy string

	// Timeout is the influx connection and push timeout
	Timeout int

	// WriteRetries is the number of write retries in case of failure
	WriteRetries int

	influxclient.Client
	// contains filtered or unexported fields
}

type KafkaClient struct {
	// Hosts is the list of kafka brokers addresses
	Hosts []string

	// Topic is the kafka topic
	Topic string

	// Partition is the kafka partition number
	Partition int32

	kafka.Producer
	// contains filtered or unexported fields
}

type NatsClient struct {
	// Hosts is the list of NATS urls
	Hosts []string

	// Subject is the NATS subject to use for the metrics
	Subject string

	// Name is the NATS connection name
	Name string
	// contains filtered or unexported fields
}

type PingCollector struct {
	*PromCollector
}

type PingMeasure struct {
	// HostID is the host db id
	HostID int

	// Hostname is the pinged host name
	Hostname string

	// IPAddr is the ip address of the pinged host
	IPAddr string

	// Category is the device category (for profile identification)
	Category string

	// Vendor is the device vendor (for profile identification)
	Vendor string

	// Model is the device model (for profile identification)
	Model string

	// Min is the minimal RTT in seconds
	Min float64

	// Max is the maximal RTT in seconds
	Max float64

	// Avg is the average RTT in seconds
	Avg float64

	// Loss is the packet loss percentage
	Loss float64

	// Stamp is the ping request datetime
	Stamp time.Time
}

type PollResult struct {
	// RequestID is the polling job id
	RequestID string `json:"request_id"`

	// AgentID is the poller agent id
	AgentID int `json:"agent_id"`

	// IPAddr is the polled device IP address
	IPAddr string `json:"device_ipaddr"`

	// Scalar is the set of scalar measures results
	Scalar []ScalarResults `json:"scalar_measures,omitempty"`

	// Indexed is the set of indexed measures results
	Indexed []IndexedResults `json:"indexed_measures,omitempty"`

	// PollStart is the poll starting time
	PollStart time.Time `json:"poll_start"`

	// Duration is the total polling duration in ms
	Duration int64 `json:"poll_duration"`

	// PollErr is the error message returned by the poll request
	PollErr string `json:"poll_error,omitempty"`

	// Tags is the tag map associated with the result
	Tags map[string]string `json:"tags,omitempty"`

	// IsPartial tells if the result is partial due to a mid-request snmp timeout.
	IsPartial bool `json:"is_partial,omitempty"`
	// contains filtered or unexported fields
}

type PromCollector struct {
	// Samples is the map of last samples kept in memory.
	Samples map[uint64]*PromSample

	// MaxResultAge is the max time a sample is kept in memory.
	MaxResultAge time.Duration

	// SweepFreq is the cleanup goroutine frequency to remove old metrics.
	SweepFreq time.Duration

	sync.Mutex
	// contains filtered or unexported fields
}

type PromSample struct {
	// Name is the prometheus metric name in the form of <snmp measurement name>_<snmp metric name>.
	Name string

	// Desc is the metric description (usually the snmp oid).
	Desc string

	// Value is the metric value.
	Value float64

	// Labels is the metric label map.
	Labels map[string]string

	// Stamp is the metric timestamp (the snmp poll start time).
	Stamp time.Time
}

type Result struct {
	// Oid is the metric OID as returned by the device.
	Oid string `json:"oid"`

	// Name is the metric name (from SNMP MIB usually).
	Name string `json:"name"`

	// ExportedName is the name of the exported metric.
	ExportedName string `json:"exported_name"`

	// Description is the metric description copied from request.
	Description string `json:"description,omitempty"`

	// Value is the metric value converted to the corresponding Go type.
	Value interface{} `json:"value"`

	// AsLabel tells if the result is exported as a prometheus label.
	AsLabel bool `json:"as_label,omitempty"`

	// Index is the result index as extracted from the oid according to the index_pattern.
	Index string `json:"index,omitempty"`
	// contains filtered or unexported fields
}

type ScalarResults struct {
	// Name is the name of the result group
	Name string `json:"name"`

	// Results is the list of results of this measure
	Results []Result `json:"metrics"`

	// ToInflux tells wether this measure is exported to influxDB
	ToInflux bool `json:"to_influx,omitempty"`

	// ToKafka tells wether this measure is exported to kafka
	ToKafka bool `json:"to_kafka,omitempty"`

	// ToProm tells wether this measure is exported to prometheus
	ToProm bool `json:"to_prom,omitempty"`

	// ToNats tells wether this measure is exported to NATS
	ToNats bool `json:"to_nats,omitempty"`
}

type SnmpCollector struct {
	*PromCollector
}

type SnmpRequest struct {
	model.SnmpRequest

	// logger is the internal gosnmp compatible glog Logger.
	log.Logger
	// contains filtered or unexported fields
}

type TabularResults map[string][]Result