pb

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Jul 25, 2023 License: Apache-2.0, BSD-2-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_provider_proto protoreflect.FileDescriptor
View Source 
var History_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "History",
	HandlerType: (*HistoryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryTimeSeries",
			Handler:    _History_QueryTimeSeries_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "provider.proto",
}

History_ServiceDesc is the grpc.ServiceDesc for History service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Realtime_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "Realtime",
	HandlerType: (*RealtimeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryLatestTimeSeries",
			Handler:    _Realtime_QueryLatestTimeSeries_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "provider.proto",
}

Realtime_ServiceDesc is the grpc.ServiceDesc for Realtime service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterHistoryServer 

func RegisterHistoryServer(s grpc.ServiceRegistrar, srv HistoryServer)

func RegisterRealtimeServer 

func RegisterRealtimeServer(s grpc.ServiceRegistrar, srv RealtimeServer)

Types

type Container 

type Container struct {
	Namespace    string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	WorkloadKind string `protobuf:"bytes,2,opt,name=workloadKind,proto3" json:"workloadKind,omitempty"`
	WorkloadName string `protobuf:"bytes,3,opt,name=workloadName,proto3" json:"workloadName,omitempty"`
	ApiVersion   string `protobuf:"bytes,4,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	Name         string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Container) Descriptor deprecated 

func (*Container) Descriptor() ([]byte, []int)

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetApiVersion 

func (x *Container) GetApiVersion() string

func (*Container) GetName 

func (x *Container) GetName() string

func (*Container) GetNamespace 

func (x *Container) GetNamespace() string

func (*Container) GetWorkloadKind 

func (x *Container) GetWorkloadKind() string

func (*Container) GetWorkloadName 

func (x *Container) GetWorkloadName() string

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) ProtoReflect 

func (x *Container) ProtoReflect() protoreflect.Message

func (*Container) Reset 

func (x *Container) Reset()

func (*Container) String 

func (x *Container) String() string

type HistoryClient 

type HistoryClient interface {
	QueryTimeSeries(ctx context.Context, in *QueryTimeSeriesRequest, opts ...grpc.CallOption) (*QueryTimeSeriesResponse, error)
}

HistoryClient is the client API for History 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 NewHistoryClient 

func NewHistoryClient(cc grpc.ClientConnInterface) HistoryClient

type HistoryServer 

type HistoryServer interface {
	QueryTimeSeries(context.Context, *QueryTimeSeriesRequest) (*QueryTimeSeriesResponse, error)
	// contains filtered or unexported methods
}

HistoryServer is the server API for History service. All implementations must embed UnimplementedHistoryServer for forward compatibility

type Label 

type Label struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Label) Descriptor deprecated 

func (*Label) Descriptor() ([]byte, []int)

Deprecated: Use Label.ProtoReflect.Descriptor instead.

func (*Label) GetName 

func (x *Label) GetName() string

func (*Label) GetValue 

func (x *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) ProtoReflect 

func (x *Label) ProtoReflect() protoreflect.Message

func (*Label) Reset 

func (x *Label) Reset()

func (*Label) String 

func (x *Label) String() string

type Metric 

type Metric struct {
	MetricName string `protobuf:"bytes,1,opt,name=metricName,proto3" json:"metricName,omitempty"`
	// Types that are assignable to Info:
	//	*Metric_Container
	//	*Metric_Pod
	//	*Metric_Node
	//	*Metric_Workload
	Info isMetric_Info `protobuf_oneof:"info"`
	// contains filtered or unexported fields
}

func (*Metric) Descriptor deprecated 

func (*Metric) Descriptor() ([]byte, []int)

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetContainer 

func (x *Metric) GetContainer() *Container

func (*Metric) GetInfo 

func (m *Metric) GetInfo() isMetric_Info

func (*Metric) GetMetricName 

func (x *Metric) GetMetricName() string

func (*Metric) GetNode 

func (x *Metric) GetNode() *Node

func (*Metric) GetPod 

func (x *Metric) GetPod() *Pod

func (*Metric) GetWorkload 

func (x *Metric) GetWorkload() *Workload

func (*Metric) ProtoMessage 

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect 

func (x *Metric) ProtoReflect() protoreflect.Message

func (*Metric) Reset 

func (x *Metric) Reset()

func (*Metric) String 

func (x *Metric) String() string

type Metric_Container 

type Metric_Container struct {
	Container *Container `protobuf:"bytes,2,opt,name=container,proto3,oneof"`
}

type Metric_Node 

type Metric_Node struct {
	Node *Node `protobuf:"bytes,4,opt,name=node,proto3,oneof"`
}

type Metric_Pod 

type Metric_Pod struct {
	Pod *Pod `protobuf:"bytes,3,opt,name=pod,proto3,oneof"`
}

type Metric_Workload 

type Metric_Workload struct {
	Workload *Workload `protobuf:"bytes,5,opt,name=workload,proto3,oneof"`
}

type Node 

type Node struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type Pod 

type Pod struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*Pod) Descriptor deprecated 

func (*Pod) Descriptor() ([]byte, []int)

Deprecated: Use Pod.ProtoReflect.Descriptor instead.

func (*Pod) GetName 

func (x *Pod) GetName() string

func (*Pod) GetNamespace 

func (x *Pod) GetNamespace() string

func (*Pod) ProtoMessage 

func (*Pod) ProtoMessage()

func (*Pod) ProtoReflect 

func (x *Pod) ProtoReflect() protoreflect.Message

func (*Pod) Reset 

func (x *Pod) Reset()

func (*Pod) String 

func (x *Pod) String() string

type QueryTimeSeriesRequest 

type QueryTimeSeriesRequest struct {
	Metric    *Metric `protobuf:"bytes,1,opt,name=metric,proto3" json:"metric,omitempty"`
	StartTime int64   `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime   int64   `protobuf:"varint,3,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Step      int64   `protobuf:"varint,4,opt,name=step,proto3" json:"step,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTimeSeriesRequest) Descriptor deprecated 

func (*QueryTimeSeriesRequest) Descriptor() ([]byte, []int)

Deprecated: Use QueryTimeSeriesRequest.ProtoReflect.Descriptor instead.

func (*QueryTimeSeriesRequest) GetEndTime 

func (x *QueryTimeSeriesRequest) GetEndTime() int64

func (*QueryTimeSeriesRequest) GetMetric 

func (x *QueryTimeSeriesRequest) GetMetric() *Metric

func (*QueryTimeSeriesRequest) GetStartTime 

func (x *QueryTimeSeriesRequest) GetStartTime() int64

func (*QueryTimeSeriesRequest) GetStep 

func (x *QueryTimeSeriesRequest) GetStep() int64

func (*QueryTimeSeriesRequest) ProtoMessage 

func (*QueryTimeSeriesRequest) ProtoMessage()

func (*QueryTimeSeriesRequest) ProtoReflect 

func (x *QueryTimeSeriesRequest) ProtoReflect() protoreflect.Message

func (*QueryTimeSeriesRequest) Reset 

func (x *QueryTimeSeriesRequest) Reset()

func (*QueryTimeSeriesRequest) String 

func (x *QueryTimeSeriesRequest) String() string

type QueryTimeSeriesResponse 

type QueryTimeSeriesResponse struct {
	TimeSeriesList []*TimeSeries `protobuf:"bytes,1,rep,name=timeSeriesList,proto3" json:"timeSeriesList,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryTimeSeriesResponse) Descriptor deprecated 

func (*QueryTimeSeriesResponse) Descriptor() ([]byte, []int)

Deprecated: Use QueryTimeSeriesResponse.ProtoReflect.Descriptor instead.

func (*QueryTimeSeriesResponse) GetTimeSeriesList 

func (x *QueryTimeSeriesResponse) GetTimeSeriesList() []*TimeSeries

func (*QueryTimeSeriesResponse) ProtoMessage 

func (*QueryTimeSeriesResponse) ProtoMessage()

func (*QueryTimeSeriesResponse) ProtoReflect 

func (x *QueryTimeSeriesResponse) ProtoReflect() protoreflect.Message

func (*QueryTimeSeriesResponse) Reset 

func (x *QueryTimeSeriesResponse) Reset()

func (*QueryTimeSeriesResponse) String 

func (x *QueryTimeSeriesResponse) String() string

type RealtimeClient 

type RealtimeClient interface {
	QueryLatestTimeSeries(ctx context.Context, in *QueryTimeSeriesRequest, opts ...grpc.CallOption) (*QueryTimeSeriesResponse, error)
}

RealtimeClient is the client API for Realtime 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 NewRealtimeClient 

func NewRealtimeClient(cc grpc.ClientConnInterface) RealtimeClient

type RealtimeServer 

type RealtimeServer interface {
	QueryLatestTimeSeries(context.Context, *QueryTimeSeriesRequest) (*QueryTimeSeriesResponse, error)
	// contains filtered or unexported methods
}

RealtimeServer is the server API for Realtime service. All implementations must embed UnimplementedRealtimeServer for forward compatibility

type Sample 

type Sample 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 (*Sample) Descriptor deprecated 

func (*Sample) Descriptor() ([]byte, []int)

Deprecated: Use Sample.ProtoReflect.Descriptor instead.

func (*Sample) GetTimestamp 

func (x *Sample) GetTimestamp() int64

func (*Sample) GetValue 

func (x *Sample) GetValue() float64

func (*Sample) ProtoMessage 

func (*Sample) ProtoMessage()

func (*Sample) ProtoReflect 

func (x *Sample) ProtoReflect() protoreflect.Message

func (*Sample) Reset 

func (x *Sample) Reset()

func (*Sample) String 

func (x *Sample) String() string

type TimeSeries 

type TimeSeries struct {
	Labels  []*Label  `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"`
	Samples []*Sample `protobuf:"bytes,2,rep,name=samples,proto3" json:"samples,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeSeries) Descriptor deprecated 

func (*TimeSeries) Descriptor() ([]byte, []int)

Deprecated: Use TimeSeries.ProtoReflect.Descriptor instead.

func (*TimeSeries) GetLabels 

func (x *TimeSeries) GetLabels() []*Label

func (*TimeSeries) GetSamples 

func (x *TimeSeries) GetSamples() []*Sample

func (*TimeSeries) ProtoMessage 

func (*TimeSeries) ProtoMessage()

func (*TimeSeries) ProtoReflect 

func (x *TimeSeries) ProtoReflect() protoreflect.Message

func (*TimeSeries) Reset 

func (x *TimeSeries) Reset()

func (*TimeSeries) String 

func (x *TimeSeries) String() string

type UnimplementedHistoryServer 

type UnimplementedHistoryServer struct {
}

UnimplementedHistoryServer must be embedded to have forward compatible implementations.

func (UnimplementedHistoryServer) QueryTimeSeries 

func (UnimplementedHistoryServer) QueryTimeSeries(context.Context, *QueryTimeSeriesRequest) (*QueryTimeSeriesResponse, error)

type UnimplementedRealtimeServer 

type UnimplementedRealtimeServer struct {
}

UnimplementedRealtimeServer must be embedded to have forward compatible implementations.

func (UnimplementedRealtimeServer) QueryLatestTimeSeries 

func (UnimplementedRealtimeServer) QueryLatestTimeSeries(context.Context, *QueryTimeSeriesRequest) (*QueryTimeSeriesResponse, error)

type UnsafeHistoryServer 

type UnsafeHistoryServer interface {
	// contains filtered or unexported methods
}

UnsafeHistoryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HistoryServer will result in compilation errors.

type UnsafeRealtimeServer 

type UnsafeRealtimeServer interface {
	// contains filtered or unexported methods
}

UnsafeRealtimeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RealtimeServer will result in compilation errors.

type Workload 

type Workload struct {
	Namespace  string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Kind       string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Name       string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ApiVersion string `protobuf:"bytes,4,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*Workload) Descriptor deprecated 

func (*Workload) Descriptor() ([]byte, []int)

Deprecated: Use Workload.ProtoReflect.Descriptor instead.

func (*Workload) GetApiVersion 

func (x *Workload) GetApiVersion() string

func (*Workload) GetKind 

func (x *Workload) GetKind() string

func (*Workload) GetName 

func (x *Workload) GetName() string

func (*Workload) GetNamespace 

func (x *Workload) GetNamespace() string

func (*Workload) ProtoMessage 

func (*Workload) ProtoMessage()

func (*Workload) ProtoReflect 

func (x *Workload) ProtoReflect() protoreflect.Message

func (*Workload) Reset 

func (x *Workload) Reset()

func (*Workload) String 

func (x *Workload) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.