o
    ;i                     @   sz   d dl Z d dlZd dlZd dlZejrd dlZd dlZd dl	Zd dl
Zd dlZd dlZG dd de jZG dd dZdS )    Nc                   @   s   e Zd ZejdddZejddd	ZejdddZejdddZejdddZ	ejd ddZ
ejd!ddZdejeejjf fddZdS )"ChannelzBasestreamgrpclib.server.Stream[grpclib.channelz.v1.channelz_pb2.GetTopChannelsRequest, grpclib.channelz.v1.channelz_pb2.GetTopChannelsResponse]returnNc                       d S N selfr   r   r   U/home/ubuntu/.local/lib/python3.10/site-packages/grpclib/channelz/v1/channelz_grpc.pyGetTopChannels      zChannelzBase.GetTopChannels~grpclib.server.Stream[grpclib.channelz.v1.channelz_pb2.GetServersRequest, grpclib.channelz.v1.channelz_pb2.GetServersResponse]c                    r   r   r   r	   r   r   r   
GetServers   r   zChannelzBase.GetServers|grpclib.server.Stream[grpclib.channelz.v1.channelz_pb2.GetServerRequest, grpclib.channelz.v1.channelz_pb2.GetServerResponse]c                    r   r   r   r	   r   r   r   	GetServer   r   zChannelzBase.GetServergrpclib.server.Stream[grpclib.channelz.v1.channelz_pb2.GetServerSocketsRequest, grpclib.channelz.v1.channelz_pb2.GetServerSocketsResponse]c                    r   r   r   r	   r   r   r   GetServerSockets!   r   zChannelzBase.GetServerSockets~grpclib.server.Stream[grpclib.channelz.v1.channelz_pb2.GetChannelRequest, grpclib.channelz.v1.channelz_pb2.GetChannelResponse]c                    r   r   r   r	   r   r   r   
GetChannel%   r   zChannelzBase.GetChannelgrpclib.server.Stream[grpclib.channelz.v1.channelz_pb2.GetSubchannelRequest, grpclib.channelz.v1.channelz_pb2.GetSubchannelResponse]c                    r   r   r   r	   r   r   r   GetSubchannel)   r   zChannelzBase.GetSubchannel|grpclib.server.Stream[grpclib.channelz.v1.channelz_pb2.GetSocketRequest, grpclib.channelz.v1.channelz_pb2.GetSocketResponse]c                    r   r   r   r	   r   r   r   	GetSocket-   r   zChannelzBase.GetSocketc                 C   s  t j| jt jjjt jjjj	t jjjj
t j| jt jjjt jjjjt jjjjt j| jt jjjt jjjjt jjjjt j| jt jjjt jjjjt jjjjt j| jt jjjt jjjjt jjjjt j| jt jjjt jjjjt jjjjt j| jt jjjt jjjjt jjjjdS )N))/grpc.channelz.v1.Channelz/GetTopChannels%/grpc.channelz.v1.Channelz/GetServers$/grpc.channelz.v1.Channelz/GetServer+/grpc.channelz.v1.Channelz/GetServerSockets%/grpc.channelz.v1.Channelz/GetChannel(/grpc.channelz.v1.Channelz/GetSubchannel$/grpc.channelz.v1.Channelz/GetSocket)grpclibconstHandlerr   CardinalityUNARY_UNARYchannelzv1channelz_pb2GetTopChannelsRequestGetTopChannelsResponser   GetServersRequestGetServersResponser   GetServerRequestGetServerResponser   GetServerSocketsRequestGetServerSocketsResponser   GetChannelRequestGetChannelResponser   GetSubchannelRequestGetSubchannelResponser   GetSocketRequestGetSocketResponse)r
   r   r   r   __mapping__1   sV   













zChannelzBase.__mapping__)r   r   r   N)r   r   r   N)r   r   r   N)r   r   r   N)r   r   r   N)r   r   r   N)r   r   r   N)__name__
__module____qualname__abcabstractmethodr   r   r   r   r   r   r   typingDictstrr!   r"   r#   r7   r   r   r   r   r      s      r   c                   @   s"   e Zd ZdejjddfddZdS )ChannelzStubchannelr   Nc                 C   s   t j|dt jjjjt jjjj| _t j|dt jjjj	t jjjj
| _t j|dt jjjjt jjjj| _t j|dt jjjjt jjjj| _t j|dt jjjjt jjjj| _t j|dt jjjjt jjjj| _t j|dt jjjjt jjjj| _d S )Nr   r   r   r   r   r   r    )r!   clientUnaryUnaryMethodr&   r'   r(   r)   r*   r   r+   r,   r   r-   r.   r   r/   r0   r   r1   r2   r   r3   r4   r   r5   r6   r   )r
   rA   r   r   r   __init__b   sT   














zChannelzStub.__init__)r8   r9   r:   r!   rB   ChannelrD   r   r   r   r   r@   `   s    r@   )r;   r=   grpclib.constr!   grpclib.clientTYPE_CHECKINGgrpclib.servergoogle.protobuf.any_pb2googlegoogle.protobuf.duration_pb2google.protobuf.timestamp_pb2google.protobuf.wrappers_pb2 grpclib.channelz.v1.channelz_pb2ABCr   r@   r   r   r   r   <module>   s   M