api

package
v1.27.0 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: AGPL-3.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OSCPUUsedPercentMetricKey           = "cpu_used_percent"
	MemoryUsedPercentMetricKey          = "memory_used_percent"
	DiskUsedPercentMetricKey            = "disk_used_percent"
	SystemLoadMetricKey                 = "system_load"
	CPUIowaitMetricKey                  = "cpu_iowait"
	SwapMemoryUsedPercentMetricKey      = "swap_memory_used_percent"
	NetworkSummaryMetricKey             = "network_summary"
	NetworkPacketsSummaryMetricKey      = "network_packets_summary"
	DiskReadRateMetricKey               = "disk_read_rate"
	DiskWriteRateMetricKey              = "disk_write_rate"
	DiskPartitionUsageMetricKey         = "disk_partition_usage"
	NetworkInterfaceOutputRateMetricKey = "network_interface_output_rate"
)
View Source 
const (
	SystemGroupKey         = "system"
	OperationGroupKey      = "operations"
	LatencyGroupKey        = "latency"
	CacheGroupKey          = "cache"
	HttpGroupKey           = "http"
	MemoryGroupKey         = "memory"
	StorageGroupKey        = "storage"
	JVMGroupKey            = "JVM"
	TransportGroupKey      = "transport"
	DocumentGroupKey       = "document"
	IOGroupKey             = "io"
	CircuitBreakerGroupKey = "circuit_breaker"
)
View Source 
const (
	ClusterStorageMetricKey   = "cluster_storage"
	ClusterDocumentsMetricKey = "cluster_documents"
	ClusterIndicesMetricKey   = "cluster_indices"
	ClusterNodeCountMetricKey = "node_count"
	ClusterHealthMetricKey    = "cluster_health"
	ShardCountMetricKey       = "shard_count"
	CircuitBreakerMetricKey   = "circuit_breaker"
)
View Source 
const (
	NodeOSCPUMetricKey                 = "os_cpu"
	NodeProcessCPUMetricKey            = "cpu"
	OSUsedMemoryMetricKey              = "os_used_mem"
	OSLoadAverage1mMetricKey           = "os_load_average_1m"
	OSUsedSwapMetricKey                = "os_used_swap"
	OpenFileMetricKey                  = "open_file"
	OpenFilePercentMetricKey           = "open_file_percent"
	TotalDiskMetricKey                 = "disk"
	IndexingRateMetricKey              = "indexing_rate"
	IndexingBytesMetricKey             = "indexing_bytes"
	IndexingLatencyMetricKey           = "indexing_latency"
	QueryRateMetricKey                 = "query_rate"
	QueryLatencyMetricKey              = "query_latency"
	FetchRateMetricKey                 = "fetch_rate"
	ScrollRateMetricKey                = "scroll_rate"
	RefreshRateMetricKey               = "refresh_rate"
	FlushRateMetricKey                 = "flush_rate"
	MergesRateMetricKey                = "merges_rate"
	FetchLatencyMetricKey              = "fetch_latency"
	ScrollLatencyMetricKey             = "scroll_latency"
	MergeLatencyMetricKey              = "merge_latency"
	RefreshLatencyMetricKey            = "refresh_latency"
	FlushLatencyMetricKey              = "flush_latency"
	QueryCacheMetricKey                = "query_cache"
	RequestCacheMetricKey              = "request_cache"
	RequestCacheHitMetricKey           = "request_cache_hit"
	RequestCacheMissMetricKey          = "request_cache_miss"
	QueryCacheCountMetricKey           = "query_cache_count"
	QueryCacheMissMetricKey            = "query_cache_miss"
	QueryCacheHitMetricKey             = "query_cache_hit"
	FielddataCacheMetricKey            = "fielddata_cache"
	HttpConnectNumMetricKey            = "http_connect_num"
	HttpRateMetricKey                  = "http_rate"
	SegmentCountMetricKey              = "segment_count"
	SegmentMemoryMetricKey             = "segment_memory"
	SegmentStoredFieldsMemoryMetricKey = "segment_stored_fields_memory"
	SegmentTermsMemoryMetricKey        = "segment_terms_memory"
	SegmentDocValuesMemoryMetricKey    = "segment_doc_values_memory"
	SegmentIndexWriterMemoryMetricKey  = "segment_index_writer_memory"
	SegmentTermVectorsMemoryMetricKey  = "segment_term_vectors_memory"
	DocsCountMetricKey                 = "docs_count"
	DocsDeletedMetricKey               = "docs_deleted"
	IndexStorageMetricKey              = "index_storage"
	JVMHeapUsedPercentMetricKey        = "jvm_heap_used_percent"
	JVMMemYoungUsedMetricKey           = "jvm_mem_young_used"
	JVMMemYoungPeakUsedMetricKey       = "jvm_mem_young_peak_used"
	JVMMemOldUsedMetricKey             = "jvm_mem_old_used"
	JVMMemOldPeakUsedMetricKey         = "jvm_mem_old_peak_used"
	JVMUsedHeapMetricKey               = "jvm_used_heap"
	JVMYoungGCRateMetricKey            = "jvm_young_gc_rate"
	JVMYoungGCLatencyMetricKey         = "jvm_young_gc_latency"
	JVMOldGCRateMetricKey              = "jvm_old_gc_rate"
	JVMOldGCLatencyMetricKey           = "jvm_old_gc_latency"
	TransportTXRateMetricKey           = "transport_tx_rate"
	TransportRXRateMetricKey           = "transport_rx_rate"
	TransportTXBytesMetricKey          = "transport_tx_bytes"
	TransportRXBytesMetricKey          = "transport_rx_bytes"
	TransportTCPOutboundMetricKey      = "transport_outbound_connections"
	TotalIOOperationsMetricKey         = "total_io_operations"
	TotalReadIOOperationsMetricKey     = "total_read_io_operations"
	TotalWriteIOOperationsMetricKey    = "total_write_io_operations"
	ScrollOpenContextsMetricKey        = "scroll_open_contexts"
	ParentBreakerMetricKey             = "parent_breaker"
	AccountingBreakerMetricKey         = "accounting_breaker"
	FielddataBreakerMetricKey          = "fielddata_breaker"
	RequestBreakerMetricKey            = "request_breaker"
	InFlightRequestsBreakerMetricKey   = "in_flight_requests_breaker"
	ModelInferenceBreakerMetricKey     = "model_inference_breaker"
)
View Source 
const (
	NodeCPUJVMMetricKey = "jvm"
	NodeHealthMetricKey = "node_health"
	ShardStateMetricKey = "shard_state"
)
View Source 
const (
	ThreadPoolGetGroupKey        = "thread_pool_get"
	ThreadPoolSearchGroupKey     = "thread_pool_search"
	ThreadPoolFlushGroupKey      = "thread_pool_flush"
	ThreadPoolRefreshGroupKey    = "thread_pool_refresh"
	ThreadPoolWriteGroupKey      = "thread_pool_write"
	ThreadPoolForceMergeGroupKey = "thread_pool_force_merge"
	ThreadPoolIndexGroupKey      = "thread_pool_index"
	ThreadPoolBulkGroupKey       = "thread_pool_bulk"
)
View Source 
const (
	SearchThreadsMetricKey      = "search_threads"
	IndexThreadsMetricKey       = "index_threads"
	BulkThreadsMetricKey        = "bulk_threads"
	FlushThreadsMetricKey       = "flush_threads"
	RefreshThreadsMetricKey     = "refresh_threads"
	WriteThreadsMetricKey       = "write_threads"
	ForceMergeThreadsMetricKey  = "force_merge_threads"
	SearchQueueMetricKey        = "search_queue"
	IndexQueueMetricKey         = "index_queue"
	BulkQueueMetricKey          = "bulk_queue"
	FlushQueueMetricKey         = "flush_queue"
	RefreshQueueMetricKey       = "refresh_queue"
	WriteQueueMetricKey         = "write_queue"
	SearchActiveMetricKey       = "search_active"
	IndexActiveMetricKey        = "index_active"
	BulkActiveMetricKey         = "bulk_active"
	FlushActiveMetricKey        = "flush_active"
	WriteActiveMetricKey        = "write_active"
	ForceMergeActiveMetricKey   = "force_merge_active"
	SearchRejectedMetricKey     = "search_rejected"
	IndexRejectedMetricKey      = "index_rejected"
	BulkRejectedMetricKey       = "bulk_rejected"
	FlushRejectedMetricKey      = "flush_rejected"
	WriteRejectedMetricKey      = "write_rejected"
	ForceMergeRejectedMetricKey = "force_merge_rejected"
	GetThreadsMetricKey         = "get_threads"
	GetQueueMetricKey           = "get_queue"
	GetActiveMetricKey          = "get_active"
	GetRejectedMetricKey        = "get_rejected"
	RefreshActiveMetricKey      = "refresh_active"
	RefreshRejectedMetricKey    = "refresh_rejected"
	ForceMergeQueueMetricKey    = "force_merge_queue"
)

Variables

This section is empty.

Functions

func ConvertBucketItemsToAggQuery 

func ConvertBucketItemsToAggQuery(bucketItems []*common.BucketItem, metricItems []*common.MetricItem) util.MapStr

func ConvertMetricItemsToAggQuery 

func ConvertMetricItemsToAggQuery(metricItems []*common.MetricItem) map[string]interface{}

func GetMetricRangeAndBucketSize 

func GetMetricRangeAndBucketSize(minStr string, maxStr string, bucketSize int, metricCount int) (int, int64, int64, error)

func GetMinBucketSize 

func GetMinBucketSize() int

func GetMonitorState 

func GetMonitorState(clusterID string) string

func InitTestAPI 

func InitTestAPI()

Types

type APIHandler 

type APIHandler struct {
	core.Handler
	v1.APIHandler
}

func (*APIHandler) Client 

func (h *APIHandler) Client() elastic.API

func (*APIHandler) FetchClusterInfo 

func (h *APIHandler) FetchClusterInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) FetchHostInfo 

func (h *APIHandler) FetchHostInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) FetchIndexInfo 

func (h *APIHandler) FetchIndexInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) FetchNodeInfo 

func (h *APIHandler) FetchNodeInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetClusterClient 

func (h *APIHandler) GetClusterClient(id string) (bool, elastic.API, error)

TODO use prefered client

func (*APIHandler) GetClusterHealth 

func (h *APIHandler) GetClusterHealth(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetClusterIndexMetrics 

func (h *APIHandler) GetClusterIndexMetrics(ctx context.Context, id string, bucketSize int, min, max int64, metricKey string) (map[string]*common.MetricItem, error)

func (*APIHandler) GetClusterIndices 

func (h *APIHandler) GetClusterIndices(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetClusterInfo 

func (h *APIHandler) GetClusterInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetClusterMetrics 

func (h *APIHandler) GetClusterMetrics(ctx context.Context, id string, bucketSize int, min, max int64, metricKey string) (map[string]*common.MetricItem, error)

func (*APIHandler) GetClusterNodes 

func (h *APIHandler) GetClusterNodes(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetClusterStatusAction 

func (h *APIHandler) GetClusterStatusAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetHostInfo 

func (h *APIHandler) GetHostInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetHostMetricStats 

func (h *APIHandler) GetHostMetricStats(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetHostOverviewInfo 

func (h *APIHandler) GetHostOverviewInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetHosts 

func (h *APIHandler) GetHosts(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetIndexInfo 

func (h *APIHandler) GetIndexInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetIndexShards 

func (h *APIHandler) GetIndexShards(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetMetadata 

func (h *APIHandler) GetMetadata(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetMetadataByID 

func (h *APIHandler) GetMetadataByID(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetNodeInfo 

func (h *APIHandler) GetNodeInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetNodeShards 

func (h *APIHandler) GetNodeShards(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetRealtimeClusterIndices 

func (h *APIHandler) GetRealtimeClusterIndices(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetRealtimeClusterNodes 

func (h *APIHandler) GetRealtimeClusterNodes(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetShardInfo 

func (h *APIHandler) GetShardInfo(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetSingleHostMetrics 

func (h *APIHandler) GetSingleHostMetrics(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetSingleIndexMetrics 

func (h *APIHandler) GetSingleIndexMetrics(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) GetSingleNodeMetrics 

func (h *APIHandler) GetSingleNodeMetrics(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleAliasAction 

func (h *APIHandler) HandleAliasAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleBulkGetViewAction 

func (h *APIHandler) HandleBulkGetViewAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleClusterMetricsAction 

func (h *APIHandler) HandleClusterMetricsAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

new

func (*APIHandler) HandleCrateTraceTemplateAction 

func (h *APIHandler) HandleCrateTraceTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleCreateClusterAction 

func (h *APIHandler) HandleCreateClusterAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleCreateSearchTemplateAction 

func (h *APIHandler) HandleCreateSearchTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleCreateViewAction 

func (h *APIHandler) HandleCreateViewAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleDeleteClusterAction 

func (h *APIHandler) HandleDeleteClusterAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleDeleteILMPolicyAction 

func (h *APIHandler) HandleDeleteILMPolicyAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleDeleteSearchTemplateAction 

func (h *APIHandler) HandleDeleteSearchTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleDeleteTraceTemplateAction 

func (h *APIHandler) HandleDeleteTraceTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleDeleteViewAction 

func (h *APIHandler) HandleDeleteViewAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleEseSearchAction 

func (h *APIHandler) HandleEseSearchAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetAliasAction 

func (h *APIHandler) HandleGetAliasAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetClusterAction 

func (h *APIHandler) HandleGetClusterAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetFieldCapsAction 

func (h *APIHandler) HandleGetFieldCapsAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetILMPolicyAction 

func (h *APIHandler) HandleGetILMPolicyAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetNodesAction 

func (h *APIHandler) HandleGetNodesAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetSearchTemplateAction 

func (h *APIHandler) HandleGetSearchTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetSettingAction 

func (h *APIHandler) HandleGetSettingAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetStorageMetricAction 

func (h *APIHandler) HandleGetStorageMetricAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetTemplateAction 

func (h *APIHandler) HandleGetTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetTraceTemplateAction 

func (h *APIHandler) HandleGetTraceTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetViewAction 

func (h *APIHandler) HandleGetViewAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleGetViewListAction 

func (h *APIHandler) HandleGetViewListAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleIndexMetricsAction 

func (h *APIHandler) HandleIndexMetricsAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleMetricsSummaryAction 

func (h *APIHandler) HandleMetricsSummaryAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleNodeMetricsAction 

func (h *APIHandler) HandleNodeMetricsAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleProxyAction 

func (h *APIHandler) HandleProxyAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleQueueMetricsAction 

func (h *APIHandler) HandleQueueMetricsAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleRenderTemplateAction 

func (h *APIHandler) HandleRenderTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleResolveIndexAction 

func (h *APIHandler) HandleResolveIndexAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSaveILMPolicyAction 

func (h *APIHandler) HandleSaveILMPolicyAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSaveTemplateAction 

func (h *APIHandler) HandleSaveTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSaveTraceTemplateAction 

func (h *APIHandler) HandleSaveTraceTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSearchActivityAction 

func (h *APIHandler) HandleSearchActivityAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSearchClusterAction 

func (h *APIHandler) HandleSearchClusterAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSearchSearchTemplateAction 

func (h *APIHandler) HandleSearchSearchTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSearchSearchTemplateHistoryAction 

func (h *APIHandler) HandleSearchSearchTemplateHistoryAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSearchTemplateAction 

func (h *APIHandler) HandleSearchTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSearchTraceTemplateAction 

func (h *APIHandler) HandleSearchTraceTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleSettingAction 

func (h *APIHandler) HandleSettingAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleTraceIDSearchAction 

func (h *APIHandler) HandleTraceIDSearchAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleUpdateClusterAction 

func (h *APIHandler) HandleUpdateClusterAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleUpdateSearchTemplateAction 

func (h *APIHandler) HandleUpdateSearchTemplateAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleUpdateViewAction 

func (h *APIHandler) HandleUpdateViewAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) HandleValueSuggestionAction 

func (h *APIHandler) HandleValueSuggestionAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (APIHandler) ListIndex 

func (h APIHandler) ListIndex(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) SearchClusterMetadata 

func (h *APIHandler) SearchClusterMetadata(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) SearchHostMetadata 

func (h *APIHandler) SearchHostMetadata(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) SearchIndexMetadata 

func (h *APIHandler) SearchIndexMetadata(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) SearchNodeMetadata 

func (h *APIHandler) SearchNodeMetadata(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

func (*APIHandler) SetDefaultLayout 

func (h *APIHandler) SetDefaultLayout(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

type Bucket 

type Bucket struct {
	BucketBase //子 buckets

	KeyAsString             string      `json:"key_as_string,omitempty"`
	Key                     interface{} `json:"key,omitempty"`
	DocCount                int64       `json:"doc_count,omitempty"`
	DocCountErrorUpperBound int64       `json:"doc_count_error_upper_bound,omitempty"`
	SumOtherDocCount        int64       `json:"sum_other_doc_count,omitempty"`

	Buckets []Bucket `json:"buckets,omitempty"` //本 buckets
}

type BucketBase 

type BucketBase map[string]interface{}

func (BucketBase) GetChildBucket 

func (receiver BucketBase) GetChildBucket(name string) (map[string]interface{}, bool)

type CatNodeResponse 

type CatNodeResponse elastic.CatNodeResponse

type GroupMetricItem 

type GroupMetricItem struct {
	Key          string
	Field        string
	ID           string
	IsDerivative bool
	Units        string
	FormatType   string
	MetricItem   *common.MetricItem
	Field2       string
	Calc         func(value, value2 float64) float64
}

type IndexInfo 

type IndexInfo elastic.IndexInfo

type MetricData 

type MetricData map[string][][]interface{}

func ParseAggregationBucketResult 

func ParseAggregationBucketResult(bucketSize int, aggsData util.MapStr, groupKey, resultLabelKey, resultValueKey string, resultItemHandle func()) MetricData

func ParseAggregationResult 

func ParseAggregationResult(bucketSize int, aggsData util.MapStr, groupKey, metricLabelKey, metricValueKey string) MetricData

type RealtimeIndexInfo 

type RealtimeIndexInfo struct {
	IndexQPS      interface{} `json:"index_qps"`
	QueryQPS      interface{} `json:"query_qps"`
	IndexBytesQPS interface{} `json:"index_bytes_qps"`
	IndexInfo
}

type RealtimeNodeInfo 

type RealtimeNodeInfo struct {
	IndexQPS      interface{} `json:"index_qps"`
	QueryQPS      interface{} `json:"query_qps"`
	IndexBytesQPS interface{} `json:"index_bytes_qps"`
	Timestamp     uint64      `json:"timestamp"`
	CatNodeResponse
}

type SearchResponse 

type SearchResponse struct {
	Took     int  `json:"took"`
	TimedOut bool `json:"timed_out"`
	Hits     struct {
		Total    interface{} `json:"total"`
		MaxScore float32     `json:"max_score"`
	} `json:"hits"`
	Aggregations util.MapStr `json:"aggregations,omitempty"`
}

type ShardsSummary 

type ShardsSummary struct {
	Index           string      `json:"index"`
	Shards          int         `json:"shards"`
	Replicas        int         `json:"replicas"`
	DocsCount       int64       `json:"docs_count"`
	DocsDeleted     int64       `json:"docs_deleted"`
	StoreInBytes    int64       `json:"store_in_bytes"`
	PriStoreInBytes int64       `json:"pri_store_in_bytes"`
	Timestamp       interface{} `json:"timestamp"`
}

type TestAPI 

type TestAPI struct {
	core.Handler
}

func (TestAPI) HandleTestConnectionAction 

func (h TestAPI) HandleTestConnectionAction(w http.ResponseWriter, req *http.Request, ps httprouter.Params)

type TopTerm 

type TopTerm struct {
	Key   string
	Value float64
}

type TopTermOrder 

type TopTermOrder []TopTerm

func (TopTermOrder) Len 

func (t TopTermOrder) Len() int

func (TopTermOrder) Less 

func (t TopTermOrder) Less(i, j int) bool

func (TopTermOrder) Swap 

func (t TopTermOrder) Swap(i, j int)

type TreeMapNode 

type TreeMapNode struct {
	Name     string         `json:"name"`
	Value    float64        `json:"value,omitempty"`
	Children []*TreeMapNode `json:"children,omitempty"`
	SubKeys  map[string]int `json:"-"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.