1# Generated by the Protocol Buffers compiler. DO NOT EDIT!
 2# source: app/marznode/marznode.proto
 3# plugin: grpclib.plugin.main
 4import abc
 5import typing
 6
 7import grpclib.const
 8import grpclib.client
 9if typing.TYPE_CHECKING:
10    import grpclib.server
11
12import app.marznode.marznode_pb2
13
14
15class MarzServiceBase(abc.ABC):
16
17    @abc.abstractmethod
18    async def SyncUsers(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.UserData, app.marznode.marznode_pb2.Empty]') -> None:
19        pass
20
21    @abc.abstractmethod
22    async def RepopulateUsers(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.UsersData, app.marznode.marznode_pb2.Empty]') -> None:
23        pass
24
25    @abc.abstractmethod
26    async def FetchInbounds(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.InboundsResponse]') -> None:
27        pass
28
29    @abc.abstractmethod
30    async def FetchUsersStats(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.UsersStats]') -> None:
31        pass
32
33    def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
34        return {
35            '/marznode.MarzService/SyncUsers': grpclib.const.Handler(
36                self.SyncUsers,
37                grpclib.const.Cardinality.STREAM_UNARY,
38                app.marznode.marznode_pb2.UserData,
39                app.marznode.marznode_pb2.Empty,
40            ),
41            '/marznode.MarzService/RepopulateUsers': grpclib.const.Handler(
42                self.RepopulateUsers,
43                grpclib.const.Cardinality.UNARY_UNARY,
44                app.marznode.marznode_pb2.UsersData,
45                app.marznode.marznode_pb2.Empty,
46            ),
47            '/marznode.MarzService/FetchInbounds': grpclib.const.Handler(
48                self.FetchInbounds,
49                grpclib.const.Cardinality.UNARY_UNARY,
50                app.marznode.marznode_pb2.Empty,
51                app.marznode.marznode_pb2.InboundsResponse,
52            ),
53            '/marznode.MarzService/FetchUsersStats': grpclib.const.Handler(
54                self.FetchUsersStats,
55                grpclib.const.Cardinality.UNARY_UNARY,
56                app.marznode.marznode_pb2.Empty,
57                app.marznode.marznode_pb2.UsersStats,
58            ),
59        }
60
61
62class MarzServiceStub:
63
64    def __init__(self, channel: grpclib.client.Channel) -> None:
65        self.SyncUsers = grpclib.client.StreamUnaryMethod(
66            channel,
67            '/marznode.MarzService/SyncUsers',
68            app.marznode.marznode_pb2.UserData,
69            app.marznode.marznode_pb2.Empty,
70        )
71        self.RepopulateUsers = grpclib.client.UnaryUnaryMethod(
72            channel,
73            '/marznode.MarzService/RepopulateUsers',
74            app.marznode.marznode_pb2.UsersData,
75            app.marznode.marznode_pb2.Empty,
76        )
77        self.FetchInbounds = grpclib.client.UnaryUnaryMethod(
78            channel,
79            '/marznode.MarzService/FetchInbounds',
80            app.marznode.marznode_pb2.Empty,
81            app.marznode.marznode_pb2.InboundsResponse,
82        )
83        self.FetchUsersStats = grpclib.client.UnaryUnaryMethod(
84            channel,
85            '/marznode.MarzService/FetchUsersStats',
86            app.marznode.marznode_pb2.Empty,
87            app.marznode.marznode_pb2.UsersStats,
88        )