733 lines
22 KiB
Python
733 lines
22 KiB
Python
from . import hrpc_pb2 as hrpc__pb2
|
|
import purerpc
|
|
|
|
from . import schema_pb2 as schema__pb2
|
|
|
|
|
|
class HyperspaceServicer(purerpc.Servicer):
|
|
async def Status(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
@property
|
|
def service(self) -> purerpc.Service:
|
|
service_obj = purerpc.Service("hyperspace.Hyperspace")
|
|
service_obj.add_method(
|
|
"Status",
|
|
self.Status,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
hrpc__pb2.Void,
|
|
schema__pb2.HyperspaceStatusResponse,
|
|
),
|
|
)
|
|
return service_obj
|
|
|
|
|
|
class HyperspaceStub:
|
|
def __init__(self, channel):
|
|
self._client = purerpc.Client("hyperspace.Hyperspace", channel)
|
|
self.Status = self._client.get_method_stub(
|
|
"Status",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
hrpc__pb2.Void,
|
|
schema__pb2.HyperspaceStatusResponse,
|
|
),
|
|
)
|
|
|
|
|
|
class CorestoreServicer(purerpc.Servicer):
|
|
async def Open(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnFeed(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
@property
|
|
def service(self) -> purerpc.Service:
|
|
service_obj = purerpc.Service("hyperspace.Corestore")
|
|
service_obj.add_method(
|
|
"Open",
|
|
self.Open,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.OpenRequest,
|
|
schema__pb2.OpenResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnFeed",
|
|
self.OnFeed,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.FeedEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
return service_obj
|
|
|
|
|
|
class CorestoreStub:
|
|
def __init__(self, channel):
|
|
self._client = purerpc.Client("hyperspace.Corestore", channel)
|
|
self.Open = self._client.get_method_stub(
|
|
"Open",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.OpenRequest,
|
|
schema__pb2.OpenResponse,
|
|
),
|
|
)
|
|
self.OnFeed = self._client.get_method_stub(
|
|
"OnFeed",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.FeedEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
|
|
|
|
class HypercoreServicer(purerpc.Servicer):
|
|
async def Get(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Append(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Update(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Seek(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Has(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Cancel(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Download(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Downloaded(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Undownload(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Close(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def RegisterExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def UnregisterExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def SendExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def AcquireLock(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def ReleaseLock(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnAppend(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnClose(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnPeerOpen(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnPeerRemove(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnWait(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
@property
|
|
def service(self) -> purerpc.Service:
|
|
service_obj = purerpc.Service("hyperspace.Hypercore")
|
|
service_obj.add_method(
|
|
"Get",
|
|
self.Get,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.GetRequest,
|
|
schema__pb2.GetResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Append",
|
|
self.Append,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.AppendRequest,
|
|
schema__pb2.AppendResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Update",
|
|
self.Update,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UpdateRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Seek",
|
|
self.Seek,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.SeekRequest,
|
|
schema__pb2.SeekResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Has",
|
|
self.Has,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.HasRequest,
|
|
schema__pb2.HasResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Cancel",
|
|
self.Cancel,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.CancelRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Download",
|
|
self.Download,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.DownloadRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Downloaded",
|
|
self.Downloaded,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.DownloadedRequest,
|
|
schema__pb2.DownloadedResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Undownload",
|
|
self.Undownload,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UndownloadRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Close",
|
|
self.Close,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.CloseRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"RegisterExtension",
|
|
self.RegisterExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.RegisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"UnregisterExtension",
|
|
self.UnregisterExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UnregisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"SendExtension",
|
|
self.SendExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"AcquireLock",
|
|
self.AcquireLock,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.LockRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"ReleaseLock",
|
|
self.ReleaseLock,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.LockRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnAppend",
|
|
self.OnAppend,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.AppendEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnClose",
|
|
self.OnClose,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.CloseEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnPeerOpen",
|
|
self.OnPeerOpen,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnPeerRemove",
|
|
self.OnPeerRemove,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnExtension",
|
|
self.OnExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnWait",
|
|
self.OnWait,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.WaitEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
return service_obj
|
|
|
|
|
|
class HypercoreStub:
|
|
def __init__(self, channel):
|
|
self._client = purerpc.Client("hyperspace.Hypercore", channel)
|
|
self.Get = self._client.get_method_stub(
|
|
"Get",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.GetRequest,
|
|
schema__pb2.GetResponse,
|
|
),
|
|
)
|
|
self.Append = self._client.get_method_stub(
|
|
"Append",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.AppendRequest,
|
|
schema__pb2.AppendResponse,
|
|
),
|
|
)
|
|
self.Update = self._client.get_method_stub(
|
|
"Update",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UpdateRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.Seek = self._client.get_method_stub(
|
|
"Seek",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.SeekRequest,
|
|
schema__pb2.SeekResponse,
|
|
),
|
|
)
|
|
self.Has = self._client.get_method_stub(
|
|
"Has",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.HasRequest,
|
|
schema__pb2.HasResponse,
|
|
),
|
|
)
|
|
self.Cancel = self._client.get_method_stub(
|
|
"Cancel",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.CancelRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.Download = self._client.get_method_stub(
|
|
"Download",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.DownloadRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.Downloaded = self._client.get_method_stub(
|
|
"Downloaded",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.DownloadedRequest,
|
|
schema__pb2.DownloadedResponse,
|
|
),
|
|
)
|
|
self.Undownload = self._client.get_method_stub(
|
|
"Undownload",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UndownloadRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.Close = self._client.get_method_stub(
|
|
"Close",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.CloseRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.RegisterExtension = self._client.get_method_stub(
|
|
"RegisterExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.RegisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.UnregisterExtension = self._client.get_method_stub(
|
|
"UnregisterExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UnregisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.SendExtension = self._client.get_method_stub(
|
|
"SendExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.AcquireLock = self._client.get_method_stub(
|
|
"AcquireLock",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.LockRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.ReleaseLock = self._client.get_method_stub(
|
|
"ReleaseLock",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.LockRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnAppend = self._client.get_method_stub(
|
|
"OnAppend",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.AppendEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnClose = self._client.get_method_stub(
|
|
"OnClose",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.CloseEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnPeerOpen = self._client.get_method_stub(
|
|
"OnPeerOpen",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnPeerRemove = self._client.get_method_stub(
|
|
"OnPeerRemove",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnExtension = self._client.get_method_stub(
|
|
"OnExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnWait = self._client.get_method_stub(
|
|
"OnWait",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.WaitEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
|
|
|
|
class NetworkServicer(purerpc.Servicer):
|
|
async def Open(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Configure(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def Status(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def AllStatuses(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def RegisterExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def UnregisterExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def SendExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnPeerAdd(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnPeerRemove(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
async def OnExtension(self, input_message):
|
|
raise NotImplementedError()
|
|
|
|
@property
|
|
def service(self) -> purerpc.Service:
|
|
service_obj = purerpc.Service("hyperspace.Network")
|
|
service_obj.add_method(
|
|
"Open",
|
|
self.Open,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
hrpc__pb2.Void,
|
|
schema__pb2.OpenNetworkResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Configure",
|
|
self.Configure,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ConfigureNetworkRequest,
|
|
schema__pb2.NetworkStatusResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"Status",
|
|
self.Status,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.NetworkStatusRequest,
|
|
schema__pb2.NetworkStatusResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"AllStatuses",
|
|
self.AllStatuses,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
hrpc__pb2.Void,
|
|
schema__pb2.AllNetworkStatusesResponse,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"RegisterExtension",
|
|
self.RegisterExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.RegisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"UnregisterExtension",
|
|
self.UnregisterExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UnregisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"SendExtension",
|
|
self.SendExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnPeerAdd",
|
|
self.OnPeerAdd,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnPeerRemove",
|
|
self.OnPeerRemove,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
service_obj.add_method(
|
|
"OnExtension",
|
|
self.OnExtension,
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
return service_obj
|
|
|
|
|
|
class NetworkStub:
|
|
def __init__(self, channel):
|
|
self._client = purerpc.Client("hyperspace.Network", channel)
|
|
self.Open = self._client.get_method_stub(
|
|
"Open",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
hrpc__pb2.Void,
|
|
schema__pb2.OpenNetworkResponse,
|
|
),
|
|
)
|
|
self.Configure = self._client.get_method_stub(
|
|
"Configure",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ConfigureNetworkRequest,
|
|
schema__pb2.NetworkStatusResponse,
|
|
),
|
|
)
|
|
self.Status = self._client.get_method_stub(
|
|
"Status",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.NetworkStatusRequest,
|
|
schema__pb2.NetworkStatusResponse,
|
|
),
|
|
)
|
|
self.AllStatuses = self._client.get_method_stub(
|
|
"AllStatuses",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
hrpc__pb2.Void,
|
|
schema__pb2.AllNetworkStatusesResponse,
|
|
),
|
|
)
|
|
self.RegisterExtension = self._client.get_method_stub(
|
|
"RegisterExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.RegisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.UnregisterExtension = self._client.get_method_stub(
|
|
"UnregisterExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.UnregisterExtensionRequest,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.SendExtension = self._client.get_method_stub(
|
|
"SendExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnPeerAdd = self._client.get_method_stub(
|
|
"OnPeerAdd",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnPeerRemove = self._client.get_method_stub(
|
|
"OnPeerRemove",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.PeerEvent,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|
|
self.OnExtension = self._client.get_method_stub(
|
|
"OnExtension",
|
|
purerpc.RPCSignature(
|
|
purerpc.Cardinality.UNARY_UNARY,
|
|
schema__pb2.ExtensionMessage,
|
|
hrpc__pb2.Void,
|
|
),
|
|
)
|