grpc

Documentation

Index

• func ValidateListMetricsRequest(req v1alpha1.ListMetricsRequest) error
• type Config
  • func NewConfig() *Config
  • func (c *Config) Validate() error
• type Service
  • func NewService(c *Config, manager manager.Manager) *Service
  • func (s *Service) Close() error
  • func (s *Service) CreatePredictResult(ctx context.Context, in *operator_v1alpha1.CreatePredictResultRequest) (*operator_v1alpha1.CreatePredictResultResponse, error)
  • func (s *Service) Err() <-chan error
  • func (s *Service) GetResourceInfo(ctx context.Context, in *operator_v1alpha1.GetResourceInfoRequest) (*operator_v1alpha1.GetResourceInfoResponse, error)
  • func (s *Service) GetResourceRecommendation(ctx context.Context, in *operator_v1alpha1.GetResourceRecommendationRequest) (*operator_v1alpha1.GetResourceRecommendationResponse, error)
  • func (s *Service) ListMetrics(ctx context.Context, in *operator_v1alpha1.ListMetricsRequest) (*operator_v1alpha1.ListMetricsResponse, error)
  • func (s *Service) ListMetricsSum(ctx context.Context, in *operator_v1alpha1.ListMetricsSumRequest) (*operator_v1alpha1.ListMetricsSumResponse, error)
  • func (s *Service) Open() error

Functions

func ValidateListMetricsRequest

func ValidateListMetricsRequest(req v1alpha1.ListMetricsRequest) error

Types

type Config

type Config struct {
	BindAddress string             `mapstructure:"bind-address"`
	Prometheus  *prometheus.Config `mapstructure:"prometheus"`
}

func NewConfig

func NewConfig() *Config

func (*Config) Validate

func (c *Config) Validate() error

type Service

type Service struct {
	Config    Config
	Manager   manager.Manager
	MetricsDB metrics.MetricsDB
	// contains filtered or unexported fields
}

func NewService

func NewService(c *Config, manager manager.Manager) *Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) CreatePredictResult

func (s *Service) CreatePredictResult(ctx context.Context, in *operator_v1alpha1.CreatePredictResultRequest) (*operator_v1alpha1.CreatePredictResultResponse, error)

func (*Service) Err

func (s *Service) Err() <-chan error

func (*Service) GetResourceInfo

func (s *Service) GetResourceInfo(ctx context.Context, in *operator_v1alpha1.GetResourceInfoRequest) (*operator_v1alpha1.GetResourceInfoResponse, error)

func (*Service) GetResourceRecommendation

func (s *Service) GetResourceRecommendation(ctx context.Context, in *operator_v1alpha1.GetResourceRecommendationRequest) (*operator_v1alpha1.GetResourceRecommendationResponse, error)

func (*Service) ListMetrics

func (s *Service) ListMetrics(ctx context.Context, in *operator_v1alpha1.ListMetricsRequest) (*operator_v1alpha1.ListMetricsResponse, error)

func (*Service) ListMetricsSum

func (s *Service) ListMetricsSum(ctx context.Context, in *operator_v1alpha1.ListMetricsSumRequest) (*operator_v1alpha1.ListMetricsSumResponse, error)

func (*Service) Open

func (s *Service) Open() error