8 #include <grpcpp/impl/codegen/async_stream.h>
9 #include <grpcpp/impl/codegen/async_unary_call.h>
10 #include <grpcpp/impl/codegen/channel_interface.h>
11 #include <grpcpp/impl/codegen/client_unary_call.h>
12 #include <grpcpp/impl/codegen/method_handler_impl.h>
13 #include <grpcpp/impl/codegen/rpc_service_method.h>
14 #include <grpcpp/impl/codegen/service_type.h>
15 #include <grpcpp/impl/codegen/sync_stream.h>
16 namespace etcdserverpb {
19 "/etcdserverpb.KV/Range",
20 "/etcdserverpb.KV/Put",
21 "/etcdserverpb.KV/DeleteRange",
22 "/etcdserverpb.KV/Txn",
23 "/etcdserverpb.KV/Compact",
26 std::unique_ptr< KV::Stub>
KV::NewStub(
const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions&
options) {
28 std::unique_ptr< KV::Stub> stub(
new KV::Stub(channel));
33 : channel_(channel), rpcmethod_Range_(
KV_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
34 , rpcmethod_Put_(
KV_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
35 , rpcmethod_DeleteRange_(
KV_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
36 , rpcmethod_Txn_(
KV_method_names[3], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
37 , rpcmethod_Compact_(
KV_method_names[4], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
41 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Range_, context, request, response);
44 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::RangeResponse>*
KV::Stub::AsyncRangeRaw(::grpc::ClientContext* context, const ::etcdserverpb::RangeRequest& request, ::grpc::CompletionQueue* cq) {
45 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::RangeResponse>::Create(channel_.get(), cq, rpcmethod_Range_, context, request,
true);
48 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::RangeResponse>*
KV::Stub::PrepareAsyncRangeRaw(::grpc::ClientContext* context, const ::etcdserverpb::RangeRequest& request, ::grpc::CompletionQueue* cq) {
49 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::RangeResponse>::Create(channel_.get(), cq, rpcmethod_Range_, context, request,
false);
53 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Put_, context, request, response);
56 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::PutResponse>*
KV::Stub::AsyncPutRaw(::grpc::ClientContext* context, const ::etcdserverpb::PutRequest& request, ::grpc::CompletionQueue* cq) {
57 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::PutResponse>::Create(channel_.get(), cq, rpcmethod_Put_, context, request,
true);
60 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::PutResponse>*
KV::Stub::PrepareAsyncPutRaw(::grpc::ClientContext* context, const ::etcdserverpb::PutRequest& request, ::grpc::CompletionQueue* cq) {
61 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::PutResponse>::Create(channel_.get(), cq, rpcmethod_Put_, context, request,
false);
65 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_DeleteRange_, context, request, response);
68 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::DeleteRangeResponse>*
KV::Stub::AsyncDeleteRangeRaw(::grpc::ClientContext* context, const ::etcdserverpb::DeleteRangeRequest& request, ::grpc::CompletionQueue* cq) {
69 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::DeleteRangeResponse>::Create(channel_.get(), cq, rpcmethod_DeleteRange_, context, request,
true);
72 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::DeleteRangeResponse>*
KV::Stub::PrepareAsyncDeleteRangeRaw(::grpc::ClientContext* context, const ::etcdserverpb::DeleteRangeRequest& request, ::grpc::CompletionQueue* cq) {
73 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::DeleteRangeResponse>::Create(channel_.get(), cq, rpcmethod_DeleteRange_, context, request,
false);
77 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Txn_, context, request, response);
80 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::TxnResponse>*
KV::Stub::AsyncTxnRaw(::grpc::ClientContext* context, const ::etcdserverpb::TxnRequest& request, ::grpc::CompletionQueue* cq) {
81 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::TxnResponse>::Create(channel_.get(), cq, rpcmethod_Txn_, context, request,
true);
84 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::TxnResponse>*
KV::Stub::PrepareAsyncTxnRaw(::grpc::ClientContext* context, const ::etcdserverpb::TxnRequest& request, ::grpc::CompletionQueue* cq) {
85 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::TxnResponse>::Create(channel_.get(), cq, rpcmethod_Txn_, context, request,
false);
89 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Compact_, context, request, response);
92 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::CompactionResponse>*
KV::Stub::AsyncCompactRaw(::grpc::ClientContext* context, const ::etcdserverpb::CompactionRequest& request, ::grpc::CompletionQueue* cq) {
93 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::CompactionResponse>::Create(channel_.get(), cq, rpcmethod_Compact_, context, request,
true);
96 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::CompactionResponse>*
KV::Stub::PrepareAsyncCompactRaw(::grpc::ClientContext* context, const ::etcdserverpb::CompactionRequest& request, ::grpc::CompletionQueue* cq) {
97 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::CompactionResponse>::Create(channel_.get(), cq, rpcmethod_Compact_, context, request,
false);
101 AddMethod(new ::grpc::internal::RpcServiceMethod(
103 ::grpc::internal::RpcMethod::NORMAL_RPC,
104 new ::grpc::internal::RpcMethodHandler< KV::Service, ::etcdserverpb::RangeRequest, ::etcdserverpb::RangeResponse>(
106 AddMethod(new ::grpc::internal::RpcServiceMethod(
108 ::grpc::internal::RpcMethod::NORMAL_RPC,
109 new ::grpc::internal::RpcMethodHandler< KV::Service, ::etcdserverpb::PutRequest, ::etcdserverpb::PutResponse>(
111 AddMethod(new ::grpc::internal::RpcServiceMethod(
113 ::grpc::internal::RpcMethod::NORMAL_RPC,
114 new ::grpc::internal::RpcMethodHandler< KV::Service, ::etcdserverpb::DeleteRangeRequest, ::etcdserverpb::DeleteRangeResponse>(
116 AddMethod(new ::grpc::internal::RpcServiceMethod(
118 ::grpc::internal::RpcMethod::NORMAL_RPC,
119 new ::grpc::internal::RpcMethodHandler< KV::Service, ::etcdserverpb::TxnRequest, ::etcdserverpb::TxnResponse>(
121 AddMethod(new ::grpc::internal::RpcServiceMethod(
123 ::grpc::internal::RpcMethod::NORMAL_RPC,
124 new ::grpc::internal::RpcMethodHandler< KV::Service, ::etcdserverpb::CompactionRequest, ::etcdserverpb::CompactionResponse>(
135 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
142 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
149 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
156 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
163 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
168 "/etcdserverpb.Watch/Watch",
171 std::unique_ptr< Watch::Stub>
Watch::NewStub(
const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions&
options) {
173 std::unique_ptr< Watch::Stub> stub(
new Watch::Stub(channel));
178 : channel_(channel), rpcmethod_Watch_(
Watch_method_names[0], ::grpc::internal::RpcMethod::BIDI_STREAMING, channel)
181 ::grpc::ClientReaderWriter< ::etcdserverpb::WatchRequest, ::etcdserverpb::WatchResponse>*
Watch::Stub::WatchRaw(::grpc::ClientContext* context) {
182 return ::grpc::internal::ClientReaderWriterFactory< ::etcdserverpb::WatchRequest, ::etcdserverpb::WatchResponse>::Create(channel_.get(), rpcmethod_Watch_, context);
185 ::grpc::ClientAsyncReaderWriter< ::etcdserverpb::WatchRequest, ::etcdserverpb::WatchResponse>*
Watch::Stub::AsyncWatchRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq,
void* tag) {
186 return ::grpc::internal::ClientAsyncReaderWriterFactory< ::etcdserverpb::WatchRequest, ::etcdserverpb::WatchResponse>::Create(channel_.get(), cq, rpcmethod_Watch_, context,
true, tag);
189 ::grpc::ClientAsyncReaderWriter< ::etcdserverpb::WatchRequest, ::etcdserverpb::WatchResponse>*
Watch::Stub::PrepareAsyncWatchRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
190 return ::grpc::internal::ClientAsyncReaderWriterFactory< ::etcdserverpb::WatchRequest, ::etcdserverpb::WatchResponse>::Create(channel_.get(), cq, rpcmethod_Watch_, context,
false,
nullptr);
194 AddMethod(new ::grpc::internal::RpcServiceMethod(
196 ::grpc::internal::RpcMethod::BIDI_STREAMING,
197 new ::grpc::internal::BidiStreamingHandler< Watch::Service, ::etcdserverpb::WatchRequest, ::etcdserverpb::WatchResponse>(
204 ::grpc::Status
Watch::Service::Watch(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::etcdserverpb::WatchResponse, ::etcdserverpb::WatchRequest>* stream) {
207 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
212 "/etcdserverpb.Lease/LeaseGrant",
213 "/etcdserverpb.Lease/LeaseRevoke",
214 "/etcdserverpb.Lease/LeaseKeepAlive",
217 std::unique_ptr< Lease::Stub>
Lease::NewStub(
const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions&
options) {
219 std::unique_ptr< Lease::Stub> stub(
new Lease::Stub(channel));
224 : channel_(channel), rpcmethod_LeaseGrant_(
Lease_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
225 , rpcmethod_LeaseRevoke_(
Lease_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
226 , rpcmethod_LeaseKeepAlive_(
Lease_method_names[2], ::grpc::internal::RpcMethod::BIDI_STREAMING, channel)
230 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_LeaseGrant_, context, request, response);
233 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseGrantResponse>*
Lease::Stub::AsyncLeaseGrantRaw(::grpc::ClientContext* context, const ::etcdserverpb::LeaseGrantRequest& request, ::grpc::CompletionQueue* cq) {
234 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::LeaseGrantResponse>::Create(channel_.get(), cq, rpcmethod_LeaseGrant_, context, request,
true);
237 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseGrantResponse>*
Lease::Stub::PrepareAsyncLeaseGrantRaw(::grpc::ClientContext* context, const ::etcdserverpb::LeaseGrantRequest& request, ::grpc::CompletionQueue* cq) {
238 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::LeaseGrantResponse>::Create(channel_.get(), cq, rpcmethod_LeaseGrant_, context, request,
false);
242 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_LeaseRevoke_, context, request, response);
245 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseRevokeResponse>*
Lease::Stub::AsyncLeaseRevokeRaw(::grpc::ClientContext* context, const ::etcdserverpb::LeaseRevokeRequest& request, ::grpc::CompletionQueue* cq) {
246 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::LeaseRevokeResponse>::Create(channel_.get(), cq, rpcmethod_LeaseRevoke_, context, request,
true);
249 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseRevokeResponse>*
Lease::Stub::PrepareAsyncLeaseRevokeRaw(::grpc::ClientContext* context, const ::etcdserverpb::LeaseRevokeRequest& request, ::grpc::CompletionQueue* cq) {
250 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::LeaseRevokeResponse>::Create(channel_.get(), cq, rpcmethod_LeaseRevoke_, context, request,
false);
253 ::grpc::ClientReaderWriter< ::etcdserverpb::LeaseKeepAliveRequest, ::etcdserverpb::LeaseKeepAliveResponse>*
Lease::Stub::LeaseKeepAliveRaw(::grpc::ClientContext* context) {
254 return ::grpc::internal::ClientReaderWriterFactory< ::etcdserverpb::LeaseKeepAliveRequest, ::etcdserverpb::LeaseKeepAliveResponse>::Create(channel_.get(), rpcmethod_LeaseKeepAlive_, context);
257 ::grpc::ClientAsyncReaderWriter< ::etcdserverpb::LeaseKeepAliveRequest, ::etcdserverpb::LeaseKeepAliveResponse>*
Lease::Stub::AsyncLeaseKeepAliveRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq,
void* tag) {
258 return ::grpc::internal::ClientAsyncReaderWriterFactory< ::etcdserverpb::LeaseKeepAliveRequest, ::etcdserverpb::LeaseKeepAliveResponse>::Create(channel_.get(), cq, rpcmethod_LeaseKeepAlive_, context,
true, tag);
262 return ::grpc::internal::ClientAsyncReaderWriterFactory< ::etcdserverpb::LeaseKeepAliveRequest, ::etcdserverpb::LeaseKeepAliveResponse>::Create(channel_.get(), cq, rpcmethod_LeaseKeepAlive_, context,
false,
nullptr);
266 AddMethod(new ::grpc::internal::RpcServiceMethod(
268 ::grpc::internal::RpcMethod::NORMAL_RPC,
269 new ::grpc::internal::RpcMethodHandler< Lease::Service, ::etcdserverpb::LeaseGrantRequest, ::etcdserverpb::LeaseGrantResponse>(
271 AddMethod(new ::grpc::internal::RpcServiceMethod(
273 ::grpc::internal::RpcMethod::NORMAL_RPC,
274 new ::grpc::internal::RpcMethodHandler< Lease::Service, ::etcdserverpb::LeaseRevokeRequest, ::etcdserverpb::LeaseRevokeResponse>(
276 AddMethod(new ::grpc::internal::RpcServiceMethod(
278 ::grpc::internal::RpcMethod::BIDI_STREAMING,
279 new ::grpc::internal::BidiStreamingHandler< Lease::Service, ::etcdserverpb::LeaseKeepAliveRequest, ::etcdserverpb::LeaseKeepAliveResponse>(
290 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
297 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
300 ::grpc::Status
Lease::Service::LeaseKeepAlive(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::etcdserverpb::LeaseKeepAliveResponse, ::etcdserverpb::LeaseKeepAliveRequest>* stream) {
303 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
308 "/etcdserverpb.Cluster/MemberAdd",
309 "/etcdserverpb.Cluster/MemberRemove",
310 "/etcdserverpb.Cluster/MemberUpdate",
311 "/etcdserverpb.Cluster/MemberList",
314 std::unique_ptr< Cluster::Stub>
Cluster::NewStub(
const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions&
options) {
316 std::unique_ptr< Cluster::Stub> stub(
new Cluster::Stub(channel));
321 : channel_(channel), rpcmethod_MemberAdd_(
Cluster_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
322 , rpcmethod_MemberRemove_(
Cluster_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
323 , rpcmethod_MemberUpdate_(
Cluster_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
324 , rpcmethod_MemberList_(
Cluster_method_names[3], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
328 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_MemberAdd_, context, request, response);
331 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberAddResponse>*
Cluster::Stub::AsyncMemberAddRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberAddRequest& request, ::grpc::CompletionQueue* cq) {
332 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberAddResponse>::Create(channel_.get(), cq, rpcmethod_MemberAdd_, context, request,
true);
335 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberAddResponse>*
Cluster::Stub::PrepareAsyncMemberAddRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberAddRequest& request, ::grpc::CompletionQueue* cq) {
336 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberAddResponse>::Create(channel_.get(), cq, rpcmethod_MemberAdd_, context, request,
false);
340 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_MemberRemove_, context, request, response);
343 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberRemoveResponse>*
Cluster::Stub::AsyncMemberRemoveRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberRemoveRequest& request, ::grpc::CompletionQueue* cq) {
344 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberRemoveResponse>::Create(channel_.get(), cq, rpcmethod_MemberRemove_, context, request,
true);
347 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberRemoveResponse>*
Cluster::Stub::PrepareAsyncMemberRemoveRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberRemoveRequest& request, ::grpc::CompletionQueue* cq) {
348 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberRemoveResponse>::Create(channel_.get(), cq, rpcmethod_MemberRemove_, context, request,
false);
352 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_MemberUpdate_, context, request, response);
355 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberUpdateResponse>*
Cluster::Stub::AsyncMemberUpdateRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberUpdateRequest& request, ::grpc::CompletionQueue* cq) {
356 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberUpdateResponse>::Create(channel_.get(), cq, rpcmethod_MemberUpdate_, context, request,
true);
359 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberUpdateResponse>*
Cluster::Stub::PrepareAsyncMemberUpdateRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberUpdateRequest& request, ::grpc::CompletionQueue* cq) {
360 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberUpdateResponse>::Create(channel_.get(), cq, rpcmethod_MemberUpdate_, context, request,
false);
364 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_MemberList_, context, request, response);
367 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberListResponse>*
Cluster::Stub::AsyncMemberListRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberListRequest& request, ::grpc::CompletionQueue* cq) {
368 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberListResponse>::Create(channel_.get(), cq, rpcmethod_MemberList_, context, request,
true);
371 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberListResponse>*
Cluster::Stub::PrepareAsyncMemberListRaw(::grpc::ClientContext* context, const ::etcdserverpb::MemberListRequest& request, ::grpc::CompletionQueue* cq) {
372 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::MemberListResponse>::Create(channel_.get(), cq, rpcmethod_MemberList_, context, request,
false);
376 AddMethod(new ::grpc::internal::RpcServiceMethod(
378 ::grpc::internal::RpcMethod::NORMAL_RPC,
379 new ::grpc::internal::RpcMethodHandler< Cluster::Service, ::etcdserverpb::MemberAddRequest, ::etcdserverpb::MemberAddResponse>(
381 AddMethod(new ::grpc::internal::RpcServiceMethod(
383 ::grpc::internal::RpcMethod::NORMAL_RPC,
384 new ::grpc::internal::RpcMethodHandler< Cluster::Service, ::etcdserverpb::MemberRemoveRequest, ::etcdserverpb::MemberRemoveResponse>(
386 AddMethod(new ::grpc::internal::RpcServiceMethod(
388 ::grpc::internal::RpcMethod::NORMAL_RPC,
389 new ::grpc::internal::RpcMethodHandler< Cluster::Service, ::etcdserverpb::MemberUpdateRequest, ::etcdserverpb::MemberUpdateResponse>(
391 AddMethod(new ::grpc::internal::RpcServiceMethod(
393 ::grpc::internal::RpcMethod::NORMAL_RPC,
394 new ::grpc::internal::RpcMethodHandler< Cluster::Service, ::etcdserverpb::MemberListRequest, ::etcdserverpb::MemberListResponse>(
405 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
412 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
419 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
426 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
431 "/etcdserverpb.Maintenance/Alarm",
432 "/etcdserverpb.Maintenance/Status",
433 "/etcdserverpb.Maintenance/Defragment",
434 "/etcdserverpb.Maintenance/Hash",
435 "/etcdserverpb.Maintenance/Snapshot",
438 std::unique_ptr< Maintenance::Stub>
Maintenance::NewStub(
const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions&
options) {
445 : channel_(channel), rpcmethod_Alarm_(
Maintenance_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
453 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Alarm_, context, request, response);
456 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AlarmResponse>*
Maintenance::Stub::AsyncAlarmRaw(::grpc::ClientContext* context, const ::etcdserverpb::AlarmRequest& request, ::grpc::CompletionQueue* cq) {
457 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AlarmResponse>::Create(channel_.get(), cq, rpcmethod_Alarm_, context, request,
true);
460 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AlarmResponse>*
Maintenance::Stub::PrepareAsyncAlarmRaw(::grpc::ClientContext* context, const ::etcdserverpb::AlarmRequest& request, ::grpc::CompletionQueue* cq) {
461 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AlarmResponse>::Create(channel_.get(), cq, rpcmethod_Alarm_, context, request,
false);
465 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Status_, context, request, response);
468 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::StatusResponse>*
Maintenance::Stub::AsyncStatusRaw(::grpc::ClientContext* context, const ::etcdserverpb::StatusRequest& request, ::grpc::CompletionQueue* cq) {
469 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::StatusResponse>::Create(channel_.get(), cq, rpcmethod_Status_, context, request,
true);
472 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::StatusResponse>*
Maintenance::Stub::PrepareAsyncStatusRaw(::grpc::ClientContext* context, const ::etcdserverpb::StatusRequest& request, ::grpc::CompletionQueue* cq) {
473 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::StatusResponse>::Create(channel_.get(), cq, rpcmethod_Status_, context, request,
false);
477 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Defragment_, context, request, response);
480 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::DefragmentResponse>*
Maintenance::Stub::AsyncDefragmentRaw(::grpc::ClientContext* context, const ::etcdserverpb::DefragmentRequest& request, ::grpc::CompletionQueue* cq) {
481 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::DefragmentResponse>::Create(channel_.get(), cq, rpcmethod_Defragment_, context, request,
true);
485 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::DefragmentResponse>::Create(channel_.get(), cq, rpcmethod_Defragment_, context, request,
false);
489 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Hash_, context, request, response);
492 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::HashResponse>*
Maintenance::Stub::AsyncHashRaw(::grpc::ClientContext* context, const ::etcdserverpb::HashRequest& request, ::grpc::CompletionQueue* cq) {
493 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::HashResponse>::Create(channel_.get(), cq, rpcmethod_Hash_, context, request,
true);
496 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::HashResponse>*
Maintenance::Stub::PrepareAsyncHashRaw(::grpc::ClientContext* context, const ::etcdserverpb::HashRequest& request, ::grpc::CompletionQueue* cq) {
497 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::HashResponse>::Create(channel_.get(), cq, rpcmethod_Hash_, context, request,
false);
500 ::grpc::ClientReader< ::etcdserverpb::SnapshotResponse>*
Maintenance::Stub::SnapshotRaw(::grpc::ClientContext* context, const ::etcdserverpb::SnapshotRequest& request) {
501 return ::grpc::internal::ClientReaderFactory< ::etcdserverpb::SnapshotResponse>::Create(channel_.get(), rpcmethod_Snapshot_, context, request);
504 ::grpc::ClientAsyncReader< ::etcdserverpb::SnapshotResponse>*
Maintenance::Stub::AsyncSnapshotRaw(::grpc::ClientContext* context, const ::etcdserverpb::SnapshotRequest& request, ::grpc::CompletionQueue* cq,
void* tag) {
505 return ::grpc::internal::ClientAsyncReaderFactory< ::etcdserverpb::SnapshotResponse>::Create(channel_.get(), cq, rpcmethod_Snapshot_, context, request,
true, tag);
509 return ::grpc::internal::ClientAsyncReaderFactory< ::etcdserverpb::SnapshotResponse>::Create(channel_.get(), cq, rpcmethod_Snapshot_, context, request,
false,
nullptr);
513 AddMethod(new ::grpc::internal::RpcServiceMethod(
515 ::grpc::internal::RpcMethod::NORMAL_RPC,
516 new ::grpc::internal::RpcMethodHandler< Maintenance::Service, ::etcdserverpb::AlarmRequest, ::etcdserverpb::AlarmResponse>(
518 AddMethod(new ::grpc::internal::RpcServiceMethod(
520 ::grpc::internal::RpcMethod::NORMAL_RPC,
521 new ::grpc::internal::RpcMethodHandler< Maintenance::Service, ::etcdserverpb::StatusRequest, ::etcdserverpb::StatusResponse>(
523 AddMethod(new ::grpc::internal::RpcServiceMethod(
525 ::grpc::internal::RpcMethod::NORMAL_RPC,
526 new ::grpc::internal::RpcMethodHandler< Maintenance::Service, ::etcdserverpb::DefragmentRequest, ::etcdserverpb::DefragmentResponse>(
528 AddMethod(new ::grpc::internal::RpcServiceMethod(
530 ::grpc::internal::RpcMethod::NORMAL_RPC,
531 new ::grpc::internal::RpcMethodHandler< Maintenance::Service, ::etcdserverpb::HashRequest, ::etcdserverpb::HashResponse>(
533 AddMethod(new ::grpc::internal::RpcServiceMethod(
535 ::grpc::internal::RpcMethod::SERVER_STREAMING,
536 new ::grpc::internal::ServerStreamingHandler< Maintenance::Service, ::etcdserverpb::SnapshotRequest, ::etcdserverpb::SnapshotResponse>(
547 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
554 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
561 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
568 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
571 ::grpc::Status
Maintenance::Service::Snapshot(::grpc::ServerContext* context, const ::etcdserverpb::SnapshotRequest* request, ::grpc::ServerWriter< ::etcdserverpb::SnapshotResponse>* writer) {
575 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
580 "/etcdserverpb.Auth/AuthEnable",
581 "/etcdserverpb.Auth/AuthDisable",
582 "/etcdserverpb.Auth/Authenticate",
583 "/etcdserverpb.Auth/UserAdd",
584 "/etcdserverpb.Auth/UserGet",
585 "/etcdserverpb.Auth/UserList",
586 "/etcdserverpb.Auth/UserDelete",
587 "/etcdserverpb.Auth/UserChangePassword",
588 "/etcdserverpb.Auth/UserGrantRole",
589 "/etcdserverpb.Auth/UserRevokeRole",
590 "/etcdserverpb.Auth/RoleAdd",
591 "/etcdserverpb.Auth/RoleGet",
592 "/etcdserverpb.Auth/RoleList",
593 "/etcdserverpb.Auth/RoleDelete",
594 "/etcdserverpb.Auth/RoleGrantPermission",
595 "/etcdserverpb.Auth/RoleRevokePermission",
598 std::unique_ptr< Auth::Stub>
Auth::NewStub(
const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions&
options) {
600 std::unique_ptr< Auth::Stub> stub(
new Auth::Stub(channel));
605 : channel_(channel), rpcmethod_AuthEnable_(
Auth_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
606 , rpcmethod_AuthDisable_(
Auth_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
607 , rpcmethod_Authenticate_(
Auth_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
608 , rpcmethod_UserAdd_(
Auth_method_names[3], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
609 , rpcmethod_UserGet_(
Auth_method_names[4], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
610 , rpcmethod_UserList_(
Auth_method_names[5], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
611 , rpcmethod_UserDelete_(
Auth_method_names[6], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
612 , rpcmethod_UserChangePassword_(
Auth_method_names[7], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
613 , rpcmethod_UserGrantRole_(
Auth_method_names[8], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
614 , rpcmethod_UserRevokeRole_(
Auth_method_names[9], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
615 , rpcmethod_RoleAdd_(
Auth_method_names[10], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
616 , rpcmethod_RoleGet_(
Auth_method_names[11], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
617 , rpcmethod_RoleList_(
Auth_method_names[12], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
618 , rpcmethod_RoleDelete_(
Auth_method_names[13], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
619 , rpcmethod_RoleGrantPermission_(
Auth_method_names[14], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
620 , rpcmethod_RoleRevokePermission_(
Auth_method_names[15], ::grpc::internal::RpcMethod::NORMAL_RPC, channel)
624 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_AuthEnable_, context, request, response);
627 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthEnableResponse>*
Auth::Stub::AsyncAuthEnableRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthEnableRequest& request, ::grpc::CompletionQueue* cq) {
628 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthEnableResponse>::Create(channel_.get(), cq, rpcmethod_AuthEnable_, context, request,
true);
631 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthEnableResponse>*
Auth::Stub::PrepareAsyncAuthEnableRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthEnableRequest& request, ::grpc::CompletionQueue* cq) {
632 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthEnableResponse>::Create(channel_.get(), cq, rpcmethod_AuthEnable_, context, request,
false);
636 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_AuthDisable_, context, request, response);
639 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthDisableResponse>*
Auth::Stub::AsyncAuthDisableRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthDisableRequest& request, ::grpc::CompletionQueue* cq) {
640 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthDisableResponse>::Create(channel_.get(), cq, rpcmethod_AuthDisable_, context, request,
true);
643 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthDisableResponse>*
Auth::Stub::PrepareAsyncAuthDisableRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthDisableRequest& request, ::grpc::CompletionQueue* cq) {
644 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthDisableResponse>::Create(channel_.get(), cq, rpcmethod_AuthDisable_, context, request,
false);
648 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Authenticate_, context, request, response);
651 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthenticateResponse>*
Auth::Stub::AsyncAuthenticateRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthenticateRequest& request, ::grpc::CompletionQueue* cq) {
652 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthenticateResponse>::Create(channel_.get(), cq, rpcmethod_Authenticate_, context, request,
true);
655 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthenticateResponse>*
Auth::Stub::PrepareAsyncAuthenticateRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthenticateRequest& request, ::grpc::CompletionQueue* cq) {
656 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthenticateResponse>::Create(channel_.get(), cq, rpcmethod_Authenticate_, context, request,
false);
660 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UserAdd_, context, request, response);
663 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserAddResponse>*
Auth::Stub::AsyncUserAddRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserAddRequest& request, ::grpc::CompletionQueue* cq) {
664 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserAddResponse>::Create(channel_.get(), cq, rpcmethod_UserAdd_, context, request,
true);
667 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserAddResponse>*
Auth::Stub::PrepareAsyncUserAddRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserAddRequest& request, ::grpc::CompletionQueue* cq) {
668 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserAddResponse>::Create(channel_.get(), cq, rpcmethod_UserAdd_, context, request,
false);
672 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UserGet_, context, request, response);
675 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGetResponse>*
Auth::Stub::AsyncUserGetRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserGetRequest& request, ::grpc::CompletionQueue* cq) {
676 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserGetResponse>::Create(channel_.get(), cq, rpcmethod_UserGet_, context, request,
true);
679 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGetResponse>*
Auth::Stub::PrepareAsyncUserGetRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserGetRequest& request, ::grpc::CompletionQueue* cq) {
680 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserGetResponse>::Create(channel_.get(), cq, rpcmethod_UserGet_, context, request,
false);
684 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UserList_, context, request, response);
687 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserListResponse>*
Auth::Stub::AsyncUserListRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserListRequest& request, ::grpc::CompletionQueue* cq) {
688 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserListResponse>::Create(channel_.get(), cq, rpcmethod_UserList_, context, request,
true);
691 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserListResponse>*
Auth::Stub::PrepareAsyncUserListRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserListRequest& request, ::grpc::CompletionQueue* cq) {
692 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserListResponse>::Create(channel_.get(), cq, rpcmethod_UserList_, context, request,
false);
696 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UserDelete_, context, request, response);
699 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserDeleteResponse>*
Auth::Stub::AsyncUserDeleteRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserDeleteRequest& request, ::grpc::CompletionQueue* cq) {
700 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserDeleteResponse>::Create(channel_.get(), cq, rpcmethod_UserDelete_, context, request,
true);
703 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserDeleteResponse>*
Auth::Stub::PrepareAsyncUserDeleteRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserDeleteRequest& request, ::grpc::CompletionQueue* cq) {
704 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserDeleteResponse>::Create(channel_.get(), cq, rpcmethod_UserDelete_, context, request,
false);
708 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UserChangePassword_, context, request, response);
711 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserChangePasswordResponse>*
Auth::Stub::AsyncUserChangePasswordRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserChangePasswordRequest& request, ::grpc::CompletionQueue* cq) {
712 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserChangePasswordResponse>::Create(channel_.get(), cq, rpcmethod_UserChangePassword_, context, request,
true);
715 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserChangePasswordResponse>*
Auth::Stub::PrepareAsyncUserChangePasswordRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserChangePasswordRequest& request, ::grpc::CompletionQueue* cq) {
716 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserChangePasswordResponse>::Create(channel_.get(), cq, rpcmethod_UserChangePassword_, context, request,
false);
720 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UserGrantRole_, context, request, response);
723 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGrantRoleResponse>*
Auth::Stub::AsyncUserGrantRoleRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserGrantRoleRequest& request, ::grpc::CompletionQueue* cq) {
724 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserGrantRoleResponse>::Create(channel_.get(), cq, rpcmethod_UserGrantRole_, context, request,
true);
727 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGrantRoleResponse>*
Auth::Stub::PrepareAsyncUserGrantRoleRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserGrantRoleRequest& request, ::grpc::CompletionQueue* cq) {
728 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserGrantRoleResponse>::Create(channel_.get(), cq, rpcmethod_UserGrantRole_, context, request,
false);
732 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_UserRevokeRole_, context, request, response);
735 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserRevokeRoleResponse>*
Auth::Stub::AsyncUserRevokeRoleRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserRevokeRoleRequest& request, ::grpc::CompletionQueue* cq) {
736 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserRevokeRoleResponse>::Create(channel_.get(), cq, rpcmethod_UserRevokeRole_, context, request,
true);
739 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserRevokeRoleResponse>*
Auth::Stub::PrepareAsyncUserRevokeRoleRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthUserRevokeRoleRequest& request, ::grpc::CompletionQueue* cq) {
740 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthUserRevokeRoleResponse>::Create(channel_.get(), cq, rpcmethod_UserRevokeRole_, context, request,
false);
744 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RoleAdd_, context, request, response);
747 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleAddResponse>*
Auth::Stub::AsyncRoleAddRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleAddRequest& request, ::grpc::CompletionQueue* cq) {
748 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleAddResponse>::Create(channel_.get(), cq, rpcmethod_RoleAdd_, context, request,
true);
751 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleAddResponse>*
Auth::Stub::PrepareAsyncRoleAddRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleAddRequest& request, ::grpc::CompletionQueue* cq) {
752 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleAddResponse>::Create(channel_.get(), cq, rpcmethod_RoleAdd_, context, request,
false);
756 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RoleGet_, context, request, response);
759 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGetResponse>*
Auth::Stub::AsyncRoleGetRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleGetRequest& request, ::grpc::CompletionQueue* cq) {
760 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleGetResponse>::Create(channel_.get(), cq, rpcmethod_RoleGet_, context, request,
true);
763 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGetResponse>*
Auth::Stub::PrepareAsyncRoleGetRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleGetRequest& request, ::grpc::CompletionQueue* cq) {
764 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleGetResponse>::Create(channel_.get(), cq, rpcmethod_RoleGet_, context, request,
false);
768 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RoleList_, context, request, response);
771 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleListResponse>*
Auth::Stub::AsyncRoleListRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleListRequest& request, ::grpc::CompletionQueue* cq) {
772 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleListResponse>::Create(channel_.get(), cq, rpcmethod_RoleList_, context, request,
true);
775 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleListResponse>*
Auth::Stub::PrepareAsyncRoleListRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleListRequest& request, ::grpc::CompletionQueue* cq) {
776 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleListResponse>::Create(channel_.get(), cq, rpcmethod_RoleList_, context, request,
false);
780 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RoleDelete_, context, request, response);
783 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleDeleteResponse>*
Auth::Stub::AsyncRoleDeleteRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleDeleteRequest& request, ::grpc::CompletionQueue* cq) {
784 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleDeleteResponse>::Create(channel_.get(), cq, rpcmethod_RoleDelete_, context, request,
true);
787 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleDeleteResponse>*
Auth::Stub::PrepareAsyncRoleDeleteRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleDeleteRequest& request, ::grpc::CompletionQueue* cq) {
788 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleDeleteResponse>::Create(channel_.get(), cq, rpcmethod_RoleDelete_, context, request,
false);
792 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RoleGrantPermission_, context, request, response);
795 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGrantPermissionResponse>*
Auth::Stub::AsyncRoleGrantPermissionRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleGrantPermissionRequest& request, ::grpc::CompletionQueue* cq) {
796 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleGrantPermissionResponse>::Create(channel_.get(), cq, rpcmethod_RoleGrantPermission_, context, request,
true);
799 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGrantPermissionResponse>*
Auth::Stub::PrepareAsyncRoleGrantPermissionRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleGrantPermissionRequest& request, ::grpc::CompletionQueue* cq) {
800 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleGrantPermissionResponse>::Create(channel_.get(), cq, rpcmethod_RoleGrantPermission_, context, request,
false);
804 return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_RoleRevokePermission_, context, request, response);
807 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleRevokePermissionResponse>*
Auth::Stub::AsyncRoleRevokePermissionRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleRevokePermissionRequest& request, ::grpc::CompletionQueue* cq) {
808 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleRevokePermissionResponse>::Create(channel_.get(), cq, rpcmethod_RoleRevokePermission_, context, request,
true);
811 ::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleRevokePermissionResponse>*
Auth::Stub::PrepareAsyncRoleRevokePermissionRaw(::grpc::ClientContext* context, const ::etcdserverpb::AuthRoleRevokePermissionRequest& request, ::grpc::CompletionQueue* cq) {
812 return ::grpc::internal::ClientAsyncResponseReaderFactory< ::etcdserverpb::AuthRoleRevokePermissionResponse>::Create(channel_.get(), cq, rpcmethod_RoleRevokePermission_, context, request,
false);
816 AddMethod(new ::grpc::internal::RpcServiceMethod(
818 ::grpc::internal::RpcMethod::NORMAL_RPC,
819 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthEnableRequest, ::etcdserverpb::AuthEnableResponse>(
821 AddMethod(new ::grpc::internal::RpcServiceMethod(
823 ::grpc::internal::RpcMethod::NORMAL_RPC,
824 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthDisableRequest, ::etcdserverpb::AuthDisableResponse>(
826 AddMethod(new ::grpc::internal::RpcServiceMethod(
828 ::grpc::internal::RpcMethod::NORMAL_RPC,
829 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthenticateRequest, ::etcdserverpb::AuthenticateResponse>(
831 AddMethod(new ::grpc::internal::RpcServiceMethod(
833 ::grpc::internal::RpcMethod::NORMAL_RPC,
834 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthUserAddRequest, ::etcdserverpb::AuthUserAddResponse>(
836 AddMethod(new ::grpc::internal::RpcServiceMethod(
838 ::grpc::internal::RpcMethod::NORMAL_RPC,
839 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthUserGetRequest, ::etcdserverpb::AuthUserGetResponse>(
841 AddMethod(new ::grpc::internal::RpcServiceMethod(
843 ::grpc::internal::RpcMethod::NORMAL_RPC,
844 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthUserListRequest, ::etcdserverpb::AuthUserListResponse>(
846 AddMethod(new ::grpc::internal::RpcServiceMethod(
848 ::grpc::internal::RpcMethod::NORMAL_RPC,
849 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthUserDeleteRequest, ::etcdserverpb::AuthUserDeleteResponse>(
851 AddMethod(new ::grpc::internal::RpcServiceMethod(
853 ::grpc::internal::RpcMethod::NORMAL_RPC,
854 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthUserChangePasswordRequest, ::etcdserverpb::AuthUserChangePasswordResponse>(
856 AddMethod(new ::grpc::internal::RpcServiceMethod(
858 ::grpc::internal::RpcMethod::NORMAL_RPC,
859 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthUserGrantRoleRequest, ::etcdserverpb::AuthUserGrantRoleResponse>(
861 AddMethod(new ::grpc::internal::RpcServiceMethod(
863 ::grpc::internal::RpcMethod::NORMAL_RPC,
864 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthUserRevokeRoleRequest, ::etcdserverpb::AuthUserRevokeRoleResponse>(
866 AddMethod(new ::grpc::internal::RpcServiceMethod(
868 ::grpc::internal::RpcMethod::NORMAL_RPC,
869 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthRoleAddRequest, ::etcdserverpb::AuthRoleAddResponse>(
871 AddMethod(new ::grpc::internal::RpcServiceMethod(
873 ::grpc::internal::RpcMethod::NORMAL_RPC,
874 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthRoleGetRequest, ::etcdserverpb::AuthRoleGetResponse>(
876 AddMethod(new ::grpc::internal::RpcServiceMethod(
878 ::grpc::internal::RpcMethod::NORMAL_RPC,
879 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthRoleListRequest, ::etcdserverpb::AuthRoleListResponse>(
881 AddMethod(new ::grpc::internal::RpcServiceMethod(
883 ::grpc::internal::RpcMethod::NORMAL_RPC,
884 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthRoleDeleteRequest, ::etcdserverpb::AuthRoleDeleteResponse>(
886 AddMethod(new ::grpc::internal::RpcServiceMethod(
888 ::grpc::internal::RpcMethod::NORMAL_RPC,
889 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthRoleGrantPermissionRequest, ::etcdserverpb::AuthRoleGrantPermissionResponse>(
891 AddMethod(new ::grpc::internal::RpcServiceMethod(
893 ::grpc::internal::RpcMethod::NORMAL_RPC,
894 new ::grpc::internal::RpcMethodHandler< Auth::Service, ::etcdserverpb::AuthRoleRevokePermissionRequest, ::etcdserverpb::AuthRoleRevokePermissionResponse>(
905 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
912 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
919 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
926 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
933 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
940 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
947 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
954 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
961 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
968 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
975 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
982 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
989 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
996 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
1003 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
1010 return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED,
"");
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberAddResponse > * PrepareAsyncMemberAddRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberAddRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status Put(::grpc::ServerContext *context, const ::etcdserverpb::PutRequest *request,::etcdserverpb::PutResponse *response)
static std::unique_ptr< Stub > NewStub(const std::shared_ptr< ::grpc::ChannelInterface > &channel, const ::grpc::StubOptions &options=::grpc::StubOptions())
::grpc::ClientAsyncResponseReader< ::etcdserverpb::PutResponse > * AsyncPutRaw(::grpc::ClientContext *context, const ::etcdserverpb::PutRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseRevokeResponse > * PrepareAsyncLeaseRevokeRaw(::grpc::ClientContext *context, const ::etcdserverpb::LeaseRevokeRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::DefragmentResponse > * PrepareAsyncDefragmentRaw(::grpc::ClientContext *context, const ::etcdserverpb::DefragmentRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::TxnResponse > * PrepareAsyncTxnRaw(::grpc::ClientContext *context, const ::etcdserverpb::TxnRequest &request,::grpc::CompletionQueue *cq) override
static std::unique_ptr< Stub > NewStub(const std::shared_ptr< ::grpc::ChannelInterface > &channel, const ::grpc::StubOptions &options=::grpc::StubOptions())
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserListResponse > * AsyncUserListRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserListRequest &request,::grpc::CompletionQueue *cq) override
static const char * Cluster_method_names[]
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthenticateResponse > * PrepareAsyncAuthenticateRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthenticateRequest &request,::grpc::CompletionQueue *cq) override
static const char * Watch_method_names[]
virtual ::grpc::Status UserGrantRole(::grpc::ServerContext *context, const ::etcdserverpb::AuthUserGrantRoleRequest *request,::etcdserverpb::AuthUserGrantRoleResponse *response)
virtual ::grpc::Status Range(::grpc::ServerContext *context, const ::etcdserverpb::RangeRequest *request,::etcdserverpb::RangeResponse *response)
::grpc::Status RoleGet(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleGetRequest &request,::etcdserverpb::AuthRoleGetResponse *response) override
virtual ::grpc::Status Watch(::grpc::ServerContext *context,::grpc::ServerReaderWriter< ::etcdserverpb::WatchResponse,::etcdserverpb::WatchRequest > *stream)
virtual ::grpc::Status Txn(::grpc::ServerContext *context, const ::etcdserverpb::TxnRequest *request,::etcdserverpb::TxnResponse *response)
virtual ::grpc::Status DeleteRange(::grpc::ServerContext *context, const ::etcdserverpb::DeleteRangeRequest *request,::etcdserverpb::DeleteRangeResponse *response)
::grpc::Status Alarm(::grpc::ClientContext *context, const ::etcdserverpb::AlarmRequest &request,::etcdserverpb::AlarmResponse *response) override
::grpc::Status UserChangePassword(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserChangePasswordRequest &request,::etcdserverpb::AuthUserChangePasswordResponse *response) override
virtual ::grpc::Status AuthDisable(::grpc::ServerContext *context, const ::etcdserverpb::AuthDisableRequest *request,::etcdserverpb::AuthDisableResponse *response)
virtual ::grpc::Status UserRevokeRole(::grpc::ServerContext *context, const ::etcdserverpb::AuthUserRevokeRoleRequest *request,::etcdserverpb::AuthUserRevokeRoleResponse *response)
virtual ::grpc::Status MemberList(::grpc::ServerContext *context, const ::etcdserverpb::MemberListRequest *request,::etcdserverpb::MemberListResponse *response)
static std::unique_ptr< Stub > NewStub(const std::shared_ptr< ::grpc::ChannelInterface > &channel, const ::grpc::StubOptions &options=::grpc::StubOptions())
::grpc::Status Range(::grpc::ClientContext *context, const ::etcdserverpb::RangeRequest &request,::etcdserverpb::RangeResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserDeleteResponse > * AsyncUserDeleteRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserDeleteRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status RoleGrantPermission(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleGrantPermissionRequest &request,::etcdserverpb::AuthRoleGrantPermissionResponse *response) override
::grpc::Status UserAdd(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserAddRequest &request,::etcdserverpb::AuthUserAddResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberListResponse > * PrepareAsyncMemberListRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberListRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status Txn(::grpc::ClientContext *context, const ::etcdserverpb::TxnRequest &request,::etcdserverpb::TxnResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGetResponse > * AsyncUserGetRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserGetRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status LeaseRevoke(::grpc::ClientContext *context, const ::etcdserverpb::LeaseRevokeRequest &request,::etcdserverpb::LeaseRevokeResponse *response) override
::grpc::Status AuthEnable(::grpc::ClientContext *context, const ::etcdserverpb::AuthEnableRequest &request,::etcdserverpb::AuthEnableResponse *response) override
::grpc::ClientAsyncReaderWriter< ::etcdserverpb::LeaseKeepAliveRequest,::etcdserverpb::LeaseKeepAliveResponse > * AsyncLeaseKeepAliveRaw(::grpc::ClientContext *context,::grpc::CompletionQueue *cq, void *tag) override
::grpc::ClientAsyncReaderWriter< ::etcdserverpb::LeaseKeepAliveRequest,::etcdserverpb::LeaseKeepAliveResponse > * PrepareAsyncLeaseKeepAliveRaw(::grpc::ClientContext *context,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status UserList(::grpc::ServerContext *context, const ::etcdserverpb::AuthUserListRequest *request,::etcdserverpb::AuthUserListResponse *response)
virtual ::grpc::Status Compact(::grpc::ServerContext *context, const ::etcdserverpb::CompactionRequest *request,::etcdserverpb::CompactionResponse *response)
::grpc::Status RoleRevokePermission(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleRevokePermissionRequest &request,::etcdserverpb::AuthRoleRevokePermissionResponse *response) override
::grpc::Status MemberList(::grpc::ClientContext *context, const ::etcdserverpb::MemberListRequest &request,::etcdserverpb::MemberListResponse *response) override
virtual ::grpc::Status LeaseRevoke(::grpc::ServerContext *context, const ::etcdserverpb::LeaseRevokeRequest *request,::etcdserverpb::LeaseRevokeResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::CompactionResponse > * PrepareAsyncCompactRaw(::grpc::ClientContext *context, const ::etcdserverpb::CompactionRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::RangeResponse > * PrepareAsyncRangeRaw(::grpc::ClientContext *context, const ::etcdserverpb::RangeRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status UserRevokeRole(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserRevokeRoleRequest &request,::etcdserverpb::AuthUserRevokeRoleResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberListResponse > * AsyncMemberListRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberListRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserRevokeRoleResponse > * PrepareAsyncUserRevokeRoleRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserRevokeRoleRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientReader< ::etcdserverpb::SnapshotResponse > * SnapshotRaw(::grpc::ClientContext *context, const ::etcdserverpb::SnapshotRequest &request) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::CompactionResponse > * AsyncCompactRaw(::grpc::ClientContext *context, const ::etcdserverpb::CompactionRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::HashResponse > * AsyncHashRaw(::grpc::ClientContext *context, const ::etcdserverpb::HashRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::DeleteRangeResponse > * AsyncDeleteRangeRaw(::grpc::ClientContext *context, const ::etcdserverpb::DeleteRangeRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthDisableResponse > * AsyncAuthDisableRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthDisableRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status RoleRevokePermission(::grpc::ServerContext *context, const ::etcdserverpb::AuthRoleRevokePermissionRequest *request,::etcdserverpb::AuthRoleRevokePermissionResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGetResponse > * AsyncRoleGetRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleGetRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseGrantResponse > * AsyncLeaseGrantRaw(::grpc::ClientContext *context, const ::etcdserverpb::LeaseGrantRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberAddResponse > * AsyncMemberAddRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberAddRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleRevokePermissionResponse > * PrepareAsyncRoleRevokePermissionRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleRevokePermissionRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::TxnResponse > * AsyncTxnRaw(::grpc::ClientContext *context, const ::etcdserverpb::TxnRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status UserGet(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserGetRequest &request,::etcdserverpb::AuthUserGetResponse *response) override
virtual ::grpc::Status UserAdd(::grpc::ServerContext *context, const ::etcdserverpb::AuthUserAddRequest *request,::etcdserverpb::AuthUserAddResponse *response)
virtual ::grpc::Status UserGet(::grpc::ServerContext *context, const ::etcdserverpb::AuthUserGetRequest *request,::etcdserverpb::AuthUserGetResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGrantPermissionResponse > * AsyncRoleGrantPermissionRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleGrantPermissionRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status Hash(::grpc::ClientContext *context, const ::etcdserverpb::HashRequest &request,::etcdserverpb::HashResponse *response) override
virtual ::grpc::Status LeaseKeepAlive(::grpc::ServerContext *context,::grpc::ServerReaderWriter< ::etcdserverpb::LeaseKeepAliveResponse,::etcdserverpb::LeaseKeepAliveRequest > *stream)
::grpc::Status MemberAdd(::grpc::ClientContext *context, const ::etcdserverpb::MemberAddRequest &request,::etcdserverpb::MemberAddResponse *response) override
::grpc::Status RoleAdd(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleAddRequest &request,::etcdserverpb::AuthRoleAddResponse *response) override
virtual ::grpc::Status Alarm(::grpc::ServerContext *context, const ::etcdserverpb::AlarmRequest *request,::etcdserverpb::AlarmResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::RangeResponse > * AsyncRangeRaw(::grpc::ClientContext *context, const ::etcdserverpb::RangeRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseRevokeResponse > * AsyncLeaseRevokeRaw(::grpc::ClientContext *context, const ::etcdserverpb::LeaseRevokeRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthDisableResponse > * PrepareAsyncAuthDisableRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthDisableRequest &request,::grpc::CompletionQueue *cq) override
Stub(const std::shared_ptr< ::grpc::ChannelInterface > &channel)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGetResponse > * PrepareAsyncUserGetRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserGetRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserChangePasswordResponse > * PrepareAsyncUserChangePasswordRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserChangePasswordRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status LeaseGrant(::grpc::ServerContext *context, const ::etcdserverpb::LeaseGrantRequest *request,::etcdserverpb::LeaseGrantResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGrantRoleResponse > * AsyncUserGrantRoleRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserGrantRoleRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientReaderWriter< ::etcdserverpb::WatchRequest,::etcdserverpb::WatchResponse > * WatchRaw(::grpc::ClientContext *context) override
Stub(const std::shared_ptr< ::grpc::ChannelInterface > &channel)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::HashResponse > * PrepareAsyncHashRaw(::grpc::ClientContext *context, const ::etcdserverpb::HashRequest &request,::grpc::CompletionQueue *cq) override
static std::unique_ptr< Stub > NewStub(const std::shared_ptr< ::grpc::ChannelInterface > &channel, const ::grpc::StubOptions &options=::grpc::StubOptions())
virtual ::grpc::Status RoleGet(::grpc::ServerContext *context, const ::etcdserverpb::AuthRoleGetRequest *request,::etcdserverpb::AuthRoleGetResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::DefragmentResponse > * AsyncDefragmentRaw(::grpc::ClientContext *context, const ::etcdserverpb::DefragmentRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status RoleAdd(::grpc::ServerContext *context, const ::etcdserverpb::AuthRoleAddRequest *request,::etcdserverpb::AuthRoleAddResponse *response)
::grpc::Status UserDelete(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserDeleteRequest &request,::etcdserverpb::AuthUserDeleteResponse *response) override
virtual ::grpc::Status AuthEnable(::grpc::ServerContext *context, const ::etcdserverpb::AuthEnableRequest *request,::etcdserverpb::AuthEnableResponse *response)
virtual ::grpc::Status UserDelete(::grpc::ServerContext *context, const ::etcdserverpb::AuthUserDeleteRequest *request,::etcdserverpb::AuthUserDeleteResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleRevokePermissionResponse > * AsyncRoleRevokePermissionRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleRevokePermissionRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AlarmResponse > * AsyncAlarmRaw(::grpc::ClientContext *context, const ::etcdserverpb::AlarmRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberUpdateResponse > * AsyncMemberUpdateRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberUpdateRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberRemoveResponse > * AsyncMemberRemoveRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberRemoveRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberRemoveResponse > * PrepareAsyncMemberRemoveRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberRemoveRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status RoleList(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleListRequest &request,::etcdserverpb::AuthRoleListResponse *response) override
Stub(const std::shared_ptr< ::grpc::ChannelInterface > &channel)
::grpc::ClientAsyncReaderWriter< ::etcdserverpb::WatchRequest,::etcdserverpb::WatchResponse > * PrepareAsyncWatchRaw(::grpc::ClientContext *context,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status Authenticate(::grpc::ServerContext *context, const ::etcdserverpb::AuthenticateRequest *request,::etcdserverpb::AuthenticateResponse *response)
::grpc::Status MemberRemove(::grpc::ClientContext *context, const ::etcdserverpb::MemberRemoveRequest &request,::etcdserverpb::MemberRemoveResponse *response) override
static const char * Maintenance_method_names[]
::grpc::Status LeaseGrant(::grpc::ClientContext *context, const ::etcdserverpb::LeaseGrantRequest &request,::etcdserverpb::LeaseGrantResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::LeaseGrantResponse > * PrepareAsyncLeaseGrantRaw(::grpc::ClientContext *context, const ::etcdserverpb::LeaseGrantRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleDeleteResponse > * PrepareAsyncRoleDeleteRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleDeleteRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::PutResponse > * PrepareAsyncPutRaw(::grpc::ClientContext *context, const ::etcdserverpb::PutRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AlarmResponse > * PrepareAsyncAlarmRaw(::grpc::ClientContext *context, const ::etcdserverpb::AlarmRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status DeleteRange(::grpc::ClientContext *context, const ::etcdserverpb::DeleteRangeRequest &request,::etcdserverpb::DeleteRangeResponse *response) override
virtual ::grpc::Status Hash(::grpc::ServerContext *context, const ::etcdserverpb::HashRequest *request,::etcdserverpb::HashResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserListResponse > * PrepareAsyncUserListRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserListRequest &request,::grpc::CompletionQueue *cq) override
Stub(const std::shared_ptr< ::grpc::ChannelInterface > &channel)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserRevokeRoleResponse > * AsyncUserRevokeRoleRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserRevokeRoleRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserAddResponse > * AsyncUserAddRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserAddRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status MemberRemove(::grpc::ServerContext *context, const ::etcdserverpb::MemberRemoveRequest *request,::etcdserverpb::MemberRemoveResponse *response)
virtual ::grpc::Status RoleGrantPermission(::grpc::ServerContext *context, const ::etcdserverpb::AuthRoleGrantPermissionRequest *request,::etcdserverpb::AuthRoleGrantPermissionResponse *response)
Stub(const std::shared_ptr< ::grpc::ChannelInterface > &channel)
static const char * KV_method_names[]
::grpc::Status Defragment(::grpc::ClientContext *context, const ::etcdserverpb::DefragmentRequest &request,::etcdserverpb::DefragmentResponse *response) override
virtual ::grpc::Status Defragment(::grpc::ServerContext *context, const ::etcdserverpb::DefragmentRequest *request,::etcdserverpb::DefragmentResponse *response)
static const char * Lease_method_names[]
::grpc::ClientAsyncResponseReader< ::etcdserverpb::DeleteRangeResponse > * PrepareAsyncDeleteRangeRaw(::grpc::ClientContext *context, const ::etcdserverpb::DeleteRangeRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::MemberUpdateResponse > * PrepareAsyncMemberUpdateRaw(::grpc::ClientContext *context, const ::etcdserverpb::MemberUpdateRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status MemberUpdate(::grpc::ClientContext *context, const ::etcdserverpb::MemberUpdateRequest &request,::etcdserverpb::MemberUpdateResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleDeleteResponse > * AsyncRoleDeleteRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleDeleteRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthEnableResponse > * AsyncAuthEnableRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthEnableRequest &request,::grpc::CompletionQueue *cq) override
static const char * Auth_method_names[]
::grpc::Status UserList(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserListRequest &request,::etcdserverpb::AuthUserListResponse *response) override
::grpc::ClientAsyncReaderWriter< ::etcdserverpb::WatchRequest,::etcdserverpb::WatchResponse > * AsyncWatchRaw(::grpc::ClientContext *context,::grpc::CompletionQueue *cq, void *tag) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleListResponse > * AsyncRoleListRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleListRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientReaderWriter< ::etcdserverpb::LeaseKeepAliveRequest,::etcdserverpb::LeaseKeepAliveResponse > * LeaseKeepAliveRaw(::grpc::ClientContext *context) override
virtual ::grpc::Status RoleDelete(::grpc::ServerContext *context, const ::etcdserverpb::AuthRoleDeleteRequest *request,::etcdserverpb::AuthRoleDeleteResponse *response)
virtual ::grpc::Status RoleList(::grpc::ServerContext *context, const ::etcdserverpb::AuthRoleListRequest *request,::etcdserverpb::AuthRoleListResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleAddResponse > * AsyncRoleAddRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleAddRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthEnableResponse > * PrepareAsyncAuthEnableRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthEnableRequest &request,::grpc::CompletionQueue *cq) override
static std::unique_ptr< Stub > NewStub(const std::shared_ptr< ::grpc::ChannelInterface > &channel, const ::grpc::StubOptions &options=::grpc::StubOptions())
static std::unique_ptr< Stub > NewStub(const std::shared_ptr< ::grpc::ChannelInterface > &channel, const ::grpc::StubOptions &options=::grpc::StubOptions())
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGetResponse > * PrepareAsyncRoleGetRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleGetRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::StatusResponse > * AsyncStatusRaw(::grpc::ClientContext *context, const ::etcdserverpb::StatusRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status MemberAdd(::grpc::ServerContext *context, const ::etcdserverpb::MemberAddRequest *request,::etcdserverpb::MemberAddResponse *response)
::grpc::Status UserGrantRole(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserGrantRoleRequest &request,::etcdserverpb::AuthUserGrantRoleResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleGrantPermissionResponse > * PrepareAsyncRoleGrantPermissionRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleGrantPermissionRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleListResponse > * PrepareAsyncRoleListRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleListRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserAddResponse > * PrepareAsyncUserAddRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserAddRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status AuthDisable(::grpc::ClientContext *context, const ::etcdserverpb::AuthDisableRequest &request,::etcdserverpb::AuthDisableResponse *response) override
virtual ::grpc::Status Snapshot(::grpc::ServerContext *context, const ::etcdserverpb::SnapshotRequest *request,::grpc::ServerWriter< ::etcdserverpb::SnapshotResponse > *writer)
Stub(const std::shared_ptr< ::grpc::ChannelInterface > &channel)
::grpc::Status Compact(::grpc::ClientContext *context, const ::etcdserverpb::CompactionRequest &request,::etcdserverpb::CompactionResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserChangePasswordResponse > * AsyncUserChangePasswordRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserChangePasswordRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status Status(::grpc::ServerContext *context, const ::etcdserverpb::StatusRequest *request,::etcdserverpb::StatusResponse *response)
::grpc::Status Authenticate(::grpc::ClientContext *context, const ::etcdserverpb::AuthenticateRequest &request,::etcdserverpb::AuthenticateResponse *response) override
virtual ::grpc::Status MemberUpdate(::grpc::ServerContext *context, const ::etcdserverpb::MemberUpdateRequest *request,::etcdserverpb::MemberUpdateResponse *response)
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserDeleteResponse > * PrepareAsyncUserDeleteRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserDeleteRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status Put(::grpc::ClientContext *context, const ::etcdserverpb::PutRequest &request,::etcdserverpb::PutResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthenticateResponse > * AsyncAuthenticateRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthenticateRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status RoleDelete(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleDeleteRequest &request,::etcdserverpb::AuthRoleDeleteResponse *response) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::StatusResponse > * PrepareAsyncStatusRaw(::grpc::ClientContext *context, const ::etcdserverpb::StatusRequest &request,::grpc::CompletionQueue *cq) override
::grpc::Status Status(::grpc::ClientContext *context, const ::etcdserverpb::StatusRequest &request,::etcdserverpb::StatusResponse *response) override
::grpc::ClientAsyncReader< ::etcdserverpb::SnapshotResponse > * AsyncSnapshotRaw(::grpc::ClientContext *context, const ::etcdserverpb::SnapshotRequest &request,::grpc::CompletionQueue *cq, void *tag) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthUserGrantRoleResponse > * PrepareAsyncUserGrantRoleRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthUserGrantRoleRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncResponseReader< ::etcdserverpb::AuthRoleAddResponse > * PrepareAsyncRoleAddRaw(::grpc::ClientContext *context, const ::etcdserverpb::AuthRoleAddRequest &request,::grpc::CompletionQueue *cq) override
::grpc::ClientAsyncReader< ::etcdserverpb::SnapshotResponse > * PrepareAsyncSnapshotRaw(::grpc::ClientContext *context, const ::etcdserverpb::SnapshotRequest &request,::grpc::CompletionQueue *cq) override
virtual ::grpc::Status UserChangePassword(::grpc::ServerContext *context, const ::etcdserverpb::AuthUserChangePasswordRequest *request,::etcdserverpb::AuthUserChangePasswordResponse *response)