]>
Commit | Line | Data |
---|---|---|
107c1cdb ND |
1 | // Code generated by protoc-gen-go. DO NOT EDIT. |
2 | // source: grpc/health/v1/health.proto | |
15c0b25d | 3 | |
107c1cdb | 4 | package grpc_health_v1 // import "google.golang.org/grpc/health/grpc_health_v1" |
15c0b25d AP |
5 | |
6 | import proto "github.com/golang/protobuf/proto" | |
7 | import fmt "fmt" | |
8 | import math "math" | |
9 | ||
10 | import ( | |
11 | context "golang.org/x/net/context" | |
12 | grpc "google.golang.org/grpc" | |
13 | ) | |
14 | ||
15 | // Reference imports to suppress errors if they are not otherwise used. | |
16 | var _ = proto.Marshal | |
17 | var _ = fmt.Errorf | |
18 | var _ = math.Inf | |
19 | ||
20 | // This is a compile-time assertion to ensure that this generated file | |
21 | // is compatible with the proto package it is being compiled against. | |
22 | // A compilation error at this line likely means your copy of the | |
23 | // proto package needs to be updated. | |
24 | const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package | |
25 | ||
26 | type HealthCheckResponse_ServingStatus int32 | |
27 | ||
28 | const ( | |
107c1cdb ND |
29 | HealthCheckResponse_UNKNOWN HealthCheckResponse_ServingStatus = 0 |
30 | HealthCheckResponse_SERVING HealthCheckResponse_ServingStatus = 1 | |
31 | HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2 | |
32 | HealthCheckResponse_SERVICE_UNKNOWN HealthCheckResponse_ServingStatus = 3 | |
15c0b25d AP |
33 | ) |
34 | ||
35 | var HealthCheckResponse_ServingStatus_name = map[int32]string{ | |
36 | 0: "UNKNOWN", | |
37 | 1: "SERVING", | |
38 | 2: "NOT_SERVING", | |
107c1cdb | 39 | 3: "SERVICE_UNKNOWN", |
15c0b25d AP |
40 | } |
41 | var HealthCheckResponse_ServingStatus_value = map[string]int32{ | |
107c1cdb ND |
42 | "UNKNOWN": 0, |
43 | "SERVING": 1, | |
44 | "NOT_SERVING": 2, | |
45 | "SERVICE_UNKNOWN": 3, | |
15c0b25d AP |
46 | } |
47 | ||
48 | func (x HealthCheckResponse_ServingStatus) String() string { | |
49 | return proto.EnumName(HealthCheckResponse_ServingStatus_name, int32(x)) | |
50 | } | |
51 | func (HealthCheckResponse_ServingStatus) EnumDescriptor() ([]byte, []int) { | |
107c1cdb | 52 | return fileDescriptor_health_6b1a06aa67f91efd, []int{1, 0} |
15c0b25d AP |
53 | } |
54 | ||
55 | type HealthCheckRequest struct { | |
107c1cdb ND |
56 | Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` |
57 | XXX_NoUnkeyedLiteral struct{} `json:"-"` | |
58 | XXX_unrecognized []byte `json:"-"` | |
59 | XXX_sizecache int32 `json:"-"` | |
60 | } | |
61 | ||
62 | func (m *HealthCheckRequest) Reset() { *m = HealthCheckRequest{} } | |
63 | func (m *HealthCheckRequest) String() string { return proto.CompactTextString(m) } | |
64 | func (*HealthCheckRequest) ProtoMessage() {} | |
65 | func (*HealthCheckRequest) Descriptor() ([]byte, []int) { | |
66 | return fileDescriptor_health_6b1a06aa67f91efd, []int{0} | |
67 | } | |
68 | func (m *HealthCheckRequest) XXX_Unmarshal(b []byte) error { | |
69 | return xxx_messageInfo_HealthCheckRequest.Unmarshal(m, b) | |
70 | } | |
71 | func (m *HealthCheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { | |
72 | return xxx_messageInfo_HealthCheckRequest.Marshal(b, m, deterministic) | |
73 | } | |
74 | func (dst *HealthCheckRequest) XXX_Merge(src proto.Message) { | |
75 | xxx_messageInfo_HealthCheckRequest.Merge(dst, src) | |
76 | } | |
77 | func (m *HealthCheckRequest) XXX_Size() int { | |
78 | return xxx_messageInfo_HealthCheckRequest.Size(m) | |
79 | } | |
80 | func (m *HealthCheckRequest) XXX_DiscardUnknown() { | |
81 | xxx_messageInfo_HealthCheckRequest.DiscardUnknown(m) | |
15c0b25d AP |
82 | } |
83 | ||
107c1cdb ND |
84 | var xxx_messageInfo_HealthCheckRequest proto.InternalMessageInfo |
85 | ||
86 | func (m *HealthCheckRequest) GetService() string { | |
87 | if m != nil { | |
88 | return m.Service | |
89 | } | |
90 | return "" | |
91 | } | |
15c0b25d AP |
92 | |
93 | type HealthCheckResponse struct { | |
107c1cdb ND |
94 | Status HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=grpc.health.v1.HealthCheckResponse_ServingStatus" json:"status,omitempty"` |
95 | XXX_NoUnkeyedLiteral struct{} `json:"-"` | |
96 | XXX_unrecognized []byte `json:"-"` | |
97 | XXX_sizecache int32 `json:"-"` | |
15c0b25d AP |
98 | } |
99 | ||
107c1cdb ND |
100 | func (m *HealthCheckResponse) Reset() { *m = HealthCheckResponse{} } |
101 | func (m *HealthCheckResponse) String() string { return proto.CompactTextString(m) } | |
102 | func (*HealthCheckResponse) ProtoMessage() {} | |
103 | func (*HealthCheckResponse) Descriptor() ([]byte, []int) { | |
104 | return fileDescriptor_health_6b1a06aa67f91efd, []int{1} | |
105 | } | |
106 | func (m *HealthCheckResponse) XXX_Unmarshal(b []byte) error { | |
107 | return xxx_messageInfo_HealthCheckResponse.Unmarshal(m, b) | |
108 | } | |
109 | func (m *HealthCheckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { | |
110 | return xxx_messageInfo_HealthCheckResponse.Marshal(b, m, deterministic) | |
111 | } | |
112 | func (dst *HealthCheckResponse) XXX_Merge(src proto.Message) { | |
113 | xxx_messageInfo_HealthCheckResponse.Merge(dst, src) | |
114 | } | |
115 | func (m *HealthCheckResponse) XXX_Size() int { | |
116 | return xxx_messageInfo_HealthCheckResponse.Size(m) | |
117 | } | |
118 | func (m *HealthCheckResponse) XXX_DiscardUnknown() { | |
119 | xxx_messageInfo_HealthCheckResponse.DiscardUnknown(m) | |
120 | } | |
121 | ||
122 | var xxx_messageInfo_HealthCheckResponse proto.InternalMessageInfo | |
123 | ||
124 | func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus { | |
125 | if m != nil { | |
126 | return m.Status | |
127 | } | |
128 | return HealthCheckResponse_UNKNOWN | |
129 | } | |
15c0b25d AP |
130 | |
131 | func init() { | |
132 | proto.RegisterType((*HealthCheckRequest)(nil), "grpc.health.v1.HealthCheckRequest") | |
133 | proto.RegisterType((*HealthCheckResponse)(nil), "grpc.health.v1.HealthCheckResponse") | |
134 | proto.RegisterEnum("grpc.health.v1.HealthCheckResponse_ServingStatus", HealthCheckResponse_ServingStatus_name, HealthCheckResponse_ServingStatus_value) | |
135 | } | |
136 | ||
137 | // Reference imports to suppress errors if they are not otherwise used. | |
138 | var _ context.Context | |
139 | var _ grpc.ClientConn | |
140 | ||
141 | // This is a compile-time assertion to ensure that this generated file | |
142 | // is compatible with the grpc package it is being compiled against. | |
143 | const _ = grpc.SupportPackageIsVersion4 | |
144 | ||
107c1cdb ND |
145 | // HealthClient is the client API for Health service. |
146 | // | |
147 | // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream. | |
15c0b25d | 148 | type HealthClient interface { |
107c1cdb ND |
149 | // If the requested service is unknown, the call will fail with status |
150 | // NOT_FOUND. | |
15c0b25d | 151 | Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) |
107c1cdb ND |
152 | // Performs a watch for the serving status of the requested service. |
153 | // The server will immediately send back a message indicating the current | |
154 | // serving status. It will then subsequently send a new message whenever | |
155 | // the service's serving status changes. | |
156 | // | |
157 | // If the requested service is unknown when the call is received, the | |
158 | // server will send a message setting the serving status to | |
159 | // SERVICE_UNKNOWN but will *not* terminate the call. If at some | |
160 | // future point, the serving status of the service becomes known, the | |
161 | // server will send a new message with the service's serving status. | |
162 | // | |
163 | // If the call terminates with status UNIMPLEMENTED, then clients | |
164 | // should assume this method is not supported and should not retry the | |
165 | // call. If the call terminates with any other status (including OK), | |
166 | // clients should retry the call with appropriate exponential backoff. | |
167 | Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (Health_WatchClient, error) | |
15c0b25d AP |
168 | } |
169 | ||
170 | type healthClient struct { | |
171 | cc *grpc.ClientConn | |
172 | } | |
173 | ||
174 | func NewHealthClient(cc *grpc.ClientConn) HealthClient { | |
175 | return &healthClient{cc} | |
176 | } | |
177 | ||
178 | func (c *healthClient) Check(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error) { | |
179 | out := new(HealthCheckResponse) | |
107c1cdb | 180 | err := c.cc.Invoke(ctx, "/grpc.health.v1.Health/Check", in, out, opts...) |
15c0b25d AP |
181 | if err != nil { |
182 | return nil, err | |
183 | } | |
184 | return out, nil | |
185 | } | |
186 | ||
107c1cdb ND |
187 | func (c *healthClient) Watch(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (Health_WatchClient, error) { |
188 | stream, err := c.cc.NewStream(ctx, &_Health_serviceDesc.Streams[0], "/grpc.health.v1.Health/Watch", opts...) | |
189 | if err != nil { | |
190 | return nil, err | |
191 | } | |
192 | x := &healthWatchClient{stream} | |
193 | if err := x.ClientStream.SendMsg(in); err != nil { | |
194 | return nil, err | |
195 | } | |
196 | if err := x.ClientStream.CloseSend(); err != nil { | |
197 | return nil, err | |
198 | } | |
199 | return x, nil | |
200 | } | |
201 | ||
202 | type Health_WatchClient interface { | |
203 | Recv() (*HealthCheckResponse, error) | |
204 | grpc.ClientStream | |
205 | } | |
206 | ||
207 | type healthWatchClient struct { | |
208 | grpc.ClientStream | |
209 | } | |
15c0b25d | 210 | |
107c1cdb ND |
211 | func (x *healthWatchClient) Recv() (*HealthCheckResponse, error) { |
212 | m := new(HealthCheckResponse) | |
213 | if err := x.ClientStream.RecvMsg(m); err != nil { | |
214 | return nil, err | |
215 | } | |
216 | return m, nil | |
217 | } | |
218 | ||
219 | // HealthServer is the server API for Health service. | |
15c0b25d | 220 | type HealthServer interface { |
107c1cdb ND |
221 | // If the requested service is unknown, the call will fail with status |
222 | // NOT_FOUND. | |
15c0b25d | 223 | Check(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error) |
107c1cdb ND |
224 | // Performs a watch for the serving status of the requested service. |
225 | // The server will immediately send back a message indicating the current | |
226 | // serving status. It will then subsequently send a new message whenever | |
227 | // the service's serving status changes. | |
228 | // | |
229 | // If the requested service is unknown when the call is received, the | |
230 | // server will send a message setting the serving status to | |
231 | // SERVICE_UNKNOWN but will *not* terminate the call. If at some | |
232 | // future point, the serving status of the service becomes known, the | |
233 | // server will send a new message with the service's serving status. | |
234 | // | |
235 | // If the call terminates with status UNIMPLEMENTED, then clients | |
236 | // should assume this method is not supported and should not retry the | |
237 | // call. If the call terminates with any other status (including OK), | |
238 | // clients should retry the call with appropriate exponential backoff. | |
239 | Watch(*HealthCheckRequest, Health_WatchServer) error | |
15c0b25d AP |
240 | } |
241 | ||
242 | func RegisterHealthServer(s *grpc.Server, srv HealthServer) { | |
243 | s.RegisterService(&_Health_serviceDesc, srv) | |
244 | } | |
245 | ||
246 | func _Health_Check_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { | |
247 | in := new(HealthCheckRequest) | |
248 | if err := dec(in); err != nil { | |
249 | return nil, err | |
250 | } | |
251 | if interceptor == nil { | |
252 | return srv.(HealthServer).Check(ctx, in) | |
253 | } | |
254 | info := &grpc.UnaryServerInfo{ | |
255 | Server: srv, | |
256 | FullMethod: "/grpc.health.v1.Health/Check", | |
257 | } | |
258 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { | |
259 | return srv.(HealthServer).Check(ctx, req.(*HealthCheckRequest)) | |
260 | } | |
261 | return interceptor(ctx, in, info, handler) | |
262 | } | |
263 | ||
107c1cdb ND |
264 | func _Health_Watch_Handler(srv interface{}, stream grpc.ServerStream) error { |
265 | m := new(HealthCheckRequest) | |
266 | if err := stream.RecvMsg(m); err != nil { | |
267 | return err | |
268 | } | |
269 | return srv.(HealthServer).Watch(m, &healthWatchServer{stream}) | |
270 | } | |
271 | ||
272 | type Health_WatchServer interface { | |
273 | Send(*HealthCheckResponse) error | |
274 | grpc.ServerStream | |
275 | } | |
276 | ||
277 | type healthWatchServer struct { | |
278 | grpc.ServerStream | |
279 | } | |
280 | ||
281 | func (x *healthWatchServer) Send(m *HealthCheckResponse) error { | |
282 | return x.ServerStream.SendMsg(m) | |
283 | } | |
284 | ||
15c0b25d AP |
285 | var _Health_serviceDesc = grpc.ServiceDesc{ |
286 | ServiceName: "grpc.health.v1.Health", | |
287 | HandlerType: (*HealthServer)(nil), | |
288 | Methods: []grpc.MethodDesc{ | |
289 | { | |
290 | MethodName: "Check", | |
291 | Handler: _Health_Check_Handler, | |
292 | }, | |
293 | }, | |
107c1cdb ND |
294 | Streams: []grpc.StreamDesc{ |
295 | { | |
296 | StreamName: "Watch", | |
297 | Handler: _Health_Watch_Handler, | |
298 | ServerStreams: true, | |
299 | }, | |
300 | }, | |
301 | Metadata: "grpc/health/v1/health.proto", | |
302 | } | |
303 | ||
304 | func init() { proto.RegisterFile("grpc/health/v1/health.proto", fileDescriptor_health_6b1a06aa67f91efd) } | |
305 | ||
306 | var fileDescriptor_health_6b1a06aa67f91efd = []byte{ | |
307 | // 297 bytes of a gzipped FileDescriptorProto | |
308 | 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x4e, 0x2f, 0x2a, 0x48, | |
309 | 0xd6, 0xcf, 0x48, 0x4d, 0xcc, 0x29, 0xc9, 0xd0, 0x2f, 0x33, 0x84, 0xb2, 0xf4, 0x0a, 0x8a, 0xf2, | |
310 | 0x4b, 0xf2, 0x85, 0xf8, 0x40, 0x92, 0x7a, 0x50, 0xa1, 0x32, 0x43, 0x25, 0x3d, 0x2e, 0x21, 0x0f, | |
311 | 0x30, 0xc7, 0x39, 0x23, 0x35, 0x39, 0x3b, 0x28, 0xb5, 0xb0, 0x34, 0xb5, 0xb8, 0x44, 0x48, 0x82, | |
312 | 0x8b, 0xbd, 0x38, 0xb5, 0xa8, 0x2c, 0x33, 0x39, 0x55, 0x82, 0x51, 0x81, 0x51, 0x83, 0x33, 0x08, | |
313 | 0xc6, 0x55, 0xda, 0xc8, 0xc8, 0x25, 0x8c, 0xa2, 0xa1, 0xb8, 0x20, 0x3f, 0xaf, 0x38, 0x55, 0xc8, | |
314 | 0x93, 0x8b, 0xad, 0xb8, 0x24, 0xb1, 0xa4, 0xb4, 0x18, 0xac, 0x81, 0xcf, 0xc8, 0x50, 0x0f, 0xd5, | |
315 | 0x22, 0x3d, 0x2c, 0x9a, 0xf4, 0x82, 0x41, 0x86, 0xe6, 0xa5, 0x07, 0x83, 0x35, 0x06, 0x41, 0x0d, | |
316 | 0x50, 0xf2, 0xe7, 0xe2, 0x45, 0x91, 0x10, 0xe2, 0xe6, 0x62, 0x0f, 0xf5, 0xf3, 0xf6, 0xf3, 0x0f, | |
317 | 0xf7, 0x13, 0x60, 0x00, 0x71, 0x82, 0x5d, 0x83, 0xc2, 0x3c, 0xfd, 0xdc, 0x05, 0x18, 0x85, 0xf8, | |
318 | 0xb9, 0xb8, 0xfd, 0xfc, 0x43, 0xe2, 0x61, 0x02, 0x4c, 0x42, 0xc2, 0x5c, 0xfc, 0x60, 0x8e, 0xb3, | |
319 | 0x6b, 0x3c, 0x4c, 0x0b, 0xb3, 0xd1, 0x3a, 0x46, 0x2e, 0x36, 0x88, 0xf5, 0x42, 0x01, 0x5c, 0xac, | |
320 | 0x60, 0x27, 0x08, 0x29, 0xe1, 0x75, 0x1f, 0x38, 0x14, 0xa4, 0x94, 0x89, 0xf0, 0x83, 0x50, 0x10, | |
321 | 0x17, 0x6b, 0x78, 0x62, 0x49, 0x72, 0x06, 0xd5, 0x4c, 0x34, 0x60, 0x74, 0x4a, 0xe4, 0x12, 0xcc, | |
322 | 0xcc, 0x47, 0x53, 0xea, 0xc4, 0x0d, 0x51, 0x1b, 0x00, 0x8a, 0xc6, 0x00, 0xc6, 0x28, 0x9d, 0xf4, | |
323 | 0xfc, 0xfc, 0xf4, 0x9c, 0x54, 0xbd, 0xf4, 0xfc, 0x9c, 0xc4, 0xbc, 0x74, 0xbd, 0xfc, 0xa2, 0x74, | |
324 | 0x7d, 0xe4, 0x78, 0x07, 0xb1, 0xe3, 0x21, 0xec, 0xf8, 0x32, 0xc3, 0x55, 0x4c, 0x7c, 0xee, 0x20, | |
325 | 0xd3, 0x20, 0x46, 0xe8, 0x85, 0x19, 0x26, 0xb1, 0x81, 0x93, 0x83, 0x31, 0x20, 0x00, 0x00, 0xff, | |
326 | 0xff, 0x12, 0x7d, 0x96, 0xcb, 0x2d, 0x02, 0x00, 0x00, | |
15c0b25d | 327 | } |