File: service.py

package info (click to toggle)
python-grpclib 0.4.8-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 484 kB
  • sloc: python: 3,370; makefile: 2
file content (51 lines) | stat: -rw-r--r-- 1,811 bytes parent folder | download | duplicates (2)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
from ..const import Status
from ..server import Stream
from ..exceptions import GRPCError

from .v1.channelz_pb2 import GetTopChannelsRequest, GetTopChannelsResponse
from .v1.channelz_pb2 import GetServersRequest, GetServersResponse
from .v1.channelz_pb2 import GetServerRequest, GetServerResponse
from .v1.channelz_pb2 import GetServerSocketsRequest, GetServerSocketsResponse
from .v1.channelz_pb2 import GetChannelRequest, GetChannelResponse
from .v1.channelz_pb2 import GetSubchannelRequest, GetSubchannelResponse
from .v1.channelz_pb2 import GetSocketRequest, GetSocketResponse
from .v1.channelz_grpc import ChannelzBase


class Channelz(ChannelzBase):

    async def GetTopChannels(
        self, stream: 'Stream[GetTopChannelsRequest, GetTopChannelsResponse]',
    ) -> None:
        raise GRPCError(Status.UNIMPLEMENTED)

    async def GetServers(
        self, stream: 'Stream[GetServersRequest, GetServersResponse]',
    ) -> None:
        raise GRPCError(Status.UNIMPLEMENTED)

    async def GetServer(
        self, stream: 'Stream[GetServerRequest, GetServerResponse]',
    ) -> None:
        raise GRPCError(Status.UNIMPLEMENTED)

    async def GetServerSockets(
        self,
        stream: 'Stream[GetServerSocketsRequest, GetServerSocketsResponse]',
    ) -> None:
        raise GRPCError(Status.UNIMPLEMENTED)

    async def GetChannel(
        self, stream: 'Stream[GetChannelRequest, GetChannelResponse]',
    ) -> None:
        raise GRPCError(Status.UNIMPLEMENTED)

    async def GetSubchannel(
        self, stream: 'Stream[GetSubchannelRequest, GetSubchannelResponse]',
    ) -> None:
        raise GRPCError(Status.UNIMPLEMENTED)

    async def GetSocket(
        self, stream: 'Stream[GetSocketRequest, GetSocketResponse]',
    ) -> None:
        raise GRPCError(Status.UNIMPLEMENTED)