gitscope
/
← marzneshin / app/marznode/marznode_grpc.py / blame
Files Commits 446 Branches 1 Tags 43 Markers 4 README License
https://dev.kronoz.win/r/marzneshin.git
app/marznode/marznode_grpc.py · v0.3.0-alpha
Source
1 12b255b Dawsh 2y ago # Generated by the Protocol Buffers compiler. DO NOT EDIT!
2 12b255b Dawsh 2y ago # source: app/marznode/marznode.proto
3 12b255b Dawsh 2y ago # plugin: grpclib.plugin.main
4 12b255b Dawsh 2y ago import abc
5 12b255b Dawsh 2y ago import typing
6 12b255b Dawsh 2y ago
7 12b255b Dawsh 2y ago import grpclib.const
8 12b255b Dawsh 2y ago import grpclib.client
9 12b255b Dawsh 2y ago if typing.TYPE_CHECKING:
10 12b255b Dawsh 2y ago import grpclib.server
11 12b255b Dawsh 2y ago
12 12b255b Dawsh 2y ago import app.marznode.marznode_pb2
13 12b255b Dawsh 2y ago
14 12b255b Dawsh 2y ago
15 12b255b Dawsh 2y ago class MarzServiceBase(abc.ABC):
16 12b255b Dawsh 2y ago
17 12b255b Dawsh 2y ago @abc.abstractmethod
18 f6a32ea Dawsh 2y ago async def SyncUsers(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.UserData, app.marznode.marznode_pb2.Empty]') -> None:
19 12b255b Dawsh 2y ago pass
20 12b255b Dawsh 2y ago
21 12b255b Dawsh 2y ago @abc.abstractmethod
22 f6a32ea Dawsh 2y ago async def RepopulateUsers(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.UsersData, app.marznode.marznode_pb2.Empty]') -> None:
23 12b255b Dawsh 2y ago pass
24 12b255b Dawsh 2y ago
25 12b255b Dawsh 2y ago @abc.abstractmethod
26 12b255b Dawsh 2y ago async def FetchInbounds(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.InboundsResponse]') -> None:
27 12b255b Dawsh 2y ago pass
28 12b255b Dawsh 2y ago
29 12b255b Dawsh 2y ago @abc.abstractmethod
30 12b255b Dawsh 2y ago async def FetchUsersStats(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.UsersStats]') -> None:
31 12b255b Dawsh 2y ago pass
32 12b255b Dawsh 2y ago
33 512d183 Mrdn 2y ago @abc.abstractmethod
34 512d183 Mrdn 2y ago async def FetchXrayConfig(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.Empty, app.marznode.marznode_pb2.XrayConfig]') -> None:
35 512d183 Mrdn 2y ago pass
36 512d183 Mrdn 2y ago
37 512d183 Mrdn 2y ago @abc.abstractmethod
38 512d183 Mrdn 2y ago async def RestartXray(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.XrayConfig, app.marznode.marznode_pb2.InboundsResponse]') -> None:
39 512d183 Mrdn 2y ago pass
40 512d183 Mrdn 2y ago
41 512d183 Mrdn 2y ago @abc.abstractmethod
42 512d183 Mrdn 2y ago async def StreamXrayLogs(self, stream: 'grpclib.server.Stream[app.marznode.marznode_pb2.XrayLogsRequest, app.marznode.marznode_pb2.LogLine]') -> None:
43 512d183 Mrdn 2y ago pass
44 512d183 Mrdn 2y ago
45 12b255b Dawsh 2y ago def __mapping__(self) -> typing.Dict[str, grpclib.const.Handler]:
46 12b255b Dawsh 2y ago return {
47 f6a32ea Dawsh 2y ago '/marznode.MarzService/SyncUsers': grpclib.const.Handler(
48 f6a32ea Dawsh 2y ago self.SyncUsers,
49 f6a32ea Dawsh 2y ago grpclib.const.Cardinality.STREAM_UNARY,
50 f6a32ea Dawsh 2y ago app.marznode.marznode_pb2.UserData,
51 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
52 12b255b Dawsh 2y ago ),
53 12b255b Dawsh 2y ago '/marznode.MarzService/RepopulateUsers': grpclib.const.Handler(
54 12b255b Dawsh 2y ago self.RepopulateUsers,
55 12b255b Dawsh 2y ago grpclib.const.Cardinality.UNARY_UNARY,
56 f6a32ea Dawsh 2y ago app.marznode.marznode_pb2.UsersData,
57 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
58 12b255b Dawsh 2y ago ),
59 12b255b Dawsh 2y ago '/marznode.MarzService/FetchInbounds': grpclib.const.Handler(
60 12b255b Dawsh 2y ago self.FetchInbounds,
61 12b255b Dawsh 2y ago grpclib.const.Cardinality.UNARY_UNARY,
62 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
63 12b255b Dawsh 2y ago app.marznode.marznode_pb2.InboundsResponse,
64 12b255b Dawsh 2y ago ),
65 12b255b Dawsh 2y ago '/marznode.MarzService/FetchUsersStats': grpclib.const.Handler(
66 12b255b Dawsh 2y ago self.FetchUsersStats,
67 12b255b Dawsh 2y ago grpclib.const.Cardinality.UNARY_UNARY,
68 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
69 12b255b Dawsh 2y ago app.marznode.marznode_pb2.UsersStats,
70 12b255b Dawsh 2y ago ),
71 512d183 Mrdn 2y ago '/marznode.MarzService/FetchXrayConfig': grpclib.const.Handler(
72 512d183 Mrdn 2y ago self.FetchXrayConfig,
73 512d183 Mrdn 2y ago grpclib.const.Cardinality.UNARY_UNARY,
74 512d183 Mrdn 2y ago app.marznode.marznode_pb2.Empty,
75 512d183 Mrdn 2y ago app.marznode.marznode_pb2.XrayConfig,
76 512d183 Mrdn 2y ago ),
77 512d183 Mrdn 2y ago '/marznode.MarzService/RestartXray': grpclib.const.Handler(
78 512d183 Mrdn 2y ago self.RestartXray,
79 512d183 Mrdn 2y ago grpclib.const.Cardinality.UNARY_UNARY,
80 512d183 Mrdn 2y ago app.marznode.marznode_pb2.XrayConfig,
81 512d183 Mrdn 2y ago app.marznode.marznode_pb2.InboundsResponse,
82 512d183 Mrdn 2y ago ),
83 512d183 Mrdn 2y ago '/marznode.MarzService/StreamXrayLogs': grpclib.const.Handler(
84 512d183 Mrdn 2y ago self.StreamXrayLogs,
85 512d183 Mrdn 2y ago grpclib.const.Cardinality.UNARY_STREAM,
86 512d183 Mrdn 2y ago app.marznode.marznode_pb2.XrayLogsRequest,
87 512d183 Mrdn 2y ago app.marznode.marznode_pb2.LogLine,
88 512d183 Mrdn 2y ago ),
89 12b255b Dawsh 2y ago }
90 12b255b Dawsh 2y ago
91 12b255b Dawsh 2y ago
92 12b255b Dawsh 2y ago class MarzServiceStub:
93 12b255b Dawsh 2y ago
94 12b255b Dawsh 2y ago def __init__(self, channel: grpclib.client.Channel) -> None:
95 f6a32ea Dawsh 2y ago self.SyncUsers = grpclib.client.StreamUnaryMethod(
96 12b255b Dawsh 2y ago channel,
97 f6a32ea Dawsh 2y ago '/marznode.MarzService/SyncUsers',
98 f6a32ea Dawsh 2y ago app.marznode.marznode_pb2.UserData,
99 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
100 12b255b Dawsh 2y ago )
101 12b255b Dawsh 2y ago self.RepopulateUsers = grpclib.client.UnaryUnaryMethod(
102 12b255b Dawsh 2y ago channel,
103 12b255b Dawsh 2y ago '/marznode.MarzService/RepopulateUsers',
104 f6a32ea Dawsh 2y ago app.marznode.marznode_pb2.UsersData,
105 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
106 12b255b Dawsh 2y ago )
107 12b255b Dawsh 2y ago self.FetchInbounds = grpclib.client.UnaryUnaryMethod(
108 12b255b Dawsh 2y ago channel,
109 12b255b Dawsh 2y ago '/marznode.MarzService/FetchInbounds',
110 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
111 12b255b Dawsh 2y ago app.marznode.marznode_pb2.InboundsResponse,
112 12b255b Dawsh 2y ago )
113 12b255b Dawsh 2y ago self.FetchUsersStats = grpclib.client.UnaryUnaryMethod(
114 12b255b Dawsh 2y ago channel,
115 12b255b Dawsh 2y ago '/marznode.MarzService/FetchUsersStats',
116 12b255b Dawsh 2y ago app.marznode.marznode_pb2.Empty,
117 12b255b Dawsh 2y ago app.marznode.marznode_pb2.UsersStats,
118 12b255b Dawsh 2y ago )
119 512d183 Mrdn 2y ago self.FetchXrayConfig = grpclib.client.UnaryUnaryMethod(
120 512d183 Mrdn 2y ago channel,
121 512d183 Mrdn 2y ago '/marznode.MarzService/FetchXrayConfig',
122 512d183 Mrdn 2y ago app.marznode.marznode_pb2.Empty,
123 512d183 Mrdn 2y ago app.marznode.marznode_pb2.XrayConfig,
124 512d183 Mrdn 2y ago )
125 512d183 Mrdn 2y ago self.RestartXray = grpclib.client.UnaryUnaryMethod(
126 512d183 Mrdn 2y ago channel,
127 512d183 Mrdn 2y ago '/marznode.MarzService/RestartXray',
128 512d183 Mrdn 2y ago app.marznode.marznode_pb2.XrayConfig,
129 512d183 Mrdn 2y ago app.marznode.marznode_pb2.InboundsResponse,
130 512d183 Mrdn 2y ago )
131 512d183 Mrdn 2y ago self.StreamXrayLogs = grpclib.client.UnaryStreamMethod(
132 512d183 Mrdn 2y ago channel,
133 512d183 Mrdn 2y ago '/marznode.MarzService/StreamXrayLogs',
134 512d183 Mrdn 2y ago app.marznode.marznode_pb2.XrayLogsRequest,
135 512d183 Mrdn 2y ago app.marznode.marznode_pb2.LogLine,
136 512d183 Mrdn 2y ago )