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