providers

Documentation

Index

• Constants
• Variables
• type ClientAuth
  • func (auth *ClientAuth) Apply(req *http.Request)
• type DataSourceType
• type GrpcConfig
• type History
• type HistoryDataProxy
  • func NewHistoryDataProxy(historyProviders map[DataSourceType]History) *HistoryDataProxy
  • func (h *HistoryDataProxy) DeleteHistoryProvider(name DataSourceType)
  • func (h *HistoryDataProxy) QueryTimeSeries(metricNamer metricnaming.MetricNamer, startTime time.Time, endTime time.Time, ...) ([]*common.TimeSeries, error)
  • func (h *HistoryDataProxy) RegisterHistoryProvider(name DataSourceType, provider History)
• type Interface
• type MockConfig
• type PromConfig
• type RealTime
• type RealTimeDataProxy
  • func NewRealTimeDataProxy(realtimeProviders map[DataSourceType]RealTime) *RealTimeDataProxy
  • func (r *RealTimeDataProxy) DeleteRealTimeProvider(name DataSourceType)
  • func (r *RealTimeDataProxy) QueryLatestTimeSeries(metricNamer metricnaming.MetricNamer) ([]*common.TimeSeries, error)
  • func (r *RealTimeDataProxy) RegisterRealTimeProvider(name DataSourceType, provider RealTime)

Constants

const (
	MockDataSource         DataSourceType = "mock"
	PrometheusDataSource   DataSourceType = "prom"
	MetricServerDataSource DataSourceType = "metricserver"
	GrpcDataSource         DataSourceType = "grpc"
	DataSourceTypeKey      string         = "data-source-type"
)

Variables

var GrpcConfigKeys = []string{"grpc-ds-address", "grpc-ds-timeout"}

var PrometheusConfigKeys = []string{"prometheus-address", "prometheus-auth-username", "prometheus-auth-password",
	"prometheus-auth-bearertoken", "prometheus-query-concurrency", "prometheus-insecure-skip-verify",
	"prometheus-keepalive", "prometheus-timeout", "prometheus-bratelimit", "prometheus-maxpoints"}

Types

type ClientAuth

type ClientAuth struct {
	Username    string
	BearerToken string
	Password    string
}

ClientAuth holds the HTTP client identity info.

func (*ClientAuth) Apply

func (auth *ClientAuth) Apply(req *http.Request)

Apply applies the authentication identity info to the HTTP request headers

type DataSourceType

type DataSourceType string

type GrpcConfig

type GrpcConfig struct {
	Address string
	Timeout time.Duration
}

type History

type History interface {
	// QueryTimeSeries returns the time series that meet thw given metricNamer.
	QueryTimeSeries(metricNamer metricnaming.MetricNamer, startTime time.Time, endTime time.Time, step time.Duration) ([]*common.TimeSeries, error)
}

History is a data source can provides history time series data at any time periods.

type HistoryDataProxy

type HistoryDataProxy struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewHistoryDataProxy

func NewHistoryDataProxy(historyProviders map[DataSourceType]History) *HistoryDataProxy

NewHistoryDataProxy return a proxy for all history providers, now it has no selecting policy configurable. Default policy is traversing all providers one by one until no error return.

func (*HistoryDataProxy) DeleteHistoryProvider

func (h *HistoryDataProxy) DeleteHistoryProvider(name DataSourceType)

func (*HistoryDataProxy) QueryTimeSeries

func (h *HistoryDataProxy) QueryTimeSeries(metricNamer metricnaming.MetricNamer, startTime time.Time, endTime time.Time, step time.Duration) ([]*common.TimeSeries, error)

func (*HistoryDataProxy) RegisterHistoryProvider

func (h *HistoryDataProxy) RegisterHistoryProvider(name DataSourceType, provider History)

type Interface

type Interface interface {
	RealTime
	History
}

Interface is a source of monitoring metric that provides metrics that can be used for prediction, such as 'cpu usage', 'memory footprint', 'request per second (qps)', etc.

type MockConfig

type MockConfig struct {
	SeedFile string
}

MockConfig represents the config of an in-memory provider, which is for demonstration or testing purpose.

type PromConfig

type PromConfig struct {
	Address                string
	AdapterConfigMapNS     string
	AdapterConfigMapName   string
	AdapterConfigMapKey    string
	AdapterConfig          string
	AdapterExtensionLabels string
	Timeout                time.Duration
	KeepAlive              time.Duration
	InsecureSkipVerify     bool
	Auth                   ClientAuth

	QueryConcurrency            int
	BRateLimit                  bool
	MaxPointsLimitPerTimeSeries int
}

PromConfig represents the config of prometheus

type RealTime

type RealTime interface {
	// QueryLatestTimeSeries returns the latest metric values that meet the given metricNamer.
	QueryLatestTimeSeries(metricNamer metricnaming.MetricNamer) ([]*common.TimeSeries, error)
}

RealTime is a source of monitoring metric that provides data that is streamed data in current time.

type RealTimeDataProxy

type RealTimeDataProxy struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRealTimeDataProxy

func NewRealTimeDataProxy(realtimeProviders map[DataSourceType]RealTime) *RealTimeDataProxy

NewRealTimeDataProxy returns a proxy for all realtime providers, now it has no selecting policy configurable. Default policy is traversing all providers one by one until no error return.

func (*RealTimeDataProxy) DeleteRealTimeProvider

func (r *RealTimeDataProxy) DeleteRealTimeProvider(name DataSourceType)

func (*RealTimeDataProxy) QueryLatestTimeSeries

func (r *RealTimeDataProxy) QueryLatestTimeSeries(metricNamer metricnaming.MetricNamer) ([]*common.TimeSeries, error)

func (*RealTimeDataProxy) RegisterRealTimeProvider

func (r *RealTimeDataProxy) RegisterRealTimeProvider(name DataSourceType, provider RealTime)