collector

Documentation

Index

• Variables
• func RegisterRemoteCollectorServer(s grpc.ServiceRegistrar, srv RemoteCollectorServer)
• type CollectorServer
  • func NewCollectorServer() CollectorServer
• type DescriptorList
  • func (*DescriptorList) Descriptor() ([]byte, []int)
  • func (x *DescriptorList) GetDescriptors() []*desc.Desc
  • func (*DescriptorList) ProtoMessage()
  • func (x *DescriptorList) ProtoReflect() protoreflect.Message
  • func (x *DescriptorList) Reset()
  • func (x *DescriptorList) String() string
• type Metric
  • func (*Metric) Descriptor() ([]byte, []int)
  • func (x *Metric) GetDesc() *desc.Desc
  • func (x *Metric) GetMetric() *_go.Metric
  • func (*Metric) ProtoMessage()
  • func (x *Metric) ProtoReflect() protoreflect.Message
  • func (x *Metric) Reset()
  • func (x *Metric) String() string
• type MetricList
  • func (*MetricList) Descriptor() ([]byte, []int)
  • func (x *MetricList) GetMetrics() []*Metric
  • func (*MetricList) ProtoMessage()
  • func (x *MetricList) ProtoReflect() protoreflect.Message
  • func (x *MetricList) Reset()
  • func (x *MetricList) String() string
• type RemoteCollector
  • func NewRemoteCollector(client RemoteCollectorClient) RemoteCollector
• type RemoteCollectorClient
  • func NewRemoteCollectorClient(cc grpc.ClientConnInterface) RemoteCollectorClient
• type RemoteCollectorServer
• type UnimplementedRemoteCollectorServer
  • func (UnimplementedRemoteCollectorServer) Collect(context.Context, *emptypb.Empty) (*MetricList, error)
  • func (UnimplementedRemoteCollectorServer) Describe(context.Context, *emptypb.Empty) (*DescriptorList, error)
• type UnsafeRemoteCollectorServer

Variables

var File_github_com_rancher_opni_pkg_metrics_collector_remote_proto protoreflect.FileDescriptor

var RemoteCollector_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "collector.RemoteCollector",
	HandlerType: (*RemoteCollectorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Describe",
			Handler:    _RemoteCollector_Describe_Handler,
		},
		{
			MethodName: "Collect",
			Handler:    _RemoteCollector_Collect_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "github.com/rancher/opni/pkg/metrics/collector/remote.proto",
}

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

Functions

func RegisterRemoteCollectorServer

func RegisterRemoteCollectorServer(s grpc.ServiceRegistrar, srv RemoteCollectorServer)

Types

type CollectorServer

type CollectorServer interface {
	RemoteCollectorServer
	MustRegister(collectors ...prometheus.Collector)
}

func NewCollectorServer

func NewCollectorServer() CollectorServer

type DescriptorList

type DescriptorList struct {
	Descriptors []*desc.Desc `protobuf:"bytes,1,rep,name=descriptors,proto3" json:"descriptors,omitempty"`
	// contains filtered or unexported fields
}

func (*DescriptorList) Descriptor

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

Deprecated: Use DescriptorList.ProtoReflect.Descriptor instead.

func (*DescriptorList) GetDescriptors

func (x *DescriptorList) GetDescriptors() []*desc.Desc

func (*DescriptorList) ProtoMessage

func (*DescriptorList) ProtoMessage()

func (*DescriptorList) ProtoReflect

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

func (*DescriptorList) Reset

func (x *DescriptorList) Reset()

func (*DescriptorList) String

func (x *DescriptorList) String() string

type Metric

type Metric struct {
	Desc   *desc.Desc  `protobuf:"bytes,1,opt,name=desc,proto3" json:"desc,omitempty"`
	Metric *_go.Metric `protobuf:"bytes,2,opt,name=metric,proto3" json:"metric,omitempty"`
	// contains filtered or unexported fields
}

func (*Metric) Descriptor

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetDesc

func (x *Metric) GetDesc() *desc.Desc

func (*Metric) GetMetric

func (x *Metric) GetMetric() *_go.Metric

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 MetricList

type MetricList struct {
	Metrics []*Metric `protobuf:"bytes,1,rep,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricList) Descriptor

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

Deprecated: Use MetricList.ProtoReflect.Descriptor instead.

func (*MetricList) GetMetrics

func (x *MetricList) GetMetrics() []*Metric

func (*MetricList) ProtoMessage

func (*MetricList) ProtoMessage()

func (*MetricList) ProtoReflect

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

func (*MetricList) Reset

func (x *MetricList) Reset()

func (*MetricList) String

func (x *MetricList) String() string

type RemoteCollector

type RemoteCollector interface {
	prometheus.Collector
}

func NewRemoteCollector

func NewRemoteCollector(client RemoteCollectorClient) RemoteCollector

type RemoteCollectorClient

type RemoteCollectorClient interface {
	Describe(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*DescriptorList, error)
	Collect(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*MetricList, error)
}

RemoteCollectorClient is the client API for RemoteCollector 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 NewRemoteCollectorClient

func NewRemoteCollectorClient(cc grpc.ClientConnInterface) RemoteCollectorClient

type RemoteCollectorServer

type RemoteCollectorServer interface {
	Describe(context.Context, *emptypb.Empty) (*DescriptorList, error)
	Collect(context.Context, *emptypb.Empty) (*MetricList, error)
	// contains filtered or unexported methods
}

RemoteCollectorServer is the server API for RemoteCollector service. All implementations must embed UnimplementedRemoteCollectorServer for forward compatibility

type UnimplementedRemoteCollectorServer

type UnimplementedRemoteCollectorServer struct {
}

UnimplementedRemoteCollectorServer must be embedded to have forward compatible implementations.

func (UnimplementedRemoteCollectorServer) Collect

func (UnimplementedRemoteCollectorServer) Collect(context.Context, *emptypb.Empty) (*MetricList, error)

func (UnimplementedRemoteCollectorServer) Describe

func (UnimplementedRemoteCollectorServer) Describe(context.Context, *emptypb.Empty) (*DescriptorList, error)

type UnsafeRemoteCollectorServer

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

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