suanligpunative

Documentation

Overview

Package suanligpunative implements the store node API on top of the Prometheus remote read API.

Index

• Variables
• type Config
• type SeriesQuery
  • func (s *SeriesQuery) String() string
• type Store
  • func NewSuanLiGPUNativeStore(reg *prometheus.Registry, conf []byte) (*Store, error)
  • func (p *Store) FetchAndSendSeries(r *storepb.SeriesRequest, s storepb.Store_SeriesServer, query *SeriesQuery) error
  • func (p *Store) GetSeriesQueryList(ctx context.Context, r *storepb.SeriesRequest) ([]*SeriesQuery, error)
  • func (p *Store) Series(r *storepb.SeriesRequest, s storepb.Store_SeriesServer) error

Variables

var MetricNames = []string{
	"k8s_container_bs_rate_mem_usage_request",
	"k8s_container_bs_rate_mem_working_set_request",
	"k8s_container_bs_cpu_core_used",
	"k8s_container_bs_mem_no_cache_bytes",
	"k8s_container_resource_request_gpu",
	"k8s_container_bs_mem_working_set_bytes",
	"k8s_container_rate_gpu_used_request",
	"k8s_container_bs_resource_request_mem",
	"k8s_container_cpu_core_used",
	"k8s_container_bs_mem_usage_bytes",
	"k8s_container_gpu_used",
	"k8s_container_bs_resource_request_cpu",
	"k8s_container_bs_rate_mem_no_cache_request",
}

MetricNames 可选的 metrics

Types

type Config

type Config struct {
	suanliclient.SuanLiConfig `yaml:",inline"`
	Name                      string `yaml:"name"`
	ClusterID                 string `yaml:"cluster_id"` // 对应的集群
}

Config 配置

type SeriesQuery

type SeriesQuery struct {
	// contains filtered or unexported fields
}

SeriesQuery series query

func (*SeriesQuery) String

func (s *SeriesQuery) String() string

String string

type Store

type Store struct {
	staticmetrics.StaticMetricsStore
	// contains filtered or unexported fields
}

Store implements the store node API on top of the Prometheus remote read API.

func NewSuanLiGPUNativeStore

func NewSuanLiGPUNativeStore(reg *prometheus.Registry, conf []byte) (*Store, error)

NewSuanLiGPUNativeStore returns a new SuanLiGPUNativeStore that uses the given HTTP client to talk to Prometheus. It attaches the provided external labels to all results.

func (*Store) FetchAndSendSeries

func (p *Store) FetchAndSendSeries(r *storepb.SeriesRequest, s storepb.Store_SeriesServer,
	query *SeriesQuery) error

FetchAndSendSeries fetch and send series

func (*Store) GetSeriesQueryList

func (p *Store) GetSeriesQueryList(ctx context.Context, r *storepb.SeriesRequest) ([]*SeriesQuery,
	error)

GetSeriesQueryList get series query list

func (*Store) Series

func (p *Store) Series(r *storepb.SeriesRequest, s storepb.Store_SeriesServer) error

Series returns all series for a requested time range and label matcher.