agent

package

Go to main page

Versions in this module

v1

v1.4.0

Sep 25, 2020

v1.3.2

Sep 21, 2020

v1.3.1

Sep 21, 2020

v1.3.0

Sep 18, 2020

v1.2.2

Sep 10, 2020

v1.2.1

Aug 18, 2020

v1.2.0

Aug 13, 2020

Changes in this version

type IndexedResults

+ ToNats bool

type NatsClient

+ Subject string

type ScalarResults

+ ToNats bool

v1.1.0

Aug 6, 2020

Changes in this version

+ func NewNatsClient(hosts []string, topic, name string) error

+ type NatsClient struct

+ Hosts []string

+ Name string

+ Topic string

+ func (c *NatsClient) Close()

+ func (c *NatsClient) Push(res PollResult)

v1.0.0

Aug 5, 2020

Changes in this version

+ var GracefulQuitMode bool

+ var InterPollDelay time.Duration

+ var MaxAllowedLoad float64

+ var MaxPingProcs int

+ var MaxSNMPRequests int

+ var MockMode bool

+ var PingPacketCount int

+ var StatsUpdFreq int

+ var StopCtx context.Context

+ func AddPingRequest(req model.PingRequest) bool

+ func AddSnmpRequest(req *SnmpRequest) bool

+ func CurrentMemLoad() float64

+ func CurrentSNMPLoad() float64

+ func ErrIsRefused(err error) bool

+ func ErrIsTimeout(err error) bool

+ func ErrIsUnreachable(err error) bool

+ func HandleCheck(w http.ResponseWriter, r *http.Request)

+ func HandleOngoing(w http.ResponseWriter, r *http.Request)

+ func HandlePingRequest(w http.ResponseWriter, r *http.Request)

+ func HandleSnmpRequest(w http.ResponseWriter, r *http.Request)

+ func Init() error

+ func InitCollectors(maxResAge, sweepFreq int) error

+ func NewInfluxClient(host, user, passwd, db, rp string, timeout, retries int) error

+ func NewKafkaClient(hosts []string, topic string, partition int) error

+ func SnmpScrapeCount() int

+ type IndexedResults struct

+ LabelsOnly bool

+ Name string

+ Results [][]Result

+ ToInflux bool

+ ToKafka bool

+ ToProm bool

+ func MakeIndexed(uid string, meas model.IndexedMeasure, tabResults []TabularResults) IndexedResults

+ func (x *IndexedResults) DedupDesc()

+ func (x *IndexedResults) Filter(meas model.IndexedMeasure)

+ func (x IndexedResults) String() string

+ type InfluxClient struct

+ Database string

+ Host string

+ Password string

+ RetentionPolicy string

+ Timeout int

+ User string

+ WriteRetries int

+ func (c *InfluxClient) Close()

+ func (c *InfluxClient) Push(res PollResult)

+ type KafkaClient struct

+ Hosts []string

+ Partition int32

+ Topic string

+ func (c *KafkaClient) Close()

+ func (c *KafkaClient) Push(res PollResult)

+ type PingCollector struct

+ func (c *PingCollector) Push(meas PingMeasure)

+ type PingMeasure struct

+ Avg float64

+ Category string

+ HostID int

+ Hostname string

+ IPAddr string

+ Loss float64

+ Max float64

+ Min float64

+ Model string

+ Stamp time.Time

+ Vendor string

+ type PollResult struct

+ AgentID int

+ Duration int64

+ IPAddr string

+ Indexed []IndexedResults

+ IsPartial bool

+ PollErr string

+ PollStart time.Time

+ RequestID string

+ Scalar []ScalarResults

+ Tags map[string]string

+ func (p *PollResult) PruneForKafka()

+ func (p PollResult) Copy() PollResult

+ type PromCollector struct

+ MaxResultAge time.Duration

+ Samples map[uint64]*PromSample

+ SweepFreq time.Duration

+ func NewCollector(maxResAge, sweepFreq int, endpoint string) (*PromCollector, error)

+ func (c *PromCollector) Collect(ch chan<- prometheus.Metric)

+ func (c *PromCollector) Describe(ch chan<- *prometheus.Desc)

+ type PromSample struct

+ Desc string

+ Labels map[string]string

+ Name string

+ Stamp time.Time

+ Value float64

+ type Result struct

+ AsLabel bool

+ Description string

+ ExportedName string

+ Index string

+ Name string

+ Oid string

+ Value interface{}

+ func MakeResult(pdu gosnmp.SnmpPDU, metric model.Metric) (Result, error)

+ func (r Result) String() string

+ type ScalarResults struct

+ Name string

+ Results []Result

+ ToInflux bool

+ ToKafka bool

+ ToProm bool

+ type SnmpCollector struct

+ func (c *SnmpCollector) Push(pollRes PollResult)

+ type SnmpRequest struct

+ func (r SnmpRequest) MakePollResult() PollResult

+ func (s *SnmpRequest) Close()

+ func (s *SnmpRequest) Dial(ctx context.Context) error

+ func (s *SnmpRequest) Get(ctx context.Context) (results []ScalarResults, err error)

+ func (s *SnmpRequest) Poll(ctx context.Context) PollResult

+ func (s *SnmpRequest) UnmarshalJSON(data []byte) error

+ func (s *SnmpRequest) Walk(ctx context.Context) ([]IndexedResults, error)

+ type TabularResults map[string][]Result

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL