1// Code generated by protoc-gen-go-grpc. DO NOT EDIT. 2 3package grpc_testing 4 5import ( 6 context "context" 7 grpc "google.golang.org/grpc" 8 codes "google.golang.org/grpc/codes" 9 status "google.golang.org/grpc/status" 10) 11 12// This is a compile-time assertion to ensure that this generated file 13// is compatible with the grpc package it is being compiled against. 14// Requires gRPC-Go v1.32.0 or later. 15const _ = grpc.SupportPackageIsVersion7 16 17// MetricsServiceClient is the client API for MetricsService service. 18// 19// 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. 20type MetricsServiceClient interface { 21 // Returns the values of all the gauges that are currently being maintained by 22 // the service 23 GetAllGauges(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (MetricsService_GetAllGaugesClient, error) 24 // Returns the value of one gauge 25 GetGauge(ctx context.Context, in *GaugeRequest, opts ...grpc.CallOption) (*GaugeResponse, error) 26} 27 28type metricsServiceClient struct { 29 cc grpc.ClientConnInterface 30} 31 32func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient { 33 return &metricsServiceClient{cc} 34} 35 36func (c *metricsServiceClient) GetAllGauges(ctx context.Context, in *EmptyMessage, opts ...grpc.CallOption) (MetricsService_GetAllGaugesClient, error) { 37 stream, err := c.cc.NewStream(ctx, &MetricsService_ServiceDesc.Streams[0], "/grpc.testing.MetricsService/GetAllGauges", opts...) 38 if err != nil { 39 return nil, err 40 } 41 x := &metricsServiceGetAllGaugesClient{stream} 42 if err := x.ClientStream.SendMsg(in); err != nil { 43 return nil, err 44 } 45 if err := x.ClientStream.CloseSend(); err != nil { 46 return nil, err 47 } 48 return x, nil 49} 50 51type MetricsService_GetAllGaugesClient interface { 52 Recv() (*GaugeResponse, error) 53 grpc.ClientStream 54} 55 56type metricsServiceGetAllGaugesClient struct { 57 grpc.ClientStream 58} 59 60func (x *metricsServiceGetAllGaugesClient) Recv() (*GaugeResponse, error) { 61 m := new(GaugeResponse) 62 if err := x.ClientStream.RecvMsg(m); err != nil { 63 return nil, err 64 } 65 return m, nil 66} 67 68func (c *metricsServiceClient) GetGauge(ctx context.Context, in *GaugeRequest, opts ...grpc.CallOption) (*GaugeResponse, error) { 69 out := new(GaugeResponse) 70 err := c.cc.Invoke(ctx, "/grpc.testing.MetricsService/GetGauge", in, out, opts...) 71 if err != nil { 72 return nil, err 73 } 74 return out, nil 75} 76 77// MetricsServiceServer is the server API for MetricsService service. 78// All implementations must embed UnimplementedMetricsServiceServer 79// for forward compatibility 80type MetricsServiceServer interface { 81 // Returns the values of all the gauges that are currently being maintained by 82 // the service 83 GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error 84 // Returns the value of one gauge 85 GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error) 86 mustEmbedUnimplementedMetricsServiceServer() 87} 88 89// UnimplementedMetricsServiceServer must be embedded to have forward compatible implementations. 90type UnimplementedMetricsServiceServer struct { 91} 92 93func (UnimplementedMetricsServiceServer) GetAllGauges(*EmptyMessage, MetricsService_GetAllGaugesServer) error { 94 return status.Errorf(codes.Unimplemented, "method GetAllGauges not implemented") 95} 96func (UnimplementedMetricsServiceServer) GetGauge(context.Context, *GaugeRequest) (*GaugeResponse, error) { 97 return nil, status.Errorf(codes.Unimplemented, "method GetGauge not implemented") 98} 99func (UnimplementedMetricsServiceServer) mustEmbedUnimplementedMetricsServiceServer() {} 100 101// UnsafeMetricsServiceServer may be embedded to opt out of forward compatibility for this service. 102// Use of this interface is not recommended, as added methods to MetricsServiceServer will 103// result in compilation errors. 104type UnsafeMetricsServiceServer interface { 105 mustEmbedUnimplementedMetricsServiceServer() 106} 107 108func RegisterMetricsServiceServer(s grpc.ServiceRegistrar, srv MetricsServiceServer) { 109 s.RegisterService(&MetricsService_ServiceDesc, srv) 110} 111 112func _MetricsService_GetAllGauges_Handler(srv interface{}, stream grpc.ServerStream) error { 113 m := new(EmptyMessage) 114 if err := stream.RecvMsg(m); err != nil { 115 return err 116 } 117 return srv.(MetricsServiceServer).GetAllGauges(m, &metricsServiceGetAllGaugesServer{stream}) 118} 119 120type MetricsService_GetAllGaugesServer interface { 121 Send(*GaugeResponse) error 122 grpc.ServerStream 123} 124 125type metricsServiceGetAllGaugesServer struct { 126 grpc.ServerStream 127} 128 129func (x *metricsServiceGetAllGaugesServer) Send(m *GaugeResponse) error { 130 return x.ServerStream.SendMsg(m) 131} 132 133func _MetricsService_GetGauge_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { 134 in := new(GaugeRequest) 135 if err := dec(in); err != nil { 136 return nil, err 137 } 138 if interceptor == nil { 139 return srv.(MetricsServiceServer).GetGauge(ctx, in) 140 } 141 info := &grpc.UnaryServerInfo{ 142 Server: srv, 143 FullMethod: "/grpc.testing.MetricsService/GetGauge", 144 } 145 handler := func(ctx context.Context, req interface{}) (interface{}, error) { 146 return srv.(MetricsServiceServer).GetGauge(ctx, req.(*GaugeRequest)) 147 } 148 return interceptor(ctx, in, info, handler) 149} 150 151// MetricsService_ServiceDesc is the grpc.ServiceDesc for MetricsService service. 152// It's only intended for direct use with grpc.RegisterService, 153// and not to be introspected or modified (even as a copy) 154var MetricsService_ServiceDesc = grpc.ServiceDesc{ 155 ServiceName: "grpc.testing.MetricsService", 156 HandlerType: (*MetricsServiceServer)(nil), 157 Methods: []grpc.MethodDesc{ 158 { 159 MethodName: "GetGauge", 160 Handler: _MetricsService_GetGauge_Handler, 161 }, 162 }, 163 Streams: []grpc.StreamDesc{ 164 { 165 StreamName: "GetAllGauges", 166 Handler: _MetricsService_GetAllGauges_Handler, 167 ServerStreams: true, 168 }, 169 }, 170 Metadata: "stress/grpc_testing/metrics.proto", 171} 172