| 241 | } |
| 242 | |
| 243 | func _SlaveGrpcService_Exists_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 244 | in := new(SlaveExistsRequest) |
| 245 | if err := dec(in); err != nil { |
| 246 | return nil, err |
| 247 | } |
| 248 | if interceptor == nil { |
| 249 | return srv.(SlaveGrpcServiceServer).Exists(ctx, in) |
| 250 | } |
| 251 | info := &grpc.UnaryServerInfo{ |
| 252 | Server: srv, |
| 253 | FullMethod: "/cluster.SlaveGrpcService/Exists", |
| 254 | } |
| 255 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 256 | return srv.(SlaveGrpcServiceServer).Exists(ctx, req.(*SlaveExistsRequest)) |
| 257 | } |
| 258 | return interceptor(ctx, in, info, handler) |
| 259 | } |
| 260 | |
| 261 | func _SlaveGrpcService_Expire_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 262 | in := new(SlaveExpireRequest) |