extend

Documentation

Index

• func HeadersFrom(kvs map[string]string) http.Header
• func QueryFrom(kvs map[string]string) url.Values
• func WrappedResponse(intodata interface{}) *response.Response
• type ExtendClient
  • func NewExtendClient(addr *url.URL, tp http.RoundTripper) *ExtendClient
  • func (c *ExtendClient) CheckAlertmanagerConfig(ctx context.Context, data *monitoringv1alpha1.AlertmanagerConfig) error
  • func (c *ExtendClient) ClusterResourceStatistics(ctx context.Context, ret interface{}) error
  • func (c *ExtendClient) ClusterStatistics(ctx context.Context, ret interface{}) error
  • func (c *ExtendClient) ClusterWorkloadStatistics(ctx context.Context, ret interface{}) error
  • func (c *ExtendClient) DoRawRequest(ctx context.Context, clientreq Request) (*http.Response, error)
  • func (c *ExtendClient) DoRequest(ctx context.Context, req Request) error
  • func (c *ExtendClient) GetLokiAlertRules(ctx context.Context) (map[string]prometheus.RealTimeAlertRule, error)
  • func (c *ExtendClient) GetPromeAlertRules(ctx context.Context, name string) (map[string]prometheus.RealTimeAlertRule, error)
  • func (c *ExtendClient) GetPrometheusLabelNames(ctx context.Context, matchs []string, start, end string) ([]string, error)
  • func (c *ExtendClient) GetPrometheusLabelValues(ctx context.Context, matchs []string, label, start, end string) ([]string, error)
  • func (c *ExtendClient) Healthy(ctx context.Context) error
  • func (c *ExtendClient) KubernetesVersion(ctx context.Context) (*version.Info, error)
  • func (c *ExtendClient) LokiQuery(ctx context.Context, logql string) (loki.QueryResponseData, error)
  • func (c *ExtendClient) PrometheusQueryRange(ctx context.Context, query, start, end, step string) (prommodel.Matrix, error)
  • func (c *ExtendClient) PrometheusTargets(ctx context.Context) (*promv1.TargetsResult, error)
  • func (c *ExtendClient) PrometheusVector(ctx context.Context, query string) (prommodel.Vector, error)
• type Request

Functions

func HeadersFrom

func HeadersFrom(kvs map[string]string) http.Header

func QueryFrom

func QueryFrom(kvs map[string]string) url.Values

func WrappedResponse

func WrappedResponse(intodata interface{}) *response.Response

Types

type ExtendClient

type ExtendClient struct {
	BaseAddr   *url.URL
	HTTPClient *http.Client
	// contains filtered or unexported fields
}

func NewExtendClient

func NewExtendClient(addr *url.URL, tp http.RoundTripper) *ExtendClient

func (*ExtendClient) CheckAlertmanagerConfig

func (c *ExtendClient) CheckAlertmanagerConfig(ctx context.Context, data *monitoringv1alpha1.AlertmanagerConfig) error

func (*ExtendClient) ClusterResourceStatistics

func (c *ExtendClient) ClusterResourceStatistics(ctx context.Context, ret interface{}) error

func (*ExtendClient) ClusterStatistics

func (c *ExtendClient) ClusterStatistics(ctx context.Context, ret interface{}) error

func (*ExtendClient) ClusterWorkloadStatistics

func (c *ExtendClient) ClusterWorkloadStatistics(ctx context.Context, ret interface{}) error

statistics.system/v1

func (*ExtendClient) DoRawRequest

func (c *ExtendClient) DoRawRequest(ctx context.Context, clientreq Request) (*http.Response, error)

func (*ExtendClient) DoRequest

func (c *ExtendClient) DoRequest(ctx context.Context, req Request) error

func (*ExtendClient) GetLokiAlertRules

func (c *ExtendClient) GetLokiAlertRules(ctx context.Context) (map[string]prometheus.RealTimeAlertRule, error)

func (*ExtendClient) GetPromeAlertRules

func (c *ExtendClient) GetPromeAlertRules(ctx context.Context, name string) (map[string]prometheus.RealTimeAlertRule, error)

func (*ExtendClient) GetPrometheusLabelNames

func (c *ExtendClient) GetPrometheusLabelNames(ctx context.Context, matchs []string, start, end string) ([]string, error)

func (*ExtendClient) GetPrometheusLabelValues

func (c *ExtendClient) GetPrometheusLabelValues(ctx context.Context, matchs []string, label, start, end string) ([]string, error)

func (*ExtendClient) Healthy

func (c *ExtendClient) Healthy(ctx context.Context) error

health.system/v1

func (*ExtendClient) KubernetesVersion

func (c *ExtendClient) KubernetesVersion(ctx context.Context) (*version.Info, error)

func (*ExtendClient) LokiQuery

func (c *ExtendClient) LokiQuery(ctx context.Context, logql string) (loki.QueryResponseData, error)

func (*ExtendClient) PrometheusQueryRange

func (c *ExtendClient) PrometheusQueryRange(ctx context.Context, query, start, end, step string) (prommodel.Matrix, error)

func (*ExtendClient) PrometheusTargets

func (c *ExtendClient) PrometheusTargets(ctx context.Context) (*promv1.TargetsResult, error)

func (*ExtendClient) PrometheusVector

func (c *ExtendClient) PrometheusVector(ctx context.Context, query string) (prommodel.Vector, error)

type Request

type Request struct {
	Method  string
	Path    string // queries 可以放在 path 中
	Query   url.Values
	Headers http.Header
	Body    interface{}
	Into    interface{}
}