@@ -348,6 +348,10 @@ async def Snapshot(self, stream: 'grpclib.server.Stream[rpc_pb2.SnapshotRequest,
348
348
async def MoveLeader (self , stream : 'grpclib.server.Stream[rpc_pb2.MoveLeaderRequest, rpc_pb2.MoveLeaderResponse]' ) -> None :
349
349
pass
350
350
351
+ @abc .abstractmethod
352
+ async def Downgrade (self , stream : 'grpclib.server.Stream[rpc_pb2.DowngradeRequest, rpc_pb2.DowngradeResponse]' ) -> None :
353
+ pass
354
+
351
355
def __mapping__ (self ) -> typing .Dict [str , grpclib .const .Handler ]:
352
356
return {
353
357
'/etcdserverpb.Maintenance/Alarm' : grpclib .const .Handler (
@@ -392,6 +396,12 @@ def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
392
396
rpc_pb2 .MoveLeaderRequest ,
393
397
rpc_pb2 .MoveLeaderResponse ,
394
398
),
399
+ '/etcdserverpb.Maintenance/Downgrade' : grpclib .const .Handler (
400
+ self .Downgrade ,
401
+ grpclib .const .Cardinality .UNARY_UNARY ,
402
+ rpc_pb2 .DowngradeRequest ,
403
+ rpc_pb2 .DowngradeResponse ,
404
+ ),
395
405
}
396
406
397
407
@@ -440,6 +450,12 @@ def __init__(self, channel: grpclib.client.Channel) -> None:
440
450
rpc_pb2 .MoveLeaderRequest ,
441
451
rpc_pb2 .MoveLeaderResponse ,
442
452
)
453
+ self .Downgrade = grpclib .client .UnaryUnaryMethod (
454
+ channel ,
455
+ '/etcdserverpb.Maintenance/Downgrade' ,
456
+ rpc_pb2 .DowngradeRequest ,
457
+ rpc_pb2 .DowngradeResponse ,
458
+ )
443
459
444
460
445
461
class AuthBase (abc .ABC ):
@@ -452,6 +468,10 @@ async def AuthEnable(self, stream: 'grpclib.server.Stream[rpc_pb2.AuthEnableRequ
452
468
async def AuthDisable (self , stream : 'grpclib.server.Stream[rpc_pb2.AuthDisableRequest, rpc_pb2.AuthDisableResponse]' ) -> None :
453
469
pass
454
470
471
+ @abc .abstractmethod
472
+ async def AuthStatus (self , stream : 'grpclib.server.Stream[rpc_pb2.AuthStatusRequest, rpc_pb2.AuthStatusResponse]' ) -> None :
473
+ pass
474
+
455
475
@abc .abstractmethod
456
476
async def Authenticate (self , stream : 'grpclib.server.Stream[rpc_pb2.AuthenticateRequest, rpc_pb2.AuthenticateResponse]' ) -> None :
457
477
pass
@@ -522,6 +542,12 @@ def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
522
542
rpc_pb2 .AuthDisableRequest ,
523
543
rpc_pb2 .AuthDisableResponse ,
524
544
),
545
+ '/etcdserverpb.Auth/AuthStatus' : grpclib .const .Handler (
546
+ self .AuthStatus ,
547
+ grpclib .const .Cardinality .UNARY_UNARY ,
548
+ rpc_pb2 .AuthStatusRequest ,
549
+ rpc_pb2 .AuthStatusResponse ,
550
+ ),
525
551
'/etcdserverpb.Auth/Authenticate' : grpclib .const .Handler (
526
552
self .Authenticate ,
527
553
grpclib .const .Cardinality .UNARY_UNARY ,
@@ -624,6 +650,12 @@ def __init__(self, channel: grpclib.client.Channel) -> None:
624
650
rpc_pb2 .AuthDisableRequest ,
625
651
rpc_pb2 .AuthDisableResponse ,
626
652
)
653
+ self .AuthStatus = grpclib .client .UnaryUnaryMethod (
654
+ channel ,
655
+ '/etcdserverpb.Auth/AuthStatus' ,
656
+ rpc_pb2 .AuthStatusRequest ,
657
+ rpc_pb2 .AuthStatusResponse ,
658
+ )
627
659
self .Authenticate = grpclib .client .UnaryUnaryMethod (
628
660
channel ,
629
661
'/etcdserverpb.Auth/Authenticate' ,
0 commit comments