Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterProviderServiceServer(s grpc.ServiceRegistrar, srv ProviderServiceServer)
- type ContainerResourceQuery
- func (*ContainerResourceQuery) Descriptor() ([]byte, []int)deprecated
- func (x *ContainerResourceQuery) GetContainerName() string
- func (x *ContainerResourceQuery) GetName() string
- func (x *ContainerResourceQuery) GetNamespace() string
- func (m *ContainerResourceQuery) GetPodIdentifier() isContainerResourceQuery_PodIdentifier
- func (x *ContainerResourceQuery) GetResourceName() string
- func (x *ContainerResourceQuery) GetSelector() string
- func (*ContainerResourceQuery) ProtoMessage()
- func (x *ContainerResourceQuery) ProtoReflect() protoreflect.Message
- func (x *ContainerResourceQuery) Reset()
- func (x *ContainerResourceQuery) String() string
- type ContainerResourceQuery_Name
- type ContainerResourceQuery_Selector
- type ExternalQuery
- func (*ExternalQuery) Descriptor() ([]byte, []int)deprecated
- func (x *ExternalQuery) GetMetric() *MetricIdentifier
- func (x *ExternalQuery) GetNamespace() string
- func (*ExternalQuery) ProtoMessage()
- func (x *ExternalQuery) ProtoReflect() protoreflect.Message
- func (x *ExternalQuery) Reset()
- func (x *ExternalQuery) String() string
- type GroupKind
- type MetricIdentifier
- func (*MetricIdentifier) Descriptor() ([]byte, []int)deprecated
- func (x *MetricIdentifier) GetName() string
- func (x *MetricIdentifier) GetSelector() string
- func (*MetricIdentifier) ProtoMessage()
- func (x *MetricIdentifier) ProtoReflect() protoreflect.Message
- func (x *MetricIdentifier) Reset()
- func (x *MetricIdentifier) String() string
- type ObjectQuery
- func (*ObjectQuery) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectQuery) GetGroupKind() *GroupKind
- func (x *ObjectQuery) GetMetric() *MetricIdentifier
- func (x *ObjectQuery) GetName() string
- func (x *ObjectQuery) GetNamespace() string
- func (m *ObjectQuery) GetObjectIdentifier() isObjectQuery_ObjectIdentifier
- func (x *ObjectQuery) GetSelector() string
- func (*ObjectQuery) ProtoMessage()
- func (x *ObjectQuery) ProtoReflect() protoreflect.Message
- func (x *ObjectQuery) Reset()
- func (x *ObjectQuery) String() string
- type ObjectQuery_Name
- type ObjectQuery_Selector
- type PodResourceQuery
- func (*PodResourceQuery) Descriptor() ([]byte, []int)deprecated
- func (x *PodResourceQuery) GetName() string
- func (x *PodResourceQuery) GetNamespace() string
- func (m *PodResourceQuery) GetPodIdentifier() isPodResourceQuery_PodIdentifier
- func (x *PodResourceQuery) GetResourceName() string
- func (x *PodResourceQuery) GetSelector() string
- func (*PodResourceQuery) ProtoMessage()
- func (x *PodResourceQuery) ProtoReflect() protoreflect.Message
- func (x *PodResourceQuery) Reset()
- func (x *PodResourceQuery) String() string
- type PodResourceQuery_Name
- type PodResourceQuery_Selector
- type Point
- type ProviderServiceClient
- type ProviderServiceServer
- type Query
- func (*Query) Descriptor() ([]byte, []int)deprecated
- func (x *Query) GetContainerResource() *ContainerResourceQuery
- func (x *Query) GetExternal() *ExternalQuery
- func (x *Query) GetObject() *ObjectQuery
- func (x *Query) GetPodResource() *PodResourceQuery
- func (m *Query) GetQuery() isQuery_Query
- func (x *Query) GetType() QueryType
- func (x *Query) GetWorkloadContainerResource() *WorkloadContainerResourceQuery
- func (x *Query) GetWorkloadExternal() *WorkloadExternalQuery
- func (x *Query) GetWorkloadResource() *WorkloadResourceQuery
- func (*Query) ProtoMessage()
- func (x *Query) ProtoReflect() protoreflect.Message
- func (x *Query) Reset()
- func (x *Query) String() string
- type QueryLatestRequest
- func (*QueryLatestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryLatestRequest) GetQuery() *Query
- func (*QueryLatestRequest) ProtoMessage()
- func (x *QueryLatestRequest) ProtoReflect() protoreflect.Message
- func (x *QueryLatestRequest) Reset()
- func (x *QueryLatestRequest) String() string
- type QueryLatestResponse
- func (*QueryLatestResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryLatestResponse) GetSamples() []*Sample
- func (*QueryLatestResponse) ProtoMessage()
- func (x *QueryLatestResponse) ProtoReflect() protoreflect.Message
- func (x *QueryLatestResponse) Reset()
- func (x *QueryLatestResponse) String() string
- type QueryRequest
- func (*QueryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRequest) GetEnd() *timestamppb.Timestamp
- func (x *QueryRequest) GetQuery() *Query
- func (x *QueryRequest) GetStart() *timestamppb.Timestamp
- func (x *QueryRequest) GetStep() *durationpb.Duration
- func (*QueryRequest) ProtoMessage()
- func (x *QueryRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRequest) Reset()
- func (x *QueryRequest) String() string
- type QueryResponse
- type QueryType
- type Query_ContainerResource
- type Query_External
- type Query_Object
- type Query_PodResource
- type Query_WorkloadContainerResource
- type Query_WorkloadExternal
- type Query_WorkloadResource
- type Sample
- func (*Sample) Descriptor() ([]byte, []int)deprecated
- func (x *Sample) GetLabels() map[string]string
- func (x *Sample) GetPoint() *Point
- func (x *Sample) GetWindow() *durationpb.Duration
- func (*Sample) ProtoMessage()
- func (x *Sample) ProtoReflect() protoreflect.Message
- func (x *Sample) Reset()
- func (x *Sample) String() string
- type Series
- func (*Series) Descriptor() ([]byte, []int)deprecated
- func (x *Series) GetLabels() map[string]string
- func (x *Series) GetPoints() []*Point
- func (x *Series) GetWindow() *durationpb.Duration
- func (*Series) ProtoMessage()
- func (x *Series) ProtoReflect() protoreflect.Message
- func (x *Series) Reset()
- func (x *Series) String() string
- type UnimplementedProviderServiceServer
- type UnsafeProviderServiceServer
- type WorkloadContainerResourceQuery
- func (*WorkloadContainerResourceQuery) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadContainerResourceQuery) GetContainerName() string
- func (x *WorkloadContainerResourceQuery) GetGroupKind() *GroupKind
- func (x *WorkloadContainerResourceQuery) GetName() string
- func (x *WorkloadContainerResourceQuery) GetNamespace() string
- func (x *WorkloadContainerResourceQuery) GetReadyPodsOnly() bool
- func (x *WorkloadContainerResourceQuery) GetResourceName() string
- func (*WorkloadContainerResourceQuery) ProtoMessage()
- func (x *WorkloadContainerResourceQuery) ProtoReflect() protoreflect.Message
- func (x *WorkloadContainerResourceQuery) Reset()
- func (x *WorkloadContainerResourceQuery) String() string
- type WorkloadExternalQuery
- func (*WorkloadExternalQuery) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadExternalQuery) GetGroupKind() *GroupKind
- func (x *WorkloadExternalQuery) GetMetric() *MetricIdentifier
- func (x *WorkloadExternalQuery) GetName() string
- func (x *WorkloadExternalQuery) GetNamespace() string
- func (*WorkloadExternalQuery) ProtoMessage()
- func (x *WorkloadExternalQuery) ProtoReflect() protoreflect.Message
- func (x *WorkloadExternalQuery) Reset()
- func (x *WorkloadExternalQuery) String() string
- type WorkloadResourceQuery
- func (*WorkloadResourceQuery) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadResourceQuery) GetGroupKind() *GroupKind
- func (x *WorkloadResourceQuery) GetName() string
- func (x *WorkloadResourceQuery) GetNamespace() string
- func (x *WorkloadResourceQuery) GetReadyPodsOnly() bool
- func (x *WorkloadResourceQuery) GetResourceName() string
- func (*WorkloadResourceQuery) ProtoMessage()
- func (x *WorkloadResourceQuery) ProtoReflect() protoreflect.Message
- func (x *WorkloadResourceQuery) Reset()
- func (x *WorkloadResourceQuery) String() string
Constants ¶
const ( ProviderService_QueryLatest_FullMethodName = "/io.kapacitystack.metric.ProviderService/QueryLatest" ProviderService_Query_FullMethodName = "/io.kapacitystack.metric.ProviderService/Query" )
Variables ¶
var ( QueryType_name = map[int32]string{ 0: "POD_RESOURCE", 1: "CONTAINER_RESOURCE", 2: "WORKLOAD_RESOURCE", 3: "WORKLOAD_CONTAINER_RESOURCE", 4: "OBJECT", 5: "EXTERNAL", 6: "WORKLOAD_EXTERNAL", } QueryType_value = map[string]int32{ "POD_RESOURCE": 0, "CONTAINER_RESOURCE": 1, "WORKLOAD_RESOURCE": 2, "WORKLOAD_CONTAINER_RESOURCE": 3, "OBJECT": 4, "EXTERNAL": 5, "WORKLOAD_EXTERNAL": 6, } )
Enum value maps for QueryType.
var File_metric_proto protoreflect.FileDescriptor
var File_provider_proto protoreflect.FileDescriptor
var ProviderService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "io.kapacitystack.metric.ProviderService", HandlerType: (*ProviderServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "QueryLatest", Handler: _ProviderService_QueryLatest_Handler, }, { MethodName: "Query", Handler: _ProviderService_Query_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "provider.proto", }
ProviderService_ServiceDesc is the grpc.ServiceDesc for ProviderService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterProviderServiceServer ¶
func RegisterProviderServiceServer(s grpc.ServiceRegistrar, srv ProviderServiceServer)
Types ¶
type ContainerResourceQuery ¶
type ContainerResourceQuery struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // Types that are assignable to PodIdentifier: // // *ContainerResourceQuery_Name // *ContainerResourceQuery_Selector PodIdentifier isContainerResourceQuery_PodIdentifier `protobuf_oneof:"pod_identifier"` ResourceName string `protobuf:"bytes,4,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"` ContainerName string `protobuf:"bytes,5,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"` // contains filtered or unexported fields }
func (*ContainerResourceQuery) Descriptor
deprecated
func (*ContainerResourceQuery) Descriptor() ([]byte, []int)
Deprecated: Use ContainerResourceQuery.ProtoReflect.Descriptor instead.
func (*ContainerResourceQuery) GetContainerName ¶
func (x *ContainerResourceQuery) GetContainerName() string
func (*ContainerResourceQuery) GetName ¶
func (x *ContainerResourceQuery) GetName() string
func (*ContainerResourceQuery) GetNamespace ¶
func (x *ContainerResourceQuery) GetNamespace() string
func (*ContainerResourceQuery) GetPodIdentifier ¶
func (m *ContainerResourceQuery) GetPodIdentifier() isContainerResourceQuery_PodIdentifier
func (*ContainerResourceQuery) GetResourceName ¶
func (x *ContainerResourceQuery) GetResourceName() string
func (*ContainerResourceQuery) GetSelector ¶
func (x *ContainerResourceQuery) GetSelector() string
func (*ContainerResourceQuery) ProtoMessage ¶
func (*ContainerResourceQuery) ProtoMessage()
func (*ContainerResourceQuery) ProtoReflect ¶
func (x *ContainerResourceQuery) ProtoReflect() protoreflect.Message
func (*ContainerResourceQuery) Reset ¶
func (x *ContainerResourceQuery) Reset()
func (*ContainerResourceQuery) String ¶
func (x *ContainerResourceQuery) String() string
type ContainerResourceQuery_Name ¶
type ContainerResourceQuery_Name struct {
Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}
type ContainerResourceQuery_Selector ¶
type ContainerResourceQuery_Selector struct {
Selector string `protobuf:"bytes,3,opt,name=selector,proto3,oneof"`
}
type ExternalQuery ¶
type ExternalQuery struct { Namespace *string `protobuf:"bytes,1,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` Metric *MetricIdentifier `protobuf:"bytes,2,opt,name=metric,proto3" json:"metric,omitempty"` // contains filtered or unexported fields }
func (*ExternalQuery) Descriptor
deprecated
func (*ExternalQuery) Descriptor() ([]byte, []int)
Deprecated: Use ExternalQuery.ProtoReflect.Descriptor instead.
func (*ExternalQuery) GetMetric ¶
func (x *ExternalQuery) GetMetric() *MetricIdentifier
func (*ExternalQuery) GetNamespace ¶
func (x *ExternalQuery) GetNamespace() string
func (*ExternalQuery) ProtoMessage ¶
func (*ExternalQuery) ProtoMessage()
func (*ExternalQuery) ProtoReflect ¶
func (x *ExternalQuery) ProtoReflect() protoreflect.Message
func (*ExternalQuery) Reset ¶
func (x *ExternalQuery) Reset()
func (*ExternalQuery) String ¶
func (x *ExternalQuery) String() string
type GroupKind ¶
type GroupKind struct { Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"` Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` // contains filtered or unexported fields }
func (*GroupKind) Descriptor
deprecated
func (*GroupKind) ProtoMessage ¶
func (*GroupKind) ProtoMessage()
func (*GroupKind) ProtoReflect ¶
func (x *GroupKind) ProtoReflect() protoreflect.Message
type MetricIdentifier ¶
type MetricIdentifier struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Selector *string `protobuf:"bytes,2,opt,name=selector,proto3,oneof" json:"selector,omitempty"` // contains filtered or unexported fields }
func (*MetricIdentifier) Descriptor
deprecated
func (*MetricIdentifier) Descriptor() ([]byte, []int)
Deprecated: Use MetricIdentifier.ProtoReflect.Descriptor instead.
func (*MetricIdentifier) GetName ¶
func (x *MetricIdentifier) GetName() string
func (*MetricIdentifier) GetSelector ¶
func (x *MetricIdentifier) GetSelector() string
func (*MetricIdentifier) ProtoMessage ¶
func (*MetricIdentifier) ProtoMessage()
func (*MetricIdentifier) ProtoReflect ¶
func (x *MetricIdentifier) ProtoReflect() protoreflect.Message
func (*MetricIdentifier) Reset ¶
func (x *MetricIdentifier) Reset()
func (*MetricIdentifier) String ¶
func (x *MetricIdentifier) String() string
type ObjectQuery ¶
type ObjectQuery struct { GroupKind *GroupKind `protobuf:"bytes,1,opt,name=group_kind,json=groupKind,proto3" json:"group_kind,omitempty"` Namespace *string `protobuf:"bytes,2,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` // Types that are assignable to ObjectIdentifier: // // *ObjectQuery_Name // *ObjectQuery_Selector ObjectIdentifier isObjectQuery_ObjectIdentifier `protobuf_oneof:"object_identifier"` Metric *MetricIdentifier `protobuf:"bytes,5,opt,name=metric,proto3" json:"metric,omitempty"` // contains filtered or unexported fields }
func (*ObjectQuery) Descriptor
deprecated
func (*ObjectQuery) Descriptor() ([]byte, []int)
Deprecated: Use ObjectQuery.ProtoReflect.Descriptor instead.
func (*ObjectQuery) GetGroupKind ¶
func (x *ObjectQuery) GetGroupKind() *GroupKind
func (*ObjectQuery) GetMetric ¶
func (x *ObjectQuery) GetMetric() *MetricIdentifier
func (*ObjectQuery) GetName ¶
func (x *ObjectQuery) GetName() string
func (*ObjectQuery) GetNamespace ¶
func (x *ObjectQuery) GetNamespace() string
func (*ObjectQuery) GetObjectIdentifier ¶
func (m *ObjectQuery) GetObjectIdentifier() isObjectQuery_ObjectIdentifier
func (*ObjectQuery) GetSelector ¶
func (x *ObjectQuery) GetSelector() string
func (*ObjectQuery) ProtoMessage ¶
func (*ObjectQuery) ProtoMessage()
func (*ObjectQuery) ProtoReflect ¶
func (x *ObjectQuery) ProtoReflect() protoreflect.Message
func (*ObjectQuery) Reset ¶
func (x *ObjectQuery) Reset()
func (*ObjectQuery) String ¶
func (x *ObjectQuery) String() string
type ObjectQuery_Name ¶
type ObjectQuery_Name struct {
Name string `protobuf:"bytes,3,opt,name=name,proto3,oneof"`
}
type ObjectQuery_Selector ¶
type ObjectQuery_Selector struct {
Selector string `protobuf:"bytes,4,opt,name=selector,proto3,oneof"`
}
type PodResourceQuery ¶
type PodResourceQuery struct { Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // Types that are assignable to PodIdentifier: // // *PodResourceQuery_Name // *PodResourceQuery_Selector PodIdentifier isPodResourceQuery_PodIdentifier `protobuf_oneof:"pod_identifier"` ResourceName string `protobuf:"bytes,4,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"` // contains filtered or unexported fields }
func (*PodResourceQuery) Descriptor
deprecated
func (*PodResourceQuery) Descriptor() ([]byte, []int)
Deprecated: Use PodResourceQuery.ProtoReflect.Descriptor instead.
func (*PodResourceQuery) GetName ¶
func (x *PodResourceQuery) GetName() string
func (*PodResourceQuery) GetNamespace ¶
func (x *PodResourceQuery) GetNamespace() string
func (*PodResourceQuery) GetPodIdentifier ¶
func (m *PodResourceQuery) GetPodIdentifier() isPodResourceQuery_PodIdentifier
func (*PodResourceQuery) GetResourceName ¶
func (x *PodResourceQuery) GetResourceName() string
func (*PodResourceQuery) GetSelector ¶
func (x *PodResourceQuery) GetSelector() string
func (*PodResourceQuery) ProtoMessage ¶
func (*PodResourceQuery) ProtoMessage()
func (*PodResourceQuery) ProtoReflect ¶
func (x *PodResourceQuery) ProtoReflect() protoreflect.Message
func (*PodResourceQuery) Reset ¶
func (x *PodResourceQuery) Reset()
func (*PodResourceQuery) String ¶
func (x *PodResourceQuery) String() string
type PodResourceQuery_Name ¶
type PodResourceQuery_Name struct {
Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}
type PodResourceQuery_Selector ¶
type PodResourceQuery_Selector struct {
Selector string `protobuf:"bytes,3,opt,name=selector,proto3,oneof"`
}
type Point ¶
type Point struct { Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Value float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Point) Descriptor
deprecated
func (*Point) GetTimestamp ¶
func (*Point) ProtoMessage ¶
func (*Point) ProtoMessage()
func (*Point) ProtoReflect ¶
func (x *Point) ProtoReflect() protoreflect.Message
type ProviderServiceClient ¶
type ProviderServiceClient interface { QueryLatest(ctx context.Context, in *QueryLatestRequest, opts ...grpc.CallOption) (*QueryLatestResponse, error) Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error) }
ProviderServiceClient is the client API for ProviderService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewProviderServiceClient ¶
func NewProviderServiceClient(cc grpc.ClientConnInterface) ProviderServiceClient
type ProviderServiceServer ¶
type ProviderServiceServer interface { QueryLatest(context.Context, *QueryLatestRequest) (*QueryLatestResponse, error) Query(context.Context, *QueryRequest) (*QueryResponse, error) // contains filtered or unexported methods }
ProviderServiceServer is the server API for ProviderService service. All implementations must embed UnimplementedProviderServiceServer for forward compatibility
type Query ¶
type Query struct { Type QueryType `protobuf:"varint,1,opt,name=type,proto3,enum=io.kapacitystack.metric.QueryType" json:"type,omitempty"` // Types that are assignable to Query: // // *Query_PodResource // *Query_ContainerResource // *Query_WorkloadResource // *Query_WorkloadContainerResource // *Query_Object // *Query_External // *Query_WorkloadExternal Query isQuery_Query `protobuf_oneof:"query"` // contains filtered or unexported fields }
func (*Query) Descriptor
deprecated
func (*Query) GetContainerResource ¶
func (x *Query) GetContainerResource() *ContainerResourceQuery
func (*Query) GetExternal ¶
func (x *Query) GetExternal() *ExternalQuery
func (*Query) GetObject ¶
func (x *Query) GetObject() *ObjectQuery
func (*Query) GetPodResource ¶
func (x *Query) GetPodResource() *PodResourceQuery
func (*Query) GetWorkloadContainerResource ¶
func (x *Query) GetWorkloadContainerResource() *WorkloadContainerResourceQuery
func (*Query) GetWorkloadExternal ¶
func (x *Query) GetWorkloadExternal() *WorkloadExternalQuery
func (*Query) GetWorkloadResource ¶
func (x *Query) GetWorkloadResource() *WorkloadResourceQuery
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type QueryLatestRequest ¶
type QueryLatestRequest struct { Query *Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*QueryLatestRequest) Descriptor
deprecated
func (*QueryLatestRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryLatestRequest.ProtoReflect.Descriptor instead.
func (*QueryLatestRequest) GetQuery ¶
func (x *QueryLatestRequest) GetQuery() *Query
func (*QueryLatestRequest) ProtoMessage ¶
func (*QueryLatestRequest) ProtoMessage()
func (*QueryLatestRequest) ProtoReflect ¶
func (x *QueryLatestRequest) ProtoReflect() protoreflect.Message
func (*QueryLatestRequest) Reset ¶
func (x *QueryLatestRequest) Reset()
func (*QueryLatestRequest) String ¶
func (x *QueryLatestRequest) String() string
type QueryLatestResponse ¶
type QueryLatestResponse struct { Samples []*Sample `protobuf:"bytes,1,rep,name=samples,proto3" json:"samples,omitempty"` // contains filtered or unexported fields }
func (*QueryLatestResponse) Descriptor
deprecated
func (*QueryLatestResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryLatestResponse.ProtoReflect.Descriptor instead.
func (*QueryLatestResponse) GetSamples ¶
func (x *QueryLatestResponse) GetSamples() []*Sample
func (*QueryLatestResponse) ProtoMessage ¶
func (*QueryLatestResponse) ProtoMessage()
func (*QueryLatestResponse) ProtoReflect ¶
func (x *QueryLatestResponse) ProtoReflect() protoreflect.Message
func (*QueryLatestResponse) Reset ¶
func (x *QueryLatestResponse) Reset()
func (*QueryLatestResponse) String ¶
func (x *QueryLatestResponse) String() string
type QueryRequest ¶
type QueryRequest struct { Query *Query `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"` Start *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"` End *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=end,proto3" json:"end,omitempty"` Step *durationpb.Duration `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"` // contains filtered or unexported fields }
func (*QueryRequest) Descriptor
deprecated
func (*QueryRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.
func (*QueryRequest) GetEnd ¶
func (x *QueryRequest) GetEnd() *timestamppb.Timestamp
func (*QueryRequest) GetQuery ¶
func (x *QueryRequest) GetQuery() *Query
func (*QueryRequest) GetStart ¶
func (x *QueryRequest) GetStart() *timestamppb.Timestamp
func (*QueryRequest) GetStep ¶
func (x *QueryRequest) GetStep() *durationpb.Duration
func (*QueryRequest) ProtoMessage ¶
func (*QueryRequest) ProtoMessage()
func (*QueryRequest) ProtoReflect ¶
func (x *QueryRequest) ProtoReflect() protoreflect.Message
func (*QueryRequest) Reset ¶
func (x *QueryRequest) Reset()
func (*QueryRequest) String ¶
func (x *QueryRequest) String() string
type QueryResponse ¶
type QueryResponse struct { Series []*Series `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"` // contains filtered or unexported fields }
func (*QueryResponse) Descriptor
deprecated
func (*QueryResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.
func (*QueryResponse) GetSeries ¶
func (x *QueryResponse) GetSeries() []*Series
func (*QueryResponse) ProtoMessage ¶
func (*QueryResponse) ProtoMessage()
func (*QueryResponse) ProtoReflect ¶
func (x *QueryResponse) ProtoReflect() protoreflect.Message
func (*QueryResponse) Reset ¶
func (x *QueryResponse) Reset()
func (*QueryResponse) String ¶
func (x *QueryResponse) String() string
type QueryType ¶
type QueryType int32
func (QueryType) Descriptor ¶
func (QueryType) Descriptor() protoreflect.EnumDescriptor
func (QueryType) EnumDescriptor
deprecated
func (QueryType) Number ¶
func (x QueryType) Number() protoreflect.EnumNumber
func (QueryType) Type ¶
func (QueryType) Type() protoreflect.EnumType
type Query_ContainerResource ¶
type Query_ContainerResource struct {
ContainerResource *ContainerResourceQuery `protobuf:"bytes,3,opt,name=container_resource,json=containerResource,proto3,oneof"`
}
type Query_External ¶
type Query_External struct {
External *ExternalQuery `protobuf:"bytes,7,opt,name=external,proto3,oneof"`
}
type Query_Object ¶
type Query_Object struct {
Object *ObjectQuery `protobuf:"bytes,6,opt,name=object,proto3,oneof"`
}
type Query_PodResource ¶
type Query_PodResource struct {
PodResource *PodResourceQuery `protobuf:"bytes,2,opt,name=pod_resource,json=podResource,proto3,oneof"`
}
type Query_WorkloadContainerResource ¶
type Query_WorkloadContainerResource struct {
WorkloadContainerResource *WorkloadContainerResourceQuery `protobuf:"bytes,5,opt,name=workload_container_resource,json=workloadContainerResource,proto3,oneof"`
}
type Query_WorkloadExternal ¶
type Query_WorkloadExternal struct {
WorkloadExternal *WorkloadExternalQuery `protobuf:"bytes,8,opt,name=workload_external,json=workloadExternal,proto3,oneof"`
}
type Query_WorkloadResource ¶
type Query_WorkloadResource struct {
WorkloadResource *WorkloadResourceQuery `protobuf:"bytes,4,opt,name=workload_resource,json=workloadResource,proto3,oneof"`
}
type Sample ¶
type Sample struct { Point *Point `protobuf:"bytes,1,opt,name=point,proto3" json:"point,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Window *durationpb.Duration `protobuf:"bytes,3,opt,name=window,proto3,oneof" json:"window,omitempty"` // contains filtered or unexported fields }
func (*Sample) Descriptor
deprecated
func (*Sample) GetWindow ¶
func (x *Sample) GetWindow() *durationpb.Duration
func (*Sample) ProtoMessage ¶
func (*Sample) ProtoMessage()
func (*Sample) ProtoReflect ¶
func (x *Sample) ProtoReflect() protoreflect.Message
type Series ¶
type Series struct { Points []*Point `protobuf:"bytes,1,rep,name=points,proto3" json:"points,omitempty"` Labels map[string]string `` /* 153-byte string literal not displayed */ Window *durationpb.Duration `protobuf:"bytes,3,opt,name=window,proto3,oneof" json:"window,omitempty"` // contains filtered or unexported fields }
func (*Series) Descriptor
deprecated
func (*Series) GetWindow ¶
func (x *Series) GetWindow() *durationpb.Duration
func (*Series) ProtoMessage ¶
func (*Series) ProtoMessage()
func (*Series) ProtoReflect ¶
func (x *Series) ProtoReflect() protoreflect.Message
type UnimplementedProviderServiceServer ¶
type UnimplementedProviderServiceServer struct { }
UnimplementedProviderServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedProviderServiceServer) Query ¶
func (UnimplementedProviderServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)
func (UnimplementedProviderServiceServer) QueryLatest ¶
func (UnimplementedProviderServiceServer) QueryLatest(context.Context, *QueryLatestRequest) (*QueryLatestResponse, error)
type UnsafeProviderServiceServer ¶
type UnsafeProviderServiceServer interface {
// contains filtered or unexported methods
}
UnsafeProviderServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProviderServiceServer will result in compilation errors.
type WorkloadContainerResourceQuery ¶
type WorkloadContainerResourceQuery struct { GroupKind *GroupKind `protobuf:"bytes,1,opt,name=group_kind,json=groupKind,proto3" json:"group_kind,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"` ResourceName string `protobuf:"bytes,4,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"` ContainerName string `protobuf:"bytes,5,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"` ReadyPodsOnly bool `protobuf:"varint,6,opt,name=ready_pods_only,json=readyPodsOnly,proto3" json:"ready_pods_only,omitempty"` // contains filtered or unexported fields }
func (*WorkloadContainerResourceQuery) Descriptor
deprecated
func (*WorkloadContainerResourceQuery) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadContainerResourceQuery.ProtoReflect.Descriptor instead.
func (*WorkloadContainerResourceQuery) GetContainerName ¶
func (x *WorkloadContainerResourceQuery) GetContainerName() string
func (*WorkloadContainerResourceQuery) GetGroupKind ¶
func (x *WorkloadContainerResourceQuery) GetGroupKind() *GroupKind
func (*WorkloadContainerResourceQuery) GetName ¶
func (x *WorkloadContainerResourceQuery) GetName() string
func (*WorkloadContainerResourceQuery) GetNamespace ¶
func (x *WorkloadContainerResourceQuery) GetNamespace() string
func (*WorkloadContainerResourceQuery) GetReadyPodsOnly ¶
func (x *WorkloadContainerResourceQuery) GetReadyPodsOnly() bool
func (*WorkloadContainerResourceQuery) GetResourceName ¶
func (x *WorkloadContainerResourceQuery) GetResourceName() string
func (*WorkloadContainerResourceQuery) ProtoMessage ¶
func (*WorkloadContainerResourceQuery) ProtoMessage()
func (*WorkloadContainerResourceQuery) ProtoReflect ¶
func (x *WorkloadContainerResourceQuery) ProtoReflect() protoreflect.Message
func (*WorkloadContainerResourceQuery) Reset ¶
func (x *WorkloadContainerResourceQuery) Reset()
func (*WorkloadContainerResourceQuery) String ¶
func (x *WorkloadContainerResourceQuery) String() string
type WorkloadExternalQuery ¶
type WorkloadExternalQuery struct { GroupKind *GroupKind `protobuf:"bytes,1,opt,name=group_kind,json=groupKind,proto3" json:"group_kind,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"` Metric *MetricIdentifier `protobuf:"bytes,4,opt,name=metric,proto3" json:"metric,omitempty"` // contains filtered or unexported fields }
func (*WorkloadExternalQuery) Descriptor
deprecated
func (*WorkloadExternalQuery) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadExternalQuery.ProtoReflect.Descriptor instead.
func (*WorkloadExternalQuery) GetGroupKind ¶
func (x *WorkloadExternalQuery) GetGroupKind() *GroupKind
func (*WorkloadExternalQuery) GetMetric ¶
func (x *WorkloadExternalQuery) GetMetric() *MetricIdentifier
func (*WorkloadExternalQuery) GetName ¶
func (x *WorkloadExternalQuery) GetName() string
func (*WorkloadExternalQuery) GetNamespace ¶
func (x *WorkloadExternalQuery) GetNamespace() string
func (*WorkloadExternalQuery) ProtoMessage ¶
func (*WorkloadExternalQuery) ProtoMessage()
func (*WorkloadExternalQuery) ProtoReflect ¶
func (x *WorkloadExternalQuery) ProtoReflect() protoreflect.Message
func (*WorkloadExternalQuery) Reset ¶
func (x *WorkloadExternalQuery) Reset()
func (*WorkloadExternalQuery) String ¶
func (x *WorkloadExternalQuery) String() string
type WorkloadResourceQuery ¶
type WorkloadResourceQuery struct { GroupKind *GroupKind `protobuf:"bytes,1,opt,name=group_kind,json=groupKind,proto3" json:"group_kind,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"` ResourceName string `protobuf:"bytes,4,opt,name=resource_name,json=resourceName,proto3" json:"resource_name,omitempty"` ReadyPodsOnly bool `protobuf:"varint,5,opt,name=ready_pods_only,json=readyPodsOnly,proto3" json:"ready_pods_only,omitempty"` // contains filtered or unexported fields }
func (*WorkloadResourceQuery) Descriptor
deprecated
func (*WorkloadResourceQuery) Descriptor() ([]byte, []int)
Deprecated: Use WorkloadResourceQuery.ProtoReflect.Descriptor instead.
func (*WorkloadResourceQuery) GetGroupKind ¶
func (x *WorkloadResourceQuery) GetGroupKind() *GroupKind
func (*WorkloadResourceQuery) GetName ¶
func (x *WorkloadResourceQuery) GetName() string
func (*WorkloadResourceQuery) GetNamespace ¶
func (x *WorkloadResourceQuery) GetNamespace() string
func (*WorkloadResourceQuery) GetReadyPodsOnly ¶
func (x *WorkloadResourceQuery) GetReadyPodsOnly() bool
func (*WorkloadResourceQuery) GetResourceName ¶
func (x *WorkloadResourceQuery) GetResourceName() string
func (*WorkloadResourceQuery) ProtoMessage ¶
func (*WorkloadResourceQuery) ProtoMessage()
func (*WorkloadResourceQuery) ProtoReflect ¶
func (x *WorkloadResourceQuery) ProtoReflect() protoreflect.Message
func (*WorkloadResourceQuery) Reset ¶
func (x *WorkloadResourceQuery) Reset()
func (*WorkloadResourceQuery) String ¶
func (x *WorkloadResourceQuery) String() string