collector

package

Go to main page

Versions in this module

v1

v1.8.0

Sep 20, 2024

Changes in this version

+ func AggregateTasks(t tasksResponse) aggregatedTaskStats

type Collector

+ func NewTaskCollector(logger log.Logger, u *url.URL, hc *http.Client) (Collector, error)

+ type NodeStatsIndexingPressureCurrentResponse struct

+ AllInBytes int64

+ type NodeStatsIndexingPressureResponse struct

+ Current NodeStatsIndexingPressureCurrentResponse

+ LimitInBytes int64

type NodeStatsNodeResponse

+ IndexingPressure map[string]NodeStatsIndexingPressureResponse

+ type TaskCollector struct

+ func (t *TaskCollector) Update(ctx context.Context, ch chan<- prometheus.Metric) error

v1.7.0

Dec 21, 2023

Changes in this version

type IndexInfo

+ CreationDate string

type ShardResponse

+ State string

type Shards

+ func (s *Shards) ClusterLabelUpdates() *chan *clusterinfo.Response

+ func (s *Shards) String() string

type Snapshots

+ func (c *Snapshots) Update(ctx context.Context, ch chan<- prometheus.Metric) error

v1.6.0

Jun 29, 2023

Changes in this version

+ type ClusterSettingsCollector struct

+ func (c *ClusterSettingsCollector) Update(ctx context.Context, ch chan<- prometheus.Metric) error

+ type IlmIndexResponse struct

+ Action string

+ Index string

+ Managed bool

+ Phase string

+ Step string

+ StepTimeMillis float64

+ type IlmIndiciesCollector struct

+ func NewIlmIndicies(logger log.Logger, client *http.Client, url *url.URL) *IlmIndiciesCollector

+ func (i *IlmIndiciesCollector) Collect(ch chan<- prometheus.Metric)

+ func (i *IlmIndiciesCollector) Describe(ch chan<- *prometheus.Desc)

+ type IlmResponse struct

+ Indices map[string]IlmIndexResponse

+ type IlmStatusCollector struct

+ func NewIlmStatus(logger log.Logger, client *http.Client, url *url.URL) *IlmStatusCollector

+ func (im *IlmStatusCollector) Collect(ch chan<- prometheus.Metric)

+ func (im *IlmStatusCollector) Describe(ch chan<- *prometheus.Desc)

+ type IlmStatusResponse struct

+ OperationMode string

type IndexInfo

+ NumberOfReplicas string

v1.5.0

Jul 28, 2022

Changes in this version

+ type DataStream struct

+ func NewDataStream(logger log.Logger, client *http.Client, url *url.URL) *DataStream

+ func (ds *DataStream) Collect(ch chan<- prometheus.Metric)

+ func (ds *DataStream) Describe(ch chan<- *prometheus.Desc)

+ type DataStreamStatsDataStream struct

+ BackingIndices int64

+ DataStream string

+ MaximumTimestamp int64

+ StoreSizeBytes int64

+ type DataStreamStatsResponse struct

+ BackingIndices int64

+ DataStreamCount int64

+ DataStreamStats []DataStreamStatsDataStream

+ Shards DataStreamStatsShards

+ TotalStoreSizeBytes int64

+ type DataStreamStatsShards struct

+ Failed int64

+ Successful int64

+ Total int64

v1.4.0

Jul 13, 2022

Changes in this version

+ var ErrNoData = errors.New("collector returned no data")

+ func IsNoDataError(err error) bool

+ type ClusterInfoCollector struct

+ func (c *ClusterInfoCollector) Update(ctx context.Context, ch chan<- prometheus.Metric) error

+ type ClusterInfoResponse struct

+ ClusterName string

+ ClusterUUID string

+ Name string

+ Tagline string

+ Version VersionInfo

+ type Collector interface

+ Update func(context.Context, chan<- prometheus.Metric) error

+ func NewClusterInfo(logger log.Logger, u *url.URL, hc *http.Client) (Collector, error)

+ type ElasticsearchCollector struct

+ Collectors map[string]Collector

+ func NewElasticsearchCollector(logger log.Logger, filters []string, options ...Option) (*ElasticsearchCollector, error)

+ func (e ElasticsearchCollector) Collect(ch chan<- prometheus.Metric)

+ func (e ElasticsearchCollector) Describe(ch chan<- *prometheus.Desc)

type NodeStatsJVMResponse

+ Uptime int64

+ type Option func(*ElasticsearchCollector) error

+ func WithElasticsearchURL(esURL *url.URL) Option

+ func WithHTTPClient(hc *http.Client) Option

+ type PolicyStats struct

+ Policy string

+ SnapshotDeletionFailures int64

+ SnapshotsDeleted int64

+ SnapshotsFailed int64

+ SnapshotsTaken int64

+ type SLM struct

+ func NewSLM(logger log.Logger, client *http.Client, url *url.URL) *SLM

+ func (s *SLM) Collect(ch chan<- prometheus.Metric)

+ func (s *SLM) Describe(ch chan<- *prometheus.Desc)

+ type SLMStatsResponse struct

+ PolicyStats []PolicyStats

+ RetentionDeletionTime string

+ RetentionDeletionTimeMillis int64

+ RetentionFailed int64

+ RetentionRuns int64

+ RetentionTimedOut int64

+ TotalSnapshotDeletionFailures int64

+ TotalSnapshotsDeleted int64

+ TotalSnapshotsFailed int64

+ TotalSnapshotsTaken int64

+ type SLMStatusResponse struct

+ OperationMode string

+ type ShardResponse struct

+ Index string

+ Node string

+ Shard string

+ type Shards struct

+ func NewShards(logger log.Logger, client *http.Client, url *url.URL) *Shards

+ func (s *Shards) Collect(ch chan<- prometheus.Metric)

+ func (s *Shards) Describe(ch chan<- *prometheus.Desc)

+ type VersionInfo struct

+ BuildDate string

+ BuildHash string

+ BuildSnapshot bool

+ LuceneVersion semver.Version

+ Number semver.Version

v1.3.0

Oct 21, 2021

v1.2.1

Jun 29, 2021

v1.2.0

Jun 10, 2021

Changes in this version

type Cluster

+ MaxShardsPerNode string

type IndexInfo

+ Mapping Mapping

+ type IndexMapping struct

+ Mappings IndexMappings

+ type IndexMappingField struct

+ Fields IndexMappingFields

+ Properties IndexMappingProperties

+ Type *string

+ type IndexMappingFields map[string]*IndexMappingField

+ type IndexMappingProperties map[string]*IndexMappingProperty

+ type IndexMappingProperty struct

+ Fields IndexMappingFields

+ Properties IndexMappingProperties

+ Type *string

+ type IndexMappings struct

+ Properties IndexMappingProperties

+ type IndicesMappings struct

+ func NewIndicesMappings(logger log.Logger, client *http.Client, url *url.URL) *IndicesMappings

+ func (im *IndicesMappings) Collect(ch chan<- prometheus.Metric)

+ func (im *IndicesMappings) Describe(ch chan<- *prometheus.Desc)

+ type IndicesMappingsResponse map[string]IndexMapping

+ type Mapping struct

+ TotalFields TotalFields

+ type TotalFields struct

+ Limit string

v1.1.0

Aug 7, 2019

Changes in this version

+ type Allocation struct

+ Enabled string

+ type Blocks struct

+ ReadOnly string

+ type Cluster struct

+ Routing Routing

+ type ClusterSettings struct

+ func NewClusterSettings(logger log.Logger, client *http.Client, url *url.URL) *ClusterSettings

+ func (cs *ClusterSettings) Collect(ch chan<- prometheus.Metric)

+ func (cs *ClusterSettings) Describe(ch chan<- *prometheus.Desc)

+ type ClusterSettingsFullResponse struct

+ Defaults ClusterSettingsResponse

+ Persistent ClusterSettingsResponse

+ Transient ClusterSettingsResponse

+ type ClusterSettingsResponse struct

+ Cluster Cluster

+ type Index struct

+ Settings Settings

+ type IndexInfo struct

+ Blocks Blocks

type IndexStatsIndexResponse

+ Shards map[string][]IndexStatsIndexShardsDetailResponse

+ type IndexStatsIndexRoutingResponse struct

+ Node string

+ Primary bool

type IndexStatsIndexSegmentsResponse

+ MaxUnsafeAutoIDTimestamp int64

+ type IndexStatsIndexShardsDetailResponse struct

+ Routing IndexStatsIndexRoutingResponse

type Indices

+ func (i *Indices) ClusterLabelUpdates() *chan *clusterinfo.Response

+ func (i *Indices) String() string

+ type IndicesSettings struct

+ func NewIndicesSettings(logger log.Logger, client *http.Client, url *url.URL) *IndicesSettings

+ func (cs *IndicesSettings) Collect(ch chan<- prometheus.Metric)

+ func (cs *IndicesSettings) Describe(ch chan<- *prometheus.Desc)

+ type IndicesSettingsResponse map[string]Index

+ type NodeStatsFSIOStatsDeviceResponse struct

+ DeviceName string

+ Operations int64

+ ReadOperations int64

+ ReadSize int64

+ WriteOperations int64

+ WriteSize int64

+ type NodeStatsFSIOStatsResponse struct

+ Devices []NodeStatsFSIOStatsDeviceResponse

type NodeStatsFSResponse

+ IOStats NodeStatsFSIOStatsResponse

+ type NodeStatsIndicesCompletionResponse struct

+ Size int64

type NodeStatsIndicesIndexingResponse

+ IsThrottled bool

+ ThrottleTime int64

type NodeStatsIndicesMergesResponse

+ TotalThrottledTime int64

type NodeStatsIndicesResponse

+ Completion NodeStatsIndicesCompletionResponse

+ Warmer NodeStatsIndicesWarmerResponse

type NodeStatsIndicesSearchResponse

+ ScrollTime int64

+ ScrollTotal int64

+ SuggestTime int64

+ SuggestTotal int64

type NodeStatsIndicesSegmentsResponse

+ DocValuesMemory int64

+ FixedBitSet int64

+ IndexWriterMemory int64

+ NormsMemory int64

+ PointsMemory int64

+ StoredFieldsMemory int64

+ TermVectorsMemory int64

+ TermsMemory int64

+ VersionMapMemory int64

+ type NodeStatsIndicesWarmerResponse struct

+ Total int64

+ TotalTime int64

type NodeStatsNodeResponse

+ HTTP map[string]int

type NodeStatsOSCPUResponse

+ Percent int64

+ type Routing struct

+ Allocation Allocation

+ type Settings struct

+ IndexInfo IndexInfo

+ type SnapshotRepositoriesResponse map[string]struct

+ type SnapshotStatDataResponse struct

+ DurationInMillis int64

+ EndTime time.Time

+ EndTimeInMillis int64

+ Failures []interface{}

+ Indices []string

+ Shards struct{ ... }

+ Snapshot string

+ StartTime time.Time

+ StartTimeInMillis int64

+ State string

+ UUID string

+ Version string

+ VersionID int64

+ type SnapshotStatsResponse struct

+ Snapshots []SnapshotStatDataResponse

+ type Snapshots struct

+ func NewSnapshots(logger log.Logger, client *http.Client, url *url.URL) *Snapshots

+ func (s *Snapshots) Collect(ch chan<- prometheus.Metric)

+ func (s *Snapshots) Describe(ch chan<- *prometheus.Desc)

v1.0.2

Jan 9, 2018

Changes in this version

+ type IndexStatsIndexCompletionResponse struct

+ SizeInBytes int64

+ type IndexStatsIndexDetailResponse struct

+ Completion IndexStatsIndexCompletionResponse

+ Docs IndexStatsIndexDocsResponse

+ Fielddata IndexStatsIndexFielddataResponse

+ Flush IndexStatsIndexFlushResponse

+ Get IndexStatsIndexGetResponse

+ Indexing IndexStatsIndexIndexingResponse

+ Merges IndexStatsIndexMergesResponse

+ QueryCache IndexStatsIndexQueryCacheResponse

+ Recovery IndexStatsIndexRecoveryResponse

+ Refresh IndexStatsIndexRefreshResponse

+ RequestCache IndexStatsIndexRequestCacheResponse

+ Search IndexStatsIndexSearchResponse

+ Segments IndexStatsIndexSegmentsResponse

+ Store IndexStatsIndexStoreResponse

+ Translog IndexStatsIndexTranslogResponse

+ Warmer IndexStatsIndexWarmerResponse

+ type IndexStatsIndexDocsResponse struct

+ Count int64

+ Deleted int64

+ type IndexStatsIndexFielddataResponse struct

+ Evictions int64

+ MemorySizeInBytes int64

+ type IndexStatsIndexFlushResponse struct

+ Total int64

+ TotalTimeInMillis int64

+ type IndexStatsIndexGetResponse struct

+ Current int64

+ ExistsTimeInMillis int64

+ ExistsTotal int64

+ MissingTimeInMillis int64

+ MissingTotal int64

+ TimeInMillis int64

+ Total int64

+ type IndexStatsIndexIndexingResponse struct

+ DeleteCurrent int64

+ DeleteTimeInMillis int64

+ DeleteTotal int64

+ IndexCurrent int64

+ IndexFailed int64

+ IndexTimeInMillis int64

+ IndexTotal int64

+ IsThrottled bool

+ NoopUpdateTotal int64

+ ThrottleTimeInMillis int64

+ type IndexStatsIndexMergesResponse struct

+ Current int64

+ CurrentDocs int64

+ CurrentSizeInBytes int64

+ Total int64

+ TotalAutoThrottleInBytes int64

+ TotalDocs int64

+ TotalSizeInBytes int64

+ TotalStoppedTimeInMillis int64

+ TotalThrottledTimeInMillis int64

+ TotalTimeInMillis int64

+ type IndexStatsIndexQueryCacheResponse struct

+ CacheCount int64

+ CacheSize int64

+ Evictions int64

+ HitCount int64

+ MemorySizeInBytes int64

+ MissCount int64

+ TotalCount int64

+ type IndexStatsIndexRecoveryResponse struct

+ CurrentAsSource int64

+ CurrentAsTarget int64

+ ThrottleTimeInMillis int64

+ type IndexStatsIndexRefreshResponse struct

+ Listeners int64

+ Total int64

+ TotalTimeInMillis int64

+ type IndexStatsIndexRequestCacheResponse struct

+ Evictions int64

+ HitCount int64

+ MemorySizeInBytes int64

+ MissCount int64

+ type IndexStatsIndexResponse struct

+ Primaries IndexStatsIndexDetailResponse

+ Total IndexStatsIndexDetailResponse

+ type IndexStatsIndexSearchResponse struct

+ FetchCurrent int64

+ FetchTimeInMillis int64

+ FetchTotal int64

+ OpenContexts int64

+ QueryCurrent int64

+ QueryTimeInMillis int64

+ QueryTotal int64

+ ScrollCurrent int64

+ ScrollTimeInMillis int64

+ ScrollTotal int64

+ SuggestCurrent int64

+ SuggestTimeInMillis int64

+ SuggestTotal int64

+ type IndexStatsIndexSegmentsResponse struct

+ Count int64

+ DocValuesMemoryInBytes int64

+ FixedBitSetMemoryInBytes int64

+ IndexWriterMemoryInBytes int64

+ MaxUnsafeAutoIdTimestamp int64

+ MemoryInBytes int64

+ NormsMemoryInBytes int64

+ PointsMemoryInBytes int64

+ StoredFieldsMemoryInBytes int64

+ TermVectorsMemoryInBytes int64

+ TermsMemoryInBytes int64

+ VersionMapMemoryInBytes int64

+ type IndexStatsIndexStoreResponse struct

+ SizeInBytes int64

+ ThrottleTimeInMillis int64

+ type IndexStatsIndexTranslogResponse struct

+ Operations int64

+ SizeInBytes int64

+ type IndexStatsIndexWarmerResponse struct

+ Current int64

+ Total int64

+ TotalTimeInMillis int64

+ type IndexStatsShardsResponse struct

+ Failed int64

+ Successful int64

+ Total int64

+ type Indices struct

+ func NewIndices(logger log.Logger, client *http.Client, url *url.URL) *Indices

+ func (i *Indices) Collect(ch chan<- prometheus.Metric)

+ func (i *Indices) Describe(ch chan<- *prometheus.Desc)

+ type NodeStatsJVMMemPoolResponse struct

+ Max int64

+ PeakMax int64

+ PeakUsed int64

+ Used int64

type NodeStatsJVMMemResponse

+ Pools map[string]NodeStatsJVMMemPoolResponse

type NodeStatsNodeResponse

+ Attributes map[string]string

+ Http map[string]int

+ Roles []string

+ type NodeStatsOSCPULoadResponse struct

+ Load1 float64

+ Load15 float64

+ Load5 float64

type NodeStatsOSCPUResponse

+ LoadAvg NodeStatsOSCPULoadResponse

v1.0.1

Jul 24, 2017

v1.0.0

Jul 3, 2017

Changes in this version

+ type ClusterHealth struct

+ func NewClusterHealth(logger log.Logger, client *http.Client, url *url.URL) *ClusterHealth

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

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

+ type ClusterHealthResponse struct

+ ActivePrimaryShards int64

+ ActiveShards int64

+ ClusterName string

+ DelayedUnassignedShards int64

+ InitializingShards int64

+ NumberOfDataNodes int64

+ NumberOfInFlightFetch int64

+ NumberOfNodes int64

+ NumberOfPendingTasks int64

+ RelocatingShards int64

+ Status string

+ TimedOut bool

+ UnassignedShards int64

+ type NodeStatsBreakersResponse struct

+ EstimatedSize int64

+ LimitSize int64

+ Overhead float64

+ Tripped int64

+ type NodeStatsFSDataResponse struct

+ Available int64

+ Device string

+ DiskReadSize int64

+ DiskReads int64

+ DiskWriteSize int64

+ DiskWrites int64

+ Free int64

+ Mount string

+ Path string

+ Total int64

+ type NodeStatsFSResponse struct

+ Data []NodeStatsFSDataResponse

+ Timestamp int64

+ type NodeStatsHTTPResponse struct

+ CurrentOpen int64

+ TotalOpen int64

+ type NodeStatsIndicesCacheResponse struct

+ CacheCount int64

+ CacheSize int64

+ Evictions int64

+ HitCount int64

+ MemorySize int64

+ MissCount int64

+ TotalCount int64

+ type NodeStatsIndicesDocsResponse struct

+ Count int64

+ Deleted int64

+ type NodeStatsIndicesFlushResponse struct

+ Time int64

+ Total int64

+ type NodeStatsIndicesGetResponse struct

+ Current int64

+ ExistsTime int64

+ ExistsTotal int64

+ MissingTime int64

+ MissingTotal int64

+ Time int64

+ Total int64

+ type NodeStatsIndicesIndexingResponse struct

+ DeleteCurrent int64

+ DeleteTime int64

+ DeleteTotal int64

+ IndexCurrent int64

+ IndexTime int64

+ IndexTotal int64

+ type NodeStatsIndicesMergesResponse struct

+ Current int64

+ CurrentDocs int64

+ CurrentSize int64

+ Total int64

+ TotalDocs int64

+ TotalSize int64

+ TotalTime int64

+ type NodeStatsIndicesRefreshResponse struct

+ Total int64

+ TotalTime int64

+ type NodeStatsIndicesResponse struct

+ Docs NodeStatsIndicesDocsResponse

+ FieldData NodeStatsIndicesCacheResponse

+ FilterCache NodeStatsIndicesCacheResponse

+ Flush NodeStatsIndicesFlushResponse

+ Get NodeStatsIndicesGetResponse

+ Indexing NodeStatsIndicesIndexingResponse

+ Merges NodeStatsIndicesMergesResponse

+ QueryCache NodeStatsIndicesCacheResponse

+ Refresh NodeStatsIndicesRefreshResponse

+ RequestCache NodeStatsIndicesCacheResponse

+ Search NodeStatsIndicesSearchResponse

+ Segments NodeStatsIndicesSegmentsResponse

+ Store NodeStatsIndicesStoreResponse

+ Translog NodeStatsIndicesTranslogResponse

+ type NodeStatsIndicesSearchResponse struct

+ FetchCurrent int64

+ FetchTime int64

+ FetchTotal int64

+ OpenContext int64

+ QueryCurrent int64

+ QueryTime int64

+ QueryTotal int64

+ type NodeStatsIndicesSegmentsResponse struct

+ Count int64

+ Memory int64

+ type NodeStatsIndicesStoreResponse struct

+ Size int64

+ ThrottleTime int64

+ type NodeStatsIndicesTranslogResponse struct

+ Operations int64

+ Size int64

+ type NodeStatsJVMBufferPoolResponse struct

+ Count int64

+ TotalCapacity int64

+ Used int64

+ type NodeStatsJVMGCCollectorResponse struct

+ CollectionCount int64

+ CollectionTime int64

+ type NodeStatsJVMGCResponse struct

+ Collectors map[string]NodeStatsJVMGCCollectorResponse

+ type NodeStatsJVMMemResponse struct

+ HeapCommitted int64

+ HeapMax int64

+ HeapUsed int64

+ NonHeapCommitted int64

+ NonHeapUsed int64

+ type NodeStatsJVMResponse struct

+ BufferPools map[string]NodeStatsJVMBufferPoolResponse

+ GC NodeStatsJVMGCResponse

+ Mem NodeStatsJVMMemResponse

+ type NodeStatsNetworkResponse struct

+ TCP NodeStatsTCPResponse

+ type NodeStatsNodeResponse struct

+ Breakers map[string]NodeStatsBreakersResponse

+ FS NodeStatsFSResponse

+ Host string

+ Hostname string

+ Indices NodeStatsIndicesResponse

+ JVM NodeStatsJVMResponse

+ Name string

+ Network NodeStatsNetworkResponse

+ OS NodeStatsOSResponse

+ Process NodeStatsProcessResponse

+ ThreadPool map[string]NodeStatsThreadPoolPoolResponse

+ Timestamp int64

+ Transport NodeStatsTransportResponse

+ TransportAddress string

+ type NodeStatsOSCPUResponse struct

+ Idle int64

+ Steal int64

+ Sys int64

+ User int64

+ type NodeStatsOSMemResponse struct

+ ActualFree int64

+ ActualUsed int64

+ Free int64

+ Used int64

+ type NodeStatsOSResponse struct

+ CPU NodeStatsOSCPUResponse

+ LoadAvg json.RawMessage

+ Mem NodeStatsOSMemResponse

+ Swap NodeStatsOSSwapResponse

+ Timestamp int64

+ Uptime int64

+ type NodeStatsOSSwapResponse struct

+ Free int64

+ Used int64

+ type NodeStatsProcessCPUResponse struct

+ Percent int64

+ Sys int64

+ Total int64

+ User int64

+ type NodeStatsProcessMemResponse struct

+ Resident int64

+ Share int64

+ TotalVirtual int64

+ type NodeStatsProcessResponse struct

+ CPU NodeStatsProcessCPUResponse

+ MaxFD int64

+ Memory NodeStatsProcessMemResponse

+ OpenFD int64

+ Timestamp int64

+ type NodeStatsTCPResponse struct

+ ActiveOpens int64

+ AttemptFails int64

+ CurrEstab int64

+ EstabResets int64

+ InErrs int64

+ InSegs int64

+ OutRsts int64

+ OutSegs int64

+ PassiveOpens int64

+ RetransSegs int64

+ type NodeStatsThreadPoolPoolResponse struct

+ Active int64

+ Completed int64

+ Largest int64

+ Queue int64

+ Rejected int64

+ Threads int64

+ type NodeStatsTransportResponse struct

+ RxCount int64

+ RxSize int64

+ ServerOpen int64

+ TxCount int64

+ TxSize int64

+ type Nodes struct

+ func NewNodes(logger log.Logger, client *http.Client, url *url.URL, all bool) *Nodes

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

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

v1.0.0-rc1

Jun 28, 2017

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