Documentation
¶
Index ¶
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 ¶ added in v0.11.0
func NewRemoteProducer ¶ added in v0.11.0
func NewRemoteProducer(client RemoteCollectorClient) RemoteProducer
type UnimplementedRemoteCollectorServer ¶
type UnimplementedRemoteCollectorServer struct { }
UnimplementedRemoteCollectorServer must be embedded to have forward compatible implementations.
func (UnimplementedRemoteCollectorServer) GetMetrics ¶ added in v0.11.0
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.