containers_ai_alameda_v1alpha1_operator

package
v4.2.789+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 7, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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",
}
View Source
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,
}
View Source
var ResourceType_name = map[int32]string{
	0: "POD",
}
View Source
var ResourceType_value = map[string]int32{
	"POD": 0,
}
View Source
var StrOp_name = map[int32]string{
	0: "EQUAL",
	1: "NOT_EQUAL",
}
View Source
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) Descriptor() ([]byte, []int)

func (*Container) GetInitialResource

func (m *Container) GetInitialResource() *Resource

func (*Container) GetName

func (m *Container) GetName() string

func (*Container) GetResource

func (m *Container) GetResource() *Resource

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) Reset

func (m *Container) Reset()

func (*Container) String

func (m *Container) String() string

func (*Container) XXX_DiscardUnknown

func (m *Container) XXX_DiscardUnknown()

func (*Container) XXX_Marshal

func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Container) XXX_Merge

func (m *Container) XXX_Merge(src proto.Message)

func (*Container) XXX_Size

func (m *Container) XXX_Size() int

func (*Container) XXX_Unmarshal

func (m *Container) XXX_Unmarshal(b []byte) error

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 (*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 (*GetResourceRecommendationRequest) GetNamespace

func (m *GetResourceRecommendationRequest) GetNamespace() string

func (*GetResourceRecommendationRequest) GetType

func (*GetResourceRecommendationRequest) ProtoMessage

func (*GetResourceRecommendationRequest) ProtoMessage()

func (*GetResourceRecommendationRequest) Reset

func (*GetResourceRecommendationRequest) 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 (*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 (*GetResourceRecommendationResponse) GetNamespace

func (m *GetResourceRecommendationResponse) GetNamespace() string

func (*GetResourceRecommendationResponse) GetPodInfo

func (m *GetResourceRecommendationResponse) GetPodInfo() *PodInfo

func (*GetResourceRecommendationResponse) GetStatus

func (*GetResourceRecommendationResponse) GetType

func (*GetResourceRecommendationResponse) GetUid

func (*GetResourceRecommendationResponse) ProtoMessage

func (*GetResourceRecommendationResponse) ProtoMessage()

func (*GetResourceRecommendationResponse) Reset

func (*GetResourceRecommendationResponse) 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 (*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_Duration

type ListMetricsRequest_Duration struct {
	Duration *duration.Duration `protobuf:"bytes,3,opt,name=duration,proto3,oneof"`
}

type ListMetricsRequest_Time

type ListMetricsRequest_Time struct {
	Time *timestamp.Timestamp `protobuf:"bytes,2,opt,name=time,proto3,oneof"`
}

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 (*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_Duration

type ListMetricsSumRequest_Duration struct {
	Duration *duration.Duration `protobuf:"bytes,3,opt,name=duration,proto3,oneof"`
}

type ListMetricsSumRequest_Time

type ListMetricsSumRequest_Time struct {
	Time *timestamp.Timestamp `protobuf:"bytes,2,opt,name=time,proto3,oneof"`
}

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.

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) Descriptor() ([]byte, []int)

func (*PodInfo) GetContainers

func (m *PodInfo) GetContainers() []*Container

func (*PodInfo) ProtoMessage

func (*PodInfo) ProtoMessage()

func (*PodInfo) Reset

func (m *PodInfo) Reset()

func (*PodInfo) String

func (m *PodInfo) String() string

func (*PodInfo) XXX_DiscardUnknown

func (m *PodInfo) XXX_DiscardUnknown()

func (*PodInfo) XXX_Marshal

func (m *PodInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PodInfo) XXX_Merge

func (m *PodInfo) XXX_Merge(src proto.Message)

func (*PodInfo) XXX_Size

func (m *PodInfo) XXX_Size() int

func (*PodInfo) XXX_Unmarshal

func (m *PodInfo) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Resource) GetLimit

func (m *Resource) GetLimit() map[string]string

func (*Resource) GetRequest

func (m *Resource) GetRequest() map[string]string

func (*Resource) ProtoMessage

func (*Resource) ProtoMessage()

func (*Resource) Reset

func (m *Resource) Reset()

func (*Resource) String

func (m *Resource) String() string

func (*Resource) XXX_DiscardUnknown

func (m *Resource) XXX_DiscardUnknown()

func (*Resource) XXX_Marshal

func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Resource) XXX_Merge

func (m *Resource) XXX_Merge(src proto.Message)

func (*Resource) XXX_Size

func (m *Resource) XXX_Size() int

func (*Resource) XXX_Unmarshal

func (m *Resource) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*Sample) GetTime

func (m *Sample) GetTime() *timestamp.Timestamp

func (*Sample) GetValue

func (m *Sample) GetValue() float64

func (*Sample) ProtoMessage

func (*Sample) ProtoMessage()

func (*Sample) Reset

func (m *Sample) Reset()

func (*Sample) String

func (m *Sample) String() string

func (*Sample) XXX_DiscardUnknown

func (m *Sample) XXX_DiscardUnknown()

func (*Sample) XXX_Marshal

func (m *Sample) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sample) XXX_Merge

func (m *Sample) XXX_Merge(src proto.Message)

func (*Sample) XXX_Size

func (m *Sample) XXX_Size() int

func (*Sample) XXX_Unmarshal

func (m *Sample) XXX_Unmarshal(b []byte) error

type StrOp

type StrOp int32
const (
	StrOp_EQUAL     StrOp = 0
	StrOp_NOT_EQUAL StrOp = 1
)

func (StrOp) EnumDescriptor

func (StrOp) EnumDescriptor() ([]byte, []int)

func (StrOp) String

func (x StrOp) String() string

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) Descriptor() ([]byte, []int)

func (*TimeRange) GetEndTime

func (m *TimeRange) GetEndTime() *timestamp.Timestamp

func (*TimeRange) GetStartTime

func (m *TimeRange) GetStartTime() *timestamp.Timestamp

func (*TimeRange) GetStep

func (m *TimeRange) GetStep() *duration.Duration

func (*TimeRange) ProtoMessage

func (*TimeRange) ProtoMessage()

func (*TimeRange) Reset

func (m *TimeRange) Reset()

func (*TimeRange) String

func (m *TimeRange) String() string

func (*TimeRange) XXX_DiscardUnknown

func (m *TimeRange) XXX_DiscardUnknown()

func (*TimeRange) XXX_Marshal

func (m *TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeRange) XXX_Merge

func (m *TimeRange) XXX_Merge(src proto.Message)

func (*TimeRange) XXX_Size

func (m *TimeRange) XXX_Size() int

func (*TimeRange) XXX_Unmarshal

func (m *TimeRange) XXX_Unmarshal(b []byte) error

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) GetResourceInfo

func (*UnimplementedOperatorServiceServer) GetResourceRecommendation

func (*UnimplementedOperatorServiceServer) ListMetrics

func (*UnimplementedOperatorServiceServer) ListMetricsSum

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL