Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

collector

package

Go to main page

Versions in this module

v0

v0.1.2

Dec 22, 2017

Changes in this version

type Collector

+ func NewNodeInfoCollector(logstashEndpoint string) (Collector, error)

+ type NodeInfoCollector struct

+ JvmInfos *prometheus.Desc

+ NodeInfos *prometheus.Desc

+ OsInfos *prometheus.Desc

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

+ type NodeInfoResponse struct

+ HTTPAddress string

+ Host string

+ ID string

+ Jvm struct{ ... }

+ Name string

+ Os struct{ ... }

+ Pipeline struct{ ... }

+ Version string

+ func NodeInfo(endpoint string) (NodeInfoResponse, error)

v0.1.1

Dec 20, 2017

Changes in this version

+ type HTTPHandler struct

+ Endpoint string

+ func (h *HTTPHandler) Get() (http.Response, error)

+ type HTTPHandlerInterface interface

+ Get func() (http.Response, error)

type NodeStatsCollector

+ PipelineDeadLetterQueueSizeInBytes *prometheus.Desc

type NodeStatsResponse

+ Pipelines map[string]Pipeline

+ type Pipeline struct

+ DeadLetterQueue struct{ ... }

+ Events struct{ ... }

+ Plugins struct{ ... }

+ Queue struct{ ... }

+ Reloads struct{ ... }

v0.1.0

Nov 23, 2017

Changes in this version

+ const Namespace

+ type Collector interface

+ Collect func(ch chan<- prometheus.Metric) (err error)

+ func NewNodeStatsCollector(logstash_endpoint string) (error, Collector)

+ type HttpHandler struct

+ Endpoint string

+ func (h *HttpHandler) Get() (http.Response, error)

+ type HttpHandlerInterface interface

+ Get func() (http.Response, error)

+ type NodeStatsCollector struct

+ GCCollectionCount *prometheus.Desc

+ GCCollectionTimeInMillis *prometheus.Desc

+ JvmThreadsCount *prometheus.Desc

+ JvmThreadsPeakCount *prometheus.Desc

+ MemHeapCommittedInBytes *prometheus.Desc

+ MemHeapMaxInBytes *prometheus.Desc

+ MemHeapUsedInBytes *prometheus.Desc

+ MemNonHeapCommittedInBytes *prometheus.Desc

+ MemNonHeapUsedInBytes *prometheus.Desc

+ MemPoolCommittedInBytes *prometheus.Desc

+ MemPoolMaxInBytes *prometheus.Desc

+ MemPoolPeakMaxInBytes *prometheus.Desc

+ MemPoolPeakUsedInBytes *prometheus.Desc

+ MemPoolUsedInBytes *prometheus.Desc

+ PipelineDuration *prometheus.Desc

+ PipelineEventsFiltered *prometheus.Desc

+ PipelineEventsIn *prometheus.Desc

+ PipelineEventsOut *prometheus.Desc

+ PipelinePluginEventsDuration *prometheus.Desc

+ PipelinePluginEventsIn *prometheus.Desc

+ PipelinePluginEventsOut *prometheus.Desc

+ PipelinePluginFailures *prometheus.Desc

+ PipelinePluginMatches *prometheus.Desc

+ PipelineQueueEvents *prometheus.Desc

+ PipelineQueueMaxQueueSize *prometheus.Desc

+ PipelineQueueMaxUnreadEvents *prometheus.Desc

+ PipelineQueuePageCapacity *prometheus.Desc

+ ProcessCPUTotalInMillis *prometheus.Desc

+ ProcessMaxFileDescriptors *prometheus.Desc

+ ProcessMemTotalVirtualInBytes *prometheus.Desc

+ ProcessOpenFileDescriptors *prometheus.Desc

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

+ type NodeStatsResponse struct

+ HTTPAddress string

+ Host string

+ Jvm struct{ ... }

+ Pipeline struct{ ... }

+ Process struct{ ... }

+ Version string

+ func NodeStats(endpoint string) (NodeStatsResponse, error)