Documentation ¶
Index ¶
- Variables
- func RegisterOperatorServiceServer(s *grpc.Server, srv OperatorServiceServer)
- type Container
- func (*Container) Descriptor() ([]byte, []int)
- func (m *Container) GetInitialResource() *Resource
- func (m *Container) GetName() string
- func (m *Container) GetResource() *Resource
- func (*Container) ProtoMessage()
- func (m *Container) Reset()
- func (m *Container) String() string
- func (m *Container) XXX_DiscardUnknown()
- func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Container) XXX_Merge(src proto.Message)
- func (m *Container) XXX_Size() int
- func (m *Container) XXX_Unmarshal(b []byte) error
- type CreatePredictResultRequest
- func (*CreatePredictResultRequest) Descriptor() ([]byte, []int)
- func (m *CreatePredictResultRequest) GetPredictPods() []*PredictPod
- func (*CreatePredictResultRequest) ProtoMessage()
- func (m *CreatePredictResultRequest) Reset()
- func (m *CreatePredictResultRequest) String() string
- func (m *CreatePredictResultRequest) XXX_DiscardUnknown()
- func (m *CreatePredictResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreatePredictResultRequest) XXX_Merge(src proto.Message)
- func (m *CreatePredictResultRequest) XXX_Size() int
- func (m *CreatePredictResultRequest) XXX_Unmarshal(b []byte) error
- type CreatePredictResultResponse
- func (*CreatePredictResultResponse) Descriptor() ([]byte, []int)
- func (m *CreatePredictResultResponse) GetStatus() *status.Status
- func (*CreatePredictResultResponse) ProtoMessage()
- func (m *CreatePredictResultResponse) Reset()
- func (m *CreatePredictResultResponse) String() string
- func (m *CreatePredictResultResponse) XXX_DiscardUnknown()
- func (m *CreatePredictResultResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreatePredictResultResponse) XXX_Merge(src proto.Message)
- func (m *CreatePredictResultResponse) XXX_Size() int
- func (m *CreatePredictResultResponse) XXX_Unmarshal(b []byte) error
- type GetResourceInfoRequest
- func (*GetResourceInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetResourceInfoRequest) GetName() string
- func (m *GetResourceInfoRequest) GetNamespace() string
- func (m *GetResourceInfoRequest) GetType() ResourceType
- func (*GetResourceInfoRequest) ProtoMessage()
- func (m *GetResourceInfoRequest) Reset()
- func (m *GetResourceInfoRequest) String() string
- func (m *GetResourceInfoRequest) XXX_DiscardUnknown()
- func (m *GetResourceInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResourceInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetResourceInfoRequest) XXX_Size() int
- func (m *GetResourceInfoRequest) XXX_Unmarshal(b []byte) error
- type GetResourceInfoResponse
- func (*GetResourceInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetResourceInfoResponse) GetName() string
- func (m *GetResourceInfoResponse) GetNamespace() string
- func (m *GetResourceInfoResponse) GetPodInfo() *PodInfo
- func (m *GetResourceInfoResponse) GetStatus() *status.Status
- func (m *GetResourceInfoResponse) GetType() ResourceType
- func (m *GetResourceInfoResponse) GetUid() string
- func (*GetResourceInfoResponse) ProtoMessage()
- func (m *GetResourceInfoResponse) Reset()
- func (m *GetResourceInfoResponse) String() string
- func (m *GetResourceInfoResponse) XXX_DiscardUnknown()
- func (m *GetResourceInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResourceInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetResourceInfoResponse) XXX_Size() int
- func (m *GetResourceInfoResponse) XXX_Unmarshal(b []byte) error
- type GetResourceRecommendationRequest
- func (*GetResourceRecommendationRequest) Descriptor() ([]byte, []int)
- func (m *GetResourceRecommendationRequest) GetName() string
- func (m *GetResourceRecommendationRequest) GetNamespace() string
- func (m *GetResourceRecommendationRequest) GetType() ResourceType
- func (*GetResourceRecommendationRequest) ProtoMessage()
- func (m *GetResourceRecommendationRequest) Reset()
- func (m *GetResourceRecommendationRequest) String() string
- func (m *GetResourceRecommendationRequest) XXX_DiscardUnknown()
- func (m *GetResourceRecommendationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResourceRecommendationRequest) XXX_Merge(src proto.Message)
- func (m *GetResourceRecommendationRequest) XXX_Size() int
- func (m *GetResourceRecommendationRequest) XXX_Unmarshal(b []byte) error
- type GetResourceRecommendationResponse
- func (*GetResourceRecommendationResponse) Descriptor() ([]byte, []int)
- func (m *GetResourceRecommendationResponse) GetName() string
- func (m *GetResourceRecommendationResponse) GetNamespace() string
- func (m *GetResourceRecommendationResponse) GetPodInfo() *PodInfo
- func (m *GetResourceRecommendationResponse) GetStatus() *status.Status
- func (m *GetResourceRecommendationResponse) GetType() ResourceType
- func (m *GetResourceRecommendationResponse) GetUid() string
- func (*GetResourceRecommendationResponse) ProtoMessage()
- func (m *GetResourceRecommendationResponse) Reset()
- func (m *GetResourceRecommendationResponse) String() string
- func (m *GetResourceRecommendationResponse) XXX_DiscardUnknown()
- func (m *GetResourceRecommendationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResourceRecommendationResponse) XXX_Merge(src proto.Message)
- func (m *GetResourceRecommendationResponse) XXX_Size() int
- func (m *GetResourceRecommendationResponse) XXX_Unmarshal(b []byte) error
- type LabelSelector
- func (*LabelSelector) Descriptor() ([]byte, []int)
- func (m *LabelSelector) GetKey() string
- func (m *LabelSelector) GetOp() StrOp
- func (m *LabelSelector) GetValue() string
- func (*LabelSelector) ProtoMessage()
- func (m *LabelSelector) Reset()
- func (m *LabelSelector) String() string
- func (m *LabelSelector) XXX_DiscardUnknown()
- func (m *LabelSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LabelSelector) XXX_Merge(src proto.Message)
- func (m *LabelSelector) XXX_Size() int
- func (m *LabelSelector) XXX_Unmarshal(b []byte) error
- type ListMetricsRequest
- func (*ListMetricsRequest) Descriptor() ([]byte, []int)
- func (m *ListMetricsRequest) GetConditions() []*LabelSelector
- func (m *ListMetricsRequest) GetDuration() *duration.Duration
- func (m *ListMetricsRequest) GetMetricType() MetricType
- func (m *ListMetricsRequest) GetTime() *timestamp.Timestamp
- func (m *ListMetricsRequest) GetTimeRange() *TimeRange
- func (m *ListMetricsRequest) GetTimeSelector() isListMetricsRequest_TimeSelector
- func (*ListMetricsRequest) ProtoMessage()
- func (m *ListMetricsRequest) Reset()
- func (m *ListMetricsRequest) String() string
- func (m *ListMetricsRequest) XXX_DiscardUnknown()
- func (m *ListMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListMetricsRequest) XXX_Merge(src proto.Message)
- func (*ListMetricsRequest) XXX_OneofWrappers() []interface{}
- func (m *ListMetricsRequest) XXX_Size() int
- func (m *ListMetricsRequest) XXX_Unmarshal(b []byte) error
- type ListMetricsRequest_Duration
- type ListMetricsRequest_Time
- type ListMetricsRequest_TimeRange
- type ListMetricsResponse
- func (*ListMetricsResponse) Descriptor() ([]byte, []int)
- func (m *ListMetricsResponse) GetMetrics() []*MetricResult
- func (m *ListMetricsResponse) GetStatus() *status.Status
- func (*ListMetricsResponse) ProtoMessage()
- func (m *ListMetricsResponse) Reset()
- func (m *ListMetricsResponse) String() string
- func (m *ListMetricsResponse) XXX_DiscardUnknown()
- func (m *ListMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListMetricsResponse) XXX_Merge(src proto.Message)
- func (m *ListMetricsResponse) XXX_Size() int
- func (m *ListMetricsResponse) XXX_Unmarshal(b []byte) error
- type ListMetricsSumRequest
- func (*ListMetricsSumRequest) Descriptor() ([]byte, []int)
- func (m *ListMetricsSumRequest) GetConditions() []*LabelSelector
- func (m *ListMetricsSumRequest) GetDuration() *duration.Duration
- func (m *ListMetricsSumRequest) GetLabels() []string
- func (m *ListMetricsSumRequest) GetMetricType() MetricType
- func (m *ListMetricsSumRequest) GetTime() *timestamp.Timestamp
- func (m *ListMetricsSumRequest) GetTimeRange() *TimeRange
- func (m *ListMetricsSumRequest) GetTimeSelector() isListMetricsSumRequest_TimeSelector
- func (*ListMetricsSumRequest) ProtoMessage()
- func (m *ListMetricsSumRequest) Reset()
- func (m *ListMetricsSumRequest) String() string
- func (m *ListMetricsSumRequest) XXX_DiscardUnknown()
- func (m *ListMetricsSumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListMetricsSumRequest) XXX_Merge(src proto.Message)
- func (*ListMetricsSumRequest) XXX_OneofWrappers() []interface{}
- func (m *ListMetricsSumRequest) XXX_Size() int
- func (m *ListMetricsSumRequest) XXX_Unmarshal(b []byte) error
- type ListMetricsSumRequest_Duration
- type ListMetricsSumRequest_Time
- type ListMetricsSumRequest_TimeRange
- type ListMetricsSumResponse
- func (*ListMetricsSumResponse) Descriptor() ([]byte, []int)
- func (m *ListMetricsSumResponse) GetMetrics() []*MetricResult
- func (m *ListMetricsSumResponse) GetStatus() *status.Status
- func (*ListMetricsSumResponse) ProtoMessage()
- func (m *ListMetricsSumResponse) Reset()
- func (m *ListMetricsSumResponse) String() string
- func (m *ListMetricsSumResponse) XXX_DiscardUnknown()
- func (m *ListMetricsSumResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListMetricsSumResponse) XXX_Merge(src proto.Message)
- func (m *ListMetricsSumResponse) XXX_Size() int
- func (m *ListMetricsSumResponse) XXX_Unmarshal(b []byte) error
- type MetricResult
- func (*MetricResult) Descriptor() ([]byte, []int)
- func (m *MetricResult) GetLabels() map[string]string
- func (m *MetricResult) GetSamples() []*Sample
- func (*MetricResult) ProtoMessage()
- func (m *MetricResult) Reset()
- func (m *MetricResult) String() string
- func (m *MetricResult) XXX_DiscardUnknown()
- func (m *MetricResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetricResult) XXX_Merge(src proto.Message)
- func (m *MetricResult) XXX_Size() int
- func (m *MetricResult) XXX_Unmarshal(b []byte) error
- type MetricType
- type OperatorServiceClient
- type OperatorServiceServer
- type PodInfo
- func (*PodInfo) Descriptor() ([]byte, []int)
- func (m *PodInfo) GetContainers() []*Container
- func (*PodInfo) ProtoMessage()
- func (m *PodInfo) Reset()
- func (m *PodInfo) String() string
- func (m *PodInfo) XXX_DiscardUnknown()
- func (m *PodInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PodInfo) XXX_Merge(src proto.Message)
- func (m *PodInfo) XXX_Size() int
- func (m *PodInfo) XXX_Unmarshal(b []byte) error
- type PredictContainer
- func (*PredictContainer) Descriptor() ([]byte, []int)
- func (m *PredictContainer) GetInitialResource() *Resource
- func (m *PredictContainer) GetName() string
- func (m *PredictContainer) GetRawPredictData() map[string]*TimeSeriesData
- func (m *PredictContainer) GetRecommendations() []*Recommendation
- func (*PredictContainer) ProtoMessage()
- func (m *PredictContainer) Reset()
- func (m *PredictContainer) String() string
- func (m *PredictContainer) XXX_DiscardUnknown()
- func (m *PredictContainer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PredictContainer) XXX_Merge(src proto.Message)
- func (m *PredictContainer) XXX_Size() int
- func (m *PredictContainer) XXX_Unmarshal(b []byte) error
- type PredictData
- func (*PredictData) Descriptor() ([]byte, []int)
- func (m *PredictData) GetTime() *timestamp.Timestamp
- func (m *PredictData) GetValue() string
- func (*PredictData) ProtoMessage()
- func (m *PredictData) Reset()
- func (m *PredictData) String() string
- func (m *PredictData) XXX_DiscardUnknown()
- func (m *PredictData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PredictData) XXX_Merge(src proto.Message)
- func (m *PredictData) XXX_Size() int
- func (m *PredictData) XXX_Unmarshal(b []byte) error
- type PredictPod
- func (*PredictPod) Descriptor() ([]byte, []int)
- func (m *PredictPod) GetName() string
- func (m *PredictPod) GetNamespace() string
- func (m *PredictPod) GetPredictContainers() []*PredictContainer
- func (m *PredictPod) GetUid() string
- func (*PredictPod) ProtoMessage()
- func (m *PredictPod) Reset()
- func (m *PredictPod) String() string
- func (m *PredictPod) XXX_DiscardUnknown()
- func (m *PredictPod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PredictPod) XXX_Merge(src proto.Message)
- func (m *PredictPod) XXX_Size() int
- func (m *PredictPod) XXX_Unmarshal(b []byte) error
- type Recommendation
- func (*Recommendation) Descriptor() ([]byte, []int)
- func (m *Recommendation) GetResource() *Resource
- func (m *Recommendation) GetTime() *timestamp.Timestamp
- func (*Recommendation) ProtoMessage()
- func (m *Recommendation) Reset()
- func (m *Recommendation) String() string
- func (m *Recommendation) XXX_DiscardUnknown()
- func (m *Recommendation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Recommendation) XXX_Merge(src proto.Message)
- func (m *Recommendation) XXX_Size() int
- func (m *Recommendation) XXX_Unmarshal(b []byte) error
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)
- func (m *Resource) GetLimit() map[string]string
- func (m *Resource) GetRequest() map[string]string
- func (*Resource) ProtoMessage()
- func (m *Resource) Reset()
- func (m *Resource) String() string
- func (m *Resource) XXX_DiscardUnknown()
- func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Resource) XXX_Merge(src proto.Message)
- func (m *Resource) XXX_Size() int
- func (m *Resource) XXX_Unmarshal(b []byte) error
- type ResourceType
- type Sample
- func (*Sample) Descriptor() ([]byte, []int)
- func (m *Sample) GetTime() *timestamp.Timestamp
- func (m *Sample) GetValue() float64
- func (*Sample) ProtoMessage()
- func (m *Sample) Reset()
- func (m *Sample) String() string
- func (m *Sample) XXX_DiscardUnknown()
- func (m *Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Sample) XXX_Merge(src proto.Message)
- func (m *Sample) XXX_Size() int
- func (m *Sample) XXX_Unmarshal(b []byte) error
- type StrOp
- type TimeRange
- func (*TimeRange) Descriptor() ([]byte, []int)
- func (m *TimeRange) GetEndTime() *timestamp.Timestamp
- func (m *TimeRange) GetStartTime() *timestamp.Timestamp
- func (m *TimeRange) GetStep() *duration.Duration
- func (*TimeRange) ProtoMessage()
- func (m *TimeRange) Reset()
- func (m *TimeRange) String() string
- func (m *TimeRange) XXX_DiscardUnknown()
- func (m *TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeRange) XXX_Merge(src proto.Message)
- func (m *TimeRange) XXX_Size() int
- func (m *TimeRange) XXX_Unmarshal(b []byte) error
- type TimeSeriesData
- func (*TimeSeriesData) Descriptor() ([]byte, []int)
- func (m *TimeSeriesData) GetPredictData() []*PredictData
- func (*TimeSeriesData) ProtoMessage()
- func (m *TimeSeriesData) Reset()
- func (m *TimeSeriesData) String() string
- func (m *TimeSeriesData) XXX_DiscardUnknown()
- func (m *TimeSeriesData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimeSeriesData) XXX_Merge(src proto.Message)
- func (m *TimeSeriesData) XXX_Size() int
- func (m *TimeSeriesData) XXX_Unmarshal(b []byte) error
- type UnimplementedOperatorServiceServer
- func (*UnimplementedOperatorServiceServer) CreatePredictResult(ctx context.Context, req *CreatePredictResultRequest) (*CreatePredictResultResponse, error)
- func (*UnimplementedOperatorServiceServer) GetResourceInfo(ctx context.Context, req *GetResourceInfoRequest) (*GetResourceInfoResponse, error)
- func (*UnimplementedOperatorServiceServer) GetResourceRecommendation(ctx context.Context, req *GetResourceRecommendationRequest) (*GetResourceRecommendationResponse, error)
- func (*UnimplementedOperatorServiceServer) ListMetrics(ctx context.Context, req *ListMetricsRequest) (*ListMetricsResponse, error)
- func (*UnimplementedOperatorServiceServer) ListMetricsSum(ctx context.Context, req *ListMetricsSumRequest) (*ListMetricsSumResponse, error)
Constants ¶
This section is empty.
Variables ¶
var MetricType_name = map[int32]string{
0: "CONTAINER_CPU_USAGE_TOTAL",
1: "CONTAINER_CPU_USAGE_TOTAL_RATE",
2: "CONTAINER_MEMORY_USAGE",
3: "NODE_CPU_USAGE_SECONDS_AVG1M",
4: "NODE_MEMORY_USAGE_BYTES",
}
var MetricType_value = map[string]int32{
"CONTAINER_CPU_USAGE_TOTAL": 0,
"CONTAINER_CPU_USAGE_TOTAL_RATE": 1,
"CONTAINER_MEMORY_USAGE": 2,
"NODE_CPU_USAGE_SECONDS_AVG1M": 3,
"NODE_MEMORY_USAGE_BYTES": 4,
}
var ResourceType_name = map[int32]string{
0: "POD",
}
var ResourceType_value = map[string]int32{
"POD": 0,
}
var StrOp_name = map[int32]string{
0: "EQUAL",
1: "NOT_EQUAL",
}
var StrOp_value = map[string]int32{
"EQUAL": 0,
"NOT_EQUAL": 1,
}
Functions ¶
func RegisterOperatorServiceServer ¶
func RegisterOperatorServiceServer(s *grpc.Server, srv OperatorServiceServer)
Types ¶
type Container ¶
type Container struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Resource *Resource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"` InitialResource *Resource `protobuf:"bytes,3,opt,name=initial_resource,json=initialResource,proto3" json:"initial_resource,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a container
func (*Container) Descriptor ¶
func (*Container) GetInitialResource ¶
func (*Container) GetResource ¶
func (*Container) ProtoMessage ¶
func (*Container) ProtoMessage()
func (*Container) XXX_DiscardUnknown ¶
func (m *Container) XXX_DiscardUnknown()
func (*Container) XXX_Marshal ¶
func (*Container) XXX_Unmarshal ¶
type CreatePredictResultRequest ¶
type CreatePredictResultRequest struct { PredictPods []*PredictPod `protobuf:"bytes,1,rep,name=predict_pods,json=predictPods,proto3" json:"predict_pods,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a request for generating predictions for pods
func (*CreatePredictResultRequest) Descriptor ¶
func (*CreatePredictResultRequest) Descriptor() ([]byte, []int)
func (*CreatePredictResultRequest) GetPredictPods ¶
func (m *CreatePredictResultRequest) GetPredictPods() []*PredictPod
func (*CreatePredictResultRequest) ProtoMessage ¶
func (*CreatePredictResultRequest) ProtoMessage()
func (*CreatePredictResultRequest) Reset ¶
func (m *CreatePredictResultRequest) Reset()
func (*CreatePredictResultRequest) String ¶
func (m *CreatePredictResultRequest) String() string
func (*CreatePredictResultRequest) XXX_DiscardUnknown ¶
func (m *CreatePredictResultRequest) XXX_DiscardUnknown()
func (*CreatePredictResultRequest) XXX_Marshal ¶
func (m *CreatePredictResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreatePredictResultRequest) XXX_Merge ¶
func (m *CreatePredictResultRequest) XXX_Merge(src proto.Message)
func (*CreatePredictResultRequest) XXX_Size ¶
func (m *CreatePredictResultRequest) XXX_Size() int
func (*CreatePredictResultRequest) XXX_Unmarshal ¶
func (m *CreatePredictResultRequest) XXX_Unmarshal(b []byte) error
type CreatePredictResultResponse ¶
type CreatePredictResultResponse struct { Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a response of a creating pod prediction request
func (*CreatePredictResultResponse) Descriptor ¶
func (*CreatePredictResultResponse) Descriptor() ([]byte, []int)
func (*CreatePredictResultResponse) GetStatus ¶
func (m *CreatePredictResultResponse) GetStatus() *status.Status
func (*CreatePredictResultResponse) ProtoMessage ¶
func (*CreatePredictResultResponse) ProtoMessage()
func (*CreatePredictResultResponse) Reset ¶
func (m *CreatePredictResultResponse) Reset()
func (*CreatePredictResultResponse) String ¶
func (m *CreatePredictResultResponse) String() string
func (*CreatePredictResultResponse) XXX_DiscardUnknown ¶
func (m *CreatePredictResultResponse) XXX_DiscardUnknown()
func (*CreatePredictResultResponse) XXX_Marshal ¶
func (m *CreatePredictResultResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreatePredictResultResponse) XXX_Merge ¶
func (m *CreatePredictResultResponse) XXX_Merge(src proto.Message)
func (*CreatePredictResultResponse) XXX_Size ¶
func (m *CreatePredictResultResponse) XXX_Size() int
func (*CreatePredictResultResponse) XXX_Unmarshal ¶
func (m *CreatePredictResultResponse) XXX_Unmarshal(b []byte) error
type GetResourceInfoRequest ¶
type GetResourceInfoRequest struct { Type ResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=containers_ai.alameda.v1alpha1.operator.ResourceType" json:"type,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a request of getting info of a resource type
func (*GetResourceInfoRequest) Descriptor ¶
func (*GetResourceInfoRequest) Descriptor() ([]byte, []int)
func (*GetResourceInfoRequest) GetName ¶
func (m *GetResourceInfoRequest) GetName() string
func (*GetResourceInfoRequest) GetNamespace ¶
func (m *GetResourceInfoRequest) GetNamespace() string
func (*GetResourceInfoRequest) GetType ¶
func (m *GetResourceInfoRequest) GetType() ResourceType
func (*GetResourceInfoRequest) ProtoMessage ¶
func (*GetResourceInfoRequest) ProtoMessage()
func (*GetResourceInfoRequest) Reset ¶
func (m *GetResourceInfoRequest) Reset()
func (*GetResourceInfoRequest) String ¶
func (m *GetResourceInfoRequest) String() string
func (*GetResourceInfoRequest) XXX_DiscardUnknown ¶
func (m *GetResourceInfoRequest) XXX_DiscardUnknown()
func (*GetResourceInfoRequest) XXX_Marshal ¶
func (m *GetResourceInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResourceInfoRequest) XXX_Merge ¶
func (m *GetResourceInfoRequest) XXX_Merge(src proto.Message)
func (*GetResourceInfoRequest) XXX_Size ¶
func (m *GetResourceInfoRequest) XXX_Size() int
func (*GetResourceInfoRequest) XXX_Unmarshal ¶
func (m *GetResourceInfoRequest) XXX_Unmarshal(b []byte) error
type GetResourceInfoResponse ¶
type GetResourceInfoResponse struct { Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` Type ResourceType `protobuf:"varint,2,opt,name=type,proto3,enum=containers_ai.alameda.v1alpha1.operator.ResourceType" json:"type,omitempty"` Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"` PodInfo *PodInfo `protobuf:"bytes,6,opt,name=pod_info,json=podInfo,proto3" json:"pod_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a response of getting resource info
func (*GetResourceInfoResponse) Descriptor ¶
func (*GetResourceInfoResponse) Descriptor() ([]byte, []int)
func (*GetResourceInfoResponse) GetName ¶
func (m *GetResourceInfoResponse) GetName() string
func (*GetResourceInfoResponse) GetNamespace ¶
func (m *GetResourceInfoResponse) GetNamespace() string
func (*GetResourceInfoResponse) GetPodInfo ¶
func (m *GetResourceInfoResponse) GetPodInfo() *PodInfo
func (*GetResourceInfoResponse) GetStatus ¶
func (m *GetResourceInfoResponse) GetStatus() *status.Status
func (*GetResourceInfoResponse) GetType ¶
func (m *GetResourceInfoResponse) GetType() ResourceType
func (*GetResourceInfoResponse) GetUid ¶
func (m *GetResourceInfoResponse) GetUid() string
func (*GetResourceInfoResponse) ProtoMessage ¶
func (*GetResourceInfoResponse) ProtoMessage()
func (*GetResourceInfoResponse) Reset ¶
func (m *GetResourceInfoResponse) Reset()
func (*GetResourceInfoResponse) String ¶
func (m *GetResourceInfoResponse) String() string
func (*GetResourceInfoResponse) XXX_DiscardUnknown ¶
func (m *GetResourceInfoResponse) XXX_DiscardUnknown()
func (*GetResourceInfoResponse) XXX_Marshal ¶
func (m *GetResourceInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResourceInfoResponse) XXX_Merge ¶
func (m *GetResourceInfoResponse) XXX_Merge(src proto.Message)
func (*GetResourceInfoResponse) XXX_Size ¶
func (m *GetResourceInfoResponse) XXX_Size() int
func (*GetResourceInfoResponse) XXX_Unmarshal ¶
func (m *GetResourceInfoResponse) XXX_Unmarshal(b []byte) error
type GetResourceRecommendationRequest ¶
type GetResourceRecommendationRequest struct { Type ResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=containers_ai.alameda.v1alpha1.operator.ResourceType" json:"type,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a request of getting recommendation of a resource type
func (*GetResourceRecommendationRequest) Descriptor ¶
func (*GetResourceRecommendationRequest) Descriptor() ([]byte, []int)
func (*GetResourceRecommendationRequest) GetName ¶
func (m *GetResourceRecommendationRequest) GetName() string
func (*GetResourceRecommendationRequest) GetNamespace ¶
func (m *GetResourceRecommendationRequest) GetNamespace() string
func (*GetResourceRecommendationRequest) GetType ¶
func (m *GetResourceRecommendationRequest) GetType() ResourceType
func (*GetResourceRecommendationRequest) ProtoMessage ¶
func (*GetResourceRecommendationRequest) ProtoMessage()
func (*GetResourceRecommendationRequest) Reset ¶
func (m *GetResourceRecommendationRequest) Reset()
func (*GetResourceRecommendationRequest) String ¶
func (m *GetResourceRecommendationRequest) String() string
func (*GetResourceRecommendationRequest) XXX_DiscardUnknown ¶
func (m *GetResourceRecommendationRequest) XXX_DiscardUnknown()
func (*GetResourceRecommendationRequest) XXX_Marshal ¶
func (m *GetResourceRecommendationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResourceRecommendationRequest) XXX_Merge ¶
func (m *GetResourceRecommendationRequest) XXX_Merge(src proto.Message)
func (*GetResourceRecommendationRequest) XXX_Size ¶
func (m *GetResourceRecommendationRequest) XXX_Size() int
func (*GetResourceRecommendationRequest) XXX_Unmarshal ¶
func (m *GetResourceRecommendationRequest) XXX_Unmarshal(b []byte) error
type GetResourceRecommendationResponse ¶
type GetResourceRecommendationResponse struct { Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` Type ResourceType `protobuf:"varint,2,opt,name=type,proto3,enum=containers_ai.alameda.v1alpha1.operator.ResourceType" json:"type,omitempty"` Uid string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"` Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"` PodInfo *PodInfo `protobuf:"bytes,6,opt,name=pod_info,json=podInfo,proto3" json:"pod_info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a response of getting resource recommendation
func (*GetResourceRecommendationResponse) Descriptor ¶
func (*GetResourceRecommendationResponse) Descriptor() ([]byte, []int)
func (*GetResourceRecommendationResponse) GetName ¶
func (m *GetResourceRecommendationResponse) GetName() string
func (*GetResourceRecommendationResponse) GetNamespace ¶
func (m *GetResourceRecommendationResponse) GetNamespace() string
func (*GetResourceRecommendationResponse) GetPodInfo ¶
func (m *GetResourceRecommendationResponse) GetPodInfo() *PodInfo
func (*GetResourceRecommendationResponse) GetStatus ¶
func (m *GetResourceRecommendationResponse) GetStatus() *status.Status
func (*GetResourceRecommendationResponse) GetType ¶
func (m *GetResourceRecommendationResponse) GetType() ResourceType
func (*GetResourceRecommendationResponse) GetUid ¶
func (m *GetResourceRecommendationResponse) GetUid() string
func (*GetResourceRecommendationResponse) ProtoMessage ¶
func (*GetResourceRecommendationResponse) ProtoMessage()
func (*GetResourceRecommendationResponse) Reset ¶
func (m *GetResourceRecommendationResponse) Reset()
func (*GetResourceRecommendationResponse) String ¶
func (m *GetResourceRecommendationResponse) String() string
func (*GetResourceRecommendationResponse) XXX_DiscardUnknown ¶
func (m *GetResourceRecommendationResponse) XXX_DiscardUnknown()
func (*GetResourceRecommendationResponse) XXX_Marshal ¶
func (m *GetResourceRecommendationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResourceRecommendationResponse) XXX_Merge ¶
func (m *GetResourceRecommendationResponse) XXX_Merge(src proto.Message)
func (*GetResourceRecommendationResponse) XXX_Size ¶
func (m *GetResourceRecommendationResponse) XXX_Size() int
func (*GetResourceRecommendationResponse) XXX_Unmarshal ¶
func (m *GetResourceRecommendationResponse) XXX_Unmarshal(b []byte) error
type LabelSelector ¶
type LabelSelector struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Op StrOp `protobuf:"varint,2,opt,name=op,proto3,enum=containers_ai.alameda.v1alpha1.operator.StrOp" json:"op,omitempty"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a Kubernetes label selector
func (*LabelSelector) Descriptor ¶
func (*LabelSelector) Descriptor() ([]byte, []int)
func (*LabelSelector) GetKey ¶
func (m *LabelSelector) GetKey() string
func (*LabelSelector) GetOp ¶
func (m *LabelSelector) GetOp() StrOp
func (*LabelSelector) GetValue ¶
func (m *LabelSelector) GetValue() string
func (*LabelSelector) ProtoMessage ¶
func (*LabelSelector) ProtoMessage()
func (*LabelSelector) Reset ¶
func (m *LabelSelector) Reset()
func (*LabelSelector) String ¶
func (m *LabelSelector) String() string
func (*LabelSelector) XXX_DiscardUnknown ¶
func (m *LabelSelector) XXX_DiscardUnknown()
func (*LabelSelector) XXX_Marshal ¶
func (m *LabelSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LabelSelector) XXX_Merge ¶
func (m *LabelSelector) XXX_Merge(src proto.Message)
func (*LabelSelector) XXX_Size ¶
func (m *LabelSelector) XXX_Size() int
func (*LabelSelector) XXX_Unmarshal ¶
func (m *LabelSelector) XXX_Unmarshal(b []byte) error
type ListMetricsRequest ¶
type ListMetricsRequest struct { MetricType MetricType `` /* 148-byte string literal not displayed */ // Types that are valid to be assigned to TimeSelector: // *ListMetricsRequest_Time // *ListMetricsRequest_Duration // *ListMetricsRequest_TimeRange TimeSelector isListMetricsRequest_TimeSelector `protobuf_oneof:"time_selector"` Conditions []*LabelSelector `protobuf:"bytes,5,rep,name=conditions,proto3" json:"conditions,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a request for listing metric data with the logically combined (AND) conditions
func (*ListMetricsRequest) Descriptor ¶
func (*ListMetricsRequest) Descriptor() ([]byte, []int)
func (*ListMetricsRequest) GetConditions ¶
func (m *ListMetricsRequest) GetConditions() []*LabelSelector
func (*ListMetricsRequest) GetDuration ¶
func (m *ListMetricsRequest) GetDuration() *duration.Duration
func (*ListMetricsRequest) GetMetricType ¶
func (m *ListMetricsRequest) GetMetricType() MetricType
func (*ListMetricsRequest) GetTime ¶
func (m *ListMetricsRequest) GetTime() *timestamp.Timestamp
func (*ListMetricsRequest) GetTimeRange ¶
func (m *ListMetricsRequest) GetTimeRange() *TimeRange
func (*ListMetricsRequest) GetTimeSelector ¶
func (m *ListMetricsRequest) GetTimeSelector() isListMetricsRequest_TimeSelector
func (*ListMetricsRequest) ProtoMessage ¶
func (*ListMetricsRequest) ProtoMessage()
func (*ListMetricsRequest) Reset ¶
func (m *ListMetricsRequest) Reset()
func (*ListMetricsRequest) String ¶
func (m *ListMetricsRequest) String() string
func (*ListMetricsRequest) XXX_DiscardUnknown ¶
func (m *ListMetricsRequest) XXX_DiscardUnknown()
func (*ListMetricsRequest) XXX_Marshal ¶
func (m *ListMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMetricsRequest) XXX_Merge ¶
func (m *ListMetricsRequest) XXX_Merge(src proto.Message)
func (*ListMetricsRequest) XXX_OneofWrappers ¶
func (*ListMetricsRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ListMetricsRequest) XXX_Size ¶
func (m *ListMetricsRequest) XXX_Size() int
func (*ListMetricsRequest) XXX_Unmarshal ¶
func (m *ListMetricsRequest) XXX_Unmarshal(b []byte) error
type ListMetricsRequest_Time ¶
type ListMetricsRequest_TimeRange ¶
type ListMetricsRequest_TimeRange struct {
TimeRange *TimeRange `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3,oneof"`
}
type ListMetricsResponse ¶
type ListMetricsResponse struct { Metrics []*MetricResult `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"` Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a response of a list metric data request
func (*ListMetricsResponse) Descriptor ¶
func (*ListMetricsResponse) Descriptor() ([]byte, []int)
func (*ListMetricsResponse) GetMetrics ¶
func (m *ListMetricsResponse) GetMetrics() []*MetricResult
func (*ListMetricsResponse) GetStatus ¶
func (m *ListMetricsResponse) GetStatus() *status.Status
func (*ListMetricsResponse) ProtoMessage ¶
func (*ListMetricsResponse) ProtoMessage()
func (*ListMetricsResponse) Reset ¶
func (m *ListMetricsResponse) Reset()
func (*ListMetricsResponse) String ¶
func (m *ListMetricsResponse) String() string
func (*ListMetricsResponse) XXX_DiscardUnknown ¶
func (m *ListMetricsResponse) XXX_DiscardUnknown()
func (*ListMetricsResponse) XXX_Marshal ¶
func (m *ListMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMetricsResponse) XXX_Merge ¶
func (m *ListMetricsResponse) XXX_Merge(src proto.Message)
func (*ListMetricsResponse) XXX_Size ¶
func (m *ListMetricsResponse) XXX_Size() int
func (*ListMetricsResponse) XXX_Unmarshal ¶
func (m *ListMetricsResponse) XXX_Unmarshal(b []byte) error
type ListMetricsSumRequest ¶
type ListMetricsSumRequest struct { MetricType MetricType `` /* 148-byte string literal not displayed */ // Types that are valid to be assigned to TimeSelector: // *ListMetricsSumRequest_Time // *ListMetricsSumRequest_Duration // *ListMetricsSumRequest_TimeRange TimeSelector isListMetricsSumRequest_TimeSelector `protobuf_oneof:"time_selector"` Conditions []*LabelSelector `protobuf:"bytes,5,rep,name=conditions,proto3" json:"conditions,omitempty"` Labels []string `protobuf:"bytes,6,rep,name=labels,proto3" json:"labels,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a request for listing metric data summation by grouping labels.
func (*ListMetricsSumRequest) Descriptor ¶
func (*ListMetricsSumRequest) Descriptor() ([]byte, []int)
func (*ListMetricsSumRequest) GetConditions ¶
func (m *ListMetricsSumRequest) GetConditions() []*LabelSelector
func (*ListMetricsSumRequest) GetDuration ¶
func (m *ListMetricsSumRequest) GetDuration() *duration.Duration
func (*ListMetricsSumRequest) GetLabels ¶
func (m *ListMetricsSumRequest) GetLabels() []string
func (*ListMetricsSumRequest) GetMetricType ¶
func (m *ListMetricsSumRequest) GetMetricType() MetricType
func (*ListMetricsSumRequest) GetTime ¶
func (m *ListMetricsSumRequest) GetTime() *timestamp.Timestamp
func (*ListMetricsSumRequest) GetTimeRange ¶
func (m *ListMetricsSumRequest) GetTimeRange() *TimeRange
func (*ListMetricsSumRequest) GetTimeSelector ¶
func (m *ListMetricsSumRequest) GetTimeSelector() isListMetricsSumRequest_TimeSelector
func (*ListMetricsSumRequest) ProtoMessage ¶
func (*ListMetricsSumRequest) ProtoMessage()
func (*ListMetricsSumRequest) Reset ¶
func (m *ListMetricsSumRequest) Reset()
func (*ListMetricsSumRequest) String ¶
func (m *ListMetricsSumRequest) String() string
func (*ListMetricsSumRequest) XXX_DiscardUnknown ¶
func (m *ListMetricsSumRequest) XXX_DiscardUnknown()
func (*ListMetricsSumRequest) XXX_Marshal ¶
func (m *ListMetricsSumRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMetricsSumRequest) XXX_Merge ¶
func (m *ListMetricsSumRequest) XXX_Merge(src proto.Message)
func (*ListMetricsSumRequest) XXX_OneofWrappers ¶
func (*ListMetricsSumRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ListMetricsSumRequest) XXX_Size ¶
func (m *ListMetricsSumRequest) XXX_Size() int
func (*ListMetricsSumRequest) XXX_Unmarshal ¶
func (m *ListMetricsSumRequest) XXX_Unmarshal(b []byte) error
type ListMetricsSumRequest_TimeRange ¶
type ListMetricsSumRequest_TimeRange struct {
TimeRange *TimeRange `protobuf:"bytes,4,opt,name=time_range,json=timeRange,proto3,oneof"`
}
type ListMetricsSumResponse ¶
type ListMetricsSumResponse struct { Metrics []*MetricResult `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"` Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a response of a request for listing metric data summation by grouping labels
func (*ListMetricsSumResponse) Descriptor ¶
func (*ListMetricsSumResponse) Descriptor() ([]byte, []int)
func (*ListMetricsSumResponse) GetMetrics ¶
func (m *ListMetricsSumResponse) GetMetrics() []*MetricResult
func (*ListMetricsSumResponse) GetStatus ¶
func (m *ListMetricsSumResponse) GetStatus() *status.Status
func (*ListMetricsSumResponse) ProtoMessage ¶
func (*ListMetricsSumResponse) ProtoMessage()
func (*ListMetricsSumResponse) Reset ¶
func (m *ListMetricsSumResponse) Reset()
func (*ListMetricsSumResponse) String ¶
func (m *ListMetricsSumResponse) String() string
func (*ListMetricsSumResponse) XXX_DiscardUnknown ¶
func (m *ListMetricsSumResponse) XXX_DiscardUnknown()
func (*ListMetricsSumResponse) XXX_Marshal ¶
func (m *ListMetricsSumResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListMetricsSumResponse) XXX_Merge ¶
func (m *ListMetricsSumResponse) XXX_Merge(src proto.Message)
func (*ListMetricsSumResponse) XXX_Size ¶
func (m *ListMetricsSumResponse) XXX_Size() int
func (*ListMetricsSumResponse) XXX_Unmarshal ¶
func (m *ListMetricsSumResponse) XXX_Unmarshal(b []byte) error
type MetricResult ¶
type MetricResult struct { Labels map[string]string `` /* 153-byte string literal not displayed */ Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a data point of metric data
func (*MetricResult) Descriptor ¶
func (*MetricResult) Descriptor() ([]byte, []int)
func (*MetricResult) GetLabels ¶
func (m *MetricResult) GetLabels() map[string]string
func (*MetricResult) GetSamples ¶
func (m *MetricResult) GetSamples() []*Sample
func (*MetricResult) ProtoMessage ¶
func (*MetricResult) ProtoMessage()
func (*MetricResult) Reset ¶
func (m *MetricResult) Reset()
func (*MetricResult) String ¶
func (m *MetricResult) String() string
func (*MetricResult) XXX_DiscardUnknown ¶
func (m *MetricResult) XXX_DiscardUnknown()
func (*MetricResult) XXX_Marshal ¶
func (m *MetricResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MetricResult) XXX_Merge ¶
func (m *MetricResult) XXX_Merge(src proto.Message)
func (*MetricResult) XXX_Size ¶
func (m *MetricResult) XXX_Size() int
func (*MetricResult) XXX_Unmarshal ¶
func (m *MetricResult) XXX_Unmarshal(b []byte) error
type MetricType ¶
type MetricType int32
* Metric type
const ( MetricType_CONTAINER_CPU_USAGE_TOTAL MetricType = 0 MetricType_CONTAINER_CPU_USAGE_TOTAL_RATE MetricType = 1 MetricType_CONTAINER_MEMORY_USAGE MetricType = 2 MetricType_NODE_CPU_USAGE_SECONDS_AVG1M MetricType = 3 MetricType_NODE_MEMORY_USAGE_BYTES MetricType = 4 )
func (MetricType) EnumDescriptor ¶
func (MetricType) EnumDescriptor() ([]byte, []int)
func (MetricType) String ¶
func (x MetricType) String() string
type OperatorServiceClient ¶
type OperatorServiceClient interface { /// Used to list metric data ListMetrics(ctx context.Context, in *ListMetricsRequest, opts ...grpc.CallOption) (*ListMetricsResponse, error) /// Used to list summation of metric data ListMetricsSum(ctx context.Context, in *ListMetricsSumRequest, opts ...grpc.CallOption) (*ListMetricsSumResponse, error) /// Used to requst for creating prediction results CreatePredictResult(ctx context.Context, in *CreatePredictResultRequest, opts ...grpc.CallOption) (*CreatePredictResultResponse, error) /// Used to get resource data GetResourceInfo(ctx context.Context, in *GetResourceInfoRequest, opts ...grpc.CallOption) (*GetResourceInfoResponse, error) /// Used to get resource recommendation GetResourceRecommendation(ctx context.Context, in *GetResourceRecommendationRequest, opts ...grpc.CallOption) (*GetResourceRecommendationResponse, error) }
OperatorServiceClient is the client API for OperatorService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOperatorServiceClient ¶
func NewOperatorServiceClient(cc grpc.ClientConnInterface) OperatorServiceClient
type OperatorServiceServer ¶
type OperatorServiceServer interface { /// Used to list metric data ListMetrics(context.Context, *ListMetricsRequest) (*ListMetricsResponse, error) /// Used to list summation of metric data ListMetricsSum(context.Context, *ListMetricsSumRequest) (*ListMetricsSumResponse, error) /// Used to requst for creating prediction results CreatePredictResult(context.Context, *CreatePredictResultRequest) (*CreatePredictResultResponse, error) /// Used to get resource data GetResourceInfo(context.Context, *GetResourceInfoRequest) (*GetResourceInfoResponse, error) /// Used to get resource recommendation GetResourceRecommendation(context.Context, *GetResourceRecommendationRequest) (*GetResourceRecommendationResponse, error) }
OperatorServiceServer is the server API for OperatorService service.
type PodInfo ¶
type PodInfo struct { Containers []*Container `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents containers of a pod
func (*PodInfo) Descriptor ¶
func (*PodInfo) GetContainers ¶
func (*PodInfo) ProtoMessage ¶
func (*PodInfo) ProtoMessage()
func (*PodInfo) XXX_DiscardUnknown ¶
func (m *PodInfo) XXX_DiscardUnknown()
func (*PodInfo) XXX_Marshal ¶
func (*PodInfo) XXX_Unmarshal ¶
type PredictContainer ¶
type PredictContainer struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` RawPredictData map[string]*TimeSeriesData `` /* 193-byte string literal not displayed */ Recommendations []*Recommendation `protobuf:"bytes,3,rep,name=recommendations,proto3" json:"recommendations,omitempty"` InitialResource *Resource `protobuf:"bytes,4,opt,name=initial_resource,json=initialResource,proto3" json:"initial_resource,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents predictions and recommendations for a container
func (*PredictContainer) Descriptor ¶
func (*PredictContainer) Descriptor() ([]byte, []int)
func (*PredictContainer) GetInitialResource ¶
func (m *PredictContainer) GetInitialResource() *Resource
func (*PredictContainer) GetName ¶
func (m *PredictContainer) GetName() string
func (*PredictContainer) GetRawPredictData ¶
func (m *PredictContainer) GetRawPredictData() map[string]*TimeSeriesData
func (*PredictContainer) GetRecommendations ¶
func (m *PredictContainer) GetRecommendations() []*Recommendation
func (*PredictContainer) ProtoMessage ¶
func (*PredictContainer) ProtoMessage()
func (*PredictContainer) Reset ¶
func (m *PredictContainer) Reset()
func (*PredictContainer) String ¶
func (m *PredictContainer) String() string
func (*PredictContainer) XXX_DiscardUnknown ¶
func (m *PredictContainer) XXX_DiscardUnknown()
func (*PredictContainer) XXX_Marshal ¶
func (m *PredictContainer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PredictContainer) XXX_Merge ¶
func (m *PredictContainer) XXX_Merge(src proto.Message)
func (*PredictContainer) XXX_Size ¶
func (m *PredictContainer) XXX_Size() int
func (*PredictContainer) XXX_Unmarshal ¶
func (m *PredictContainer) XXX_Unmarshal(b []byte) error
type PredictData ¶
type PredictData struct { Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a predicted value
func (*PredictData) Descriptor ¶
func (*PredictData) Descriptor() ([]byte, []int)
func (*PredictData) GetTime ¶
func (m *PredictData) GetTime() *timestamp.Timestamp
func (*PredictData) GetValue ¶
func (m *PredictData) GetValue() string
func (*PredictData) ProtoMessage ¶
func (*PredictData) ProtoMessage()
func (*PredictData) Reset ¶
func (m *PredictData) Reset()
func (*PredictData) String ¶
func (m *PredictData) String() string
func (*PredictData) XXX_DiscardUnknown ¶
func (m *PredictData) XXX_DiscardUnknown()
func (*PredictData) XXX_Marshal ¶
func (m *PredictData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PredictData) XXX_Merge ¶
func (m *PredictData) XXX_Merge(src proto.Message)
func (*PredictData) XXX_Size ¶
func (m *PredictData) XXX_Size() int
func (*PredictData) XXX_Unmarshal ¶
func (m *PredictData) XXX_Unmarshal(b []byte) error
type PredictPod ¶
type PredictPod struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` PredictContainers []*PredictContainer `protobuf:"bytes,4,rep,name=predict_containers,json=predictContainers,proto3" json:"predict_containers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents predictions and recommendations of a pod
func (*PredictPod) Descriptor ¶
func (*PredictPod) Descriptor() ([]byte, []int)
func (*PredictPod) GetName ¶
func (m *PredictPod) GetName() string
func (*PredictPod) GetNamespace ¶
func (m *PredictPod) GetNamespace() string
func (*PredictPod) GetPredictContainers ¶
func (m *PredictPod) GetPredictContainers() []*PredictContainer
func (*PredictPod) GetUid ¶
func (m *PredictPod) GetUid() string
func (*PredictPod) ProtoMessage ¶
func (*PredictPod) ProtoMessage()
func (*PredictPod) Reset ¶
func (m *PredictPod) Reset()
func (*PredictPod) String ¶
func (m *PredictPod) String() string
func (*PredictPod) XXX_DiscardUnknown ¶
func (m *PredictPod) XXX_DiscardUnknown()
func (*PredictPod) XXX_Marshal ¶
func (m *PredictPod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PredictPod) XXX_Merge ¶
func (m *PredictPod) XXX_Merge(src proto.Message)
func (*PredictPod) XXX_Size ¶
func (m *PredictPod) XXX_Size() int
func (*PredictPod) XXX_Unmarshal ¶
func (m *PredictPod) XXX_Unmarshal(b []byte) error
type Recommendation ¶
type Recommendation struct { Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` Resource *Resource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a resource configuration recommenation
func (*Recommendation) Descriptor ¶
func (*Recommendation) Descriptor() ([]byte, []int)
func (*Recommendation) GetResource ¶
func (m *Recommendation) GetResource() *Resource
func (*Recommendation) GetTime ¶
func (m *Recommendation) GetTime() *timestamp.Timestamp
func (*Recommendation) ProtoMessage ¶
func (*Recommendation) ProtoMessage()
func (*Recommendation) Reset ¶
func (m *Recommendation) Reset()
func (*Recommendation) String ¶
func (m *Recommendation) String() string
func (*Recommendation) XXX_DiscardUnknown ¶
func (m *Recommendation) XXX_DiscardUnknown()
func (*Recommendation) XXX_Marshal ¶
func (m *Recommendation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Recommendation) XXX_Merge ¶
func (m *Recommendation) XXX_Merge(src proto.Message)
func (*Recommendation) XXX_Size ¶
func (m *Recommendation) XXX_Size() int
func (*Recommendation) XXX_Unmarshal ¶
func (m *Recommendation) XXX_Unmarshal(b []byte) error
type Resource ¶
type Resource struct { Limit map[string]string `` /* 151-byte string literal not displayed */ Request map[string]string `` /* 155-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a resource configuration including limits and requests
func (*Resource) Descriptor ¶
func (*Resource) GetRequest ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) XXX_DiscardUnknown ¶
func (m *Resource) XXX_DiscardUnknown()
func (*Resource) XXX_Marshal ¶
func (*Resource) XXX_Unmarshal ¶
type ResourceType ¶
type ResourceType int32
* Resource type.
const (
ResourceType_POD ResourceType = 0
)
func (ResourceType) EnumDescriptor ¶
func (ResourceType) EnumDescriptor() ([]byte, []int)
func (ResourceType) String ¶
func (x ResourceType) String() string
type Sample ¶
type Sample struct { Time *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a data point of time-series metric data
func (*Sample) Descriptor ¶
func (*Sample) ProtoMessage ¶
func (*Sample) ProtoMessage()
func (*Sample) XXX_DiscardUnknown ¶
func (m *Sample) XXX_DiscardUnknown()
func (*Sample) XXX_Marshal ¶
func (*Sample) XXX_Unmarshal ¶
type TimeRange ¶
type TimeRange struct { StartTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` EndTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Step *duration.Duration `protobuf:"bytes,3,opt,name=step,proto3" json:"step,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a time range definition
func (*TimeRange) Descriptor ¶
func (*TimeRange) GetEndTime ¶
func (*TimeRange) GetStartTime ¶
func (*TimeRange) ProtoMessage ¶
func (*TimeRange) ProtoMessage()
func (*TimeRange) XXX_DiscardUnknown ¶
func (m *TimeRange) XXX_DiscardUnknown()
func (*TimeRange) XXX_Marshal ¶
func (*TimeRange) XXX_Unmarshal ¶
type TimeSeriesData ¶
type TimeSeriesData struct { PredictData []*PredictData `protobuf:"bytes,1,rep,name=predict_data,json=predictData,proto3" json:"predict_data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
* Represents a predicted value of time-series data
func (*TimeSeriesData) Descriptor ¶
func (*TimeSeriesData) Descriptor() ([]byte, []int)
func (*TimeSeriesData) GetPredictData ¶
func (m *TimeSeriesData) GetPredictData() []*PredictData
func (*TimeSeriesData) ProtoMessage ¶
func (*TimeSeriesData) ProtoMessage()
func (*TimeSeriesData) Reset ¶
func (m *TimeSeriesData) Reset()
func (*TimeSeriesData) String ¶
func (m *TimeSeriesData) String() string
func (*TimeSeriesData) XXX_DiscardUnknown ¶
func (m *TimeSeriesData) XXX_DiscardUnknown()
func (*TimeSeriesData) XXX_Marshal ¶
func (m *TimeSeriesData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TimeSeriesData) XXX_Merge ¶
func (m *TimeSeriesData) XXX_Merge(src proto.Message)
func (*TimeSeriesData) XXX_Size ¶
func (m *TimeSeriesData) XXX_Size() int
func (*TimeSeriesData) XXX_Unmarshal ¶
func (m *TimeSeriesData) XXX_Unmarshal(b []byte) error
type UnimplementedOperatorServiceServer ¶
type UnimplementedOperatorServiceServer struct { }
UnimplementedOperatorServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedOperatorServiceServer) CreatePredictResult ¶
func (*UnimplementedOperatorServiceServer) CreatePredictResult(ctx context.Context, req *CreatePredictResultRequest) (*CreatePredictResultResponse, error)
func (*UnimplementedOperatorServiceServer) GetResourceInfo ¶
func (*UnimplementedOperatorServiceServer) GetResourceInfo(ctx context.Context, req *GetResourceInfoRequest) (*GetResourceInfoResponse, error)
func (*UnimplementedOperatorServiceServer) GetResourceRecommendation ¶
func (*UnimplementedOperatorServiceServer) GetResourceRecommendation(ctx context.Context, req *GetResourceRecommendationRequest) (*GetResourceRecommendationResponse, error)
func (*UnimplementedOperatorServiceServer) ListMetrics ¶
func (*UnimplementedOperatorServiceServer) ListMetrics(ctx context.Context, req *ListMetricsRequest) (*ListMetricsResponse, error)
func (*UnimplementedOperatorServiceServer) ListMetricsSum ¶
func (*UnimplementedOperatorServiceServer) ListMetricsSum(ctx context.Context, req *ListMetricsSumRequest) (*ListMetricsSumResponse, error)