collector

Documentation

Index

• Constants
• Variables
• func RegisterRemoteCollectorServer(s grpc.ServiceRegistrar, srv RemoteCollectorServer)
• type CollectorServer
  • func NewCollectorServer(readers ...metric.Reader) CollectorServer
• type RemoteCollectorClient
  • func NewRemoteCollectorClient(cc grpc.ClientConnInterface) RemoteCollectorClient
• type RemoteCollectorServer
• type RemoteProducer
  • func NewRemoteProducer(client RemoteCollectorClient) RemoteProducer
• type UnimplementedRemoteCollectorServer
  • func (UnimplementedRemoteCollectorServer) GetMetrics(context.Context, *emptypb.Empty) (*v1.MetricsData, error)
• type UnsafeRemoteCollectorServer

Constants

const (
	RemoteCollector_GetMetrics_FullMethodName = "/collector.RemoteCollector/GetMetrics"
)

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: "GetMetrics",
			Handler:    _RemoteCollector_GetMetrics_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
	AppendReader(metric.Reader)
}

func NewCollectorServer

func NewCollectorServer(readers ...metric.Reader) CollectorServer

type RemoteCollectorClient

type RemoteCollectorClient interface {
	GetMetrics(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v1.MetricsData, 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 {
	GetMetrics(context.Context, *emptypb.Empty) (*v1.MetricsData, error)
	// contains filtered or unexported methods
}

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

type RemoteProducer

type RemoteProducer interface {
	metric.Producer
}

func NewRemoteProducer

func NewRemoteProducer(client RemoteCollectorClient) RemoteProducer

type UnimplementedRemoteCollectorServer

type UnimplementedRemoteCollectorServer struct {
}

UnimplementedRemoteCollectorServer must be embedded to have forward compatible implementations.

func (UnimplementedRemoteCollectorServer) GetMetrics

func (UnimplementedRemoteCollectorServer) GetMetrics(context.Context, *emptypb.Empty) (*v1.MetricsData, 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.