beater

package
v0.0.0-...-1c5e83c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 23, 2016 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

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

func New

func New(b *beat.Beat, cfg *common.Config) (beat.Beater, error)

Creates beater

Types

type Events

type Events struct {
	Duration_in_millis uint64 `json:"duration_in_millis"`
	In                 uint64 `json:"in"`
	Filtered           uint64 `json:"filtered"`
	Out                uint64 `json:"out"`
}

type GcCollector

type GcCollector struct {
	CollectionTimeInMillis uint64 `json:"collection_time_in_millis"`
	CollectionCount        uint64 `json:"collection_count"`
}

type HotThread

type HotThread struct {
	Time            string    `json:"time"`
	Busiest_threads int       `json:"busiest_threads"`
	Threads         []*Thread `json:"threads"`
}

type HotThreadsStats

type HotThreadsStats struct {
	Host         string    `json:"host"`
	Version      string    `json:"version"`
	Http_address string    `json:"http_address"`
	Hot_threads  HotThread `json:"hot_threads"`
}

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) Run

func (bt *Logstashbeat) Run(b *beat.Beat) error

func (*Logstashbeat) Stop

func (bt *Logstashbeat) Stop()

type MemPool

type MemPool struct {
	Peak_used_in_bytes uint64 `json:"peak_used_in_bytes"`
	Used_in_bytes      uint64 `json:"used_in_bytes"`
	Peak_max_in_bytes  uint64 `json:"peak_max_in_bytes"`
	Max_in_bytes       uint64 `json:"max_in_bytes"`
	Committed_in_bytes uint64 `json:"committed_in_bytes"`
}

type PipelineElementEvents

type PipelineElementEvents struct {
	Duration_in_millis uint64 `json:"duration_in_millis"`
	In                 uint64 `json:"in"`
	Out                uint64 `json:"out"`
}

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"`
	}
}

type Thread

type Thread struct {
	Name                string    `json:"name"`
	Percent_of_cpu_time float32   `json:"percent_of_cpu_time"`
	State               string    `json:"state"`
	Traces              []*string `json:"traces"`
}

Jump to

Keyboard shortcuts

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