Documentation ¶
Index ¶
- Constants
- func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)
- type Events
- type GcCollector
- type HotThread
- type HotThreadsStats
- type JvmStats
- type Logstashbeat
- func (bt *Logstashbeat) GetHotThreads(u url.URL, numThreads int) (*HotThreadsStats, error)
- func (bt *Logstashbeat) GetJvmStats(u url.URL) (*JvmStats, error)
- func (bt *Logstashbeat) GetPipelineStats(u url.URL) (*PipelineStats, error)
- func (bt *Logstashbeat) GetProcessStats(u url.URL) (*ProcessStats, error)
- func (bt *Logstashbeat) Run(b *beat.Beat) error
- func (bt *Logstashbeat) Stop()
- type MemPool
- type PipelineElementEvents
- type PipelineEvents
- type PipelineStats
- type ProcessStats
- type Thread
Constants ¶
View Source
const NODE_HOT_THREADS = "/_node/hot_threads"
View Source
const NODE_JVM_STATS = "/_node/stats/jvm"
View Source
const NODE_PIPELINE_STATS = "/_node/stats/pipeline"
View Source
const NODE_PROCESS_STATS = "/_node/stats/process"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type GcCollector ¶
type HotThreadsStats ¶
type JvmStats ¶
type JvmStats struct { Jvm struct { Threads struct { Count uint64 `json:"count"` Peak_count uint64 `json:"peak_count"` } `json:"threads"` Mem struct { Heap_used_in_bytes int64 `json:"heap_used_in_bytes"` Heap_used_percent int64 `json:"heap_used_percent"` Heap_committed_in_bytes int64 `json:"heap_committed_in_bytes"` Heap_max_in_bytes int64 `json:"heap_max_in_bytes"` Non_heap_used_in_bytes int64 `json:"non_heap_used_in_bytes"` Non_heap_committed_in_bytes int64 `json:"non_heap_committed_in_bytes"` Pools struct { Survivor MemPool `json:"survivor"` Old MemPool `json:"old"` Young MemPool `json:"young"` } `json:"pools"` } `json:"mem"` GC struct { Collectors struct { Old GcCollector `json:"old"` New GcCollector `json:"new"` } `json:"collectors"` } `json:"gc"` } }
type Logstashbeat ¶
type Logstashbeat struct {
// contains filtered or unexported fields
}
func (*Logstashbeat) GetHotThreads ¶
func (bt *Logstashbeat) GetHotThreads(u url.URL, numThreads int) (*HotThreadsStats, error)
func (*Logstashbeat) GetJvmStats ¶
func (bt *Logstashbeat) GetJvmStats(u url.URL) (*JvmStats, error)
func (*Logstashbeat) GetPipelineStats ¶
func (bt *Logstashbeat) GetPipelineStats(u url.URL) (*PipelineStats, error)
func (*Logstashbeat) GetProcessStats ¶
func (bt *Logstashbeat) GetProcessStats(u url.URL) (*ProcessStats, error)
func (*Logstashbeat) Stop ¶
func (bt *Logstashbeat) Stop()
type PipelineElementEvents ¶
type PipelineEvents ¶
type PipelineEvents struct { Name string `json:"name"` Id string `json:"id"` Matches uint64 `json:"matches,omitempty"` Failures uint64 `json:"failures,omitempty"` Formats uint64 `json:"formats,omitempty"` PatternsPerField interface{} `json:"patterns_per_field,omitempty"` Events PipelineElementEvents `json:"events"` }
type PipelineStats ¶
type PipelineStats struct { Pipeline struct { Events Events `json:"events"` Plugins struct { Inputs []*PipelineEvents `json:"inputs"` Filters []*PipelineEvents `json:"filters"` Outputs []*PipelineEvents `json:"outputs"` } `json:"plugins"` Reloads struct { LastError string `json:"last_error"` LastSuccessTimestamp string `json:"last_success_timestamp"` LastFailureTimestamp string `json:"last_failure_timestamp"` Successes uint64 `json:"successes"` Failures uint64 `json:"failures"` } `json:"reloads"` } }
type ProcessStats ¶
type ProcessStats struct { Process struct { Open_file_descriptors int64 `json:"open_file_descriptors"` Peak_open_file_descriptors int64 `json:"peak_open_file_descriptors"` Max_file_descriptors int64 `json:"max_file_descriptors"` Cpu struct { Percent uint64 `json:"percent"` Total_in_millis uint64 `json:"total_in_millis"` } `json:"cpu"` Mem struct { Total_virtual_in_bytes uint64 `json:"total_virtual_in_bytes"` } `json:"mem"` } }
Click to show internal directories.
Click to hide internal directories.