Skip to content

message_pb2_grpc

Client and server classes corresponding to protobuf-defined services.

MessageBoard

Bases: object

Missing associated documentation comment in .proto file.

Source code in declearn/communication/grpc/protobufs/message_pb2_grpc.py 
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
class MessageBoard(object):
    """Missing associated documentation comment in .proto file."""

    @staticmethod
    def ping(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            insecure=False,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_unary(request, target, '/grpc.MessageBoard/ping',
            message__pb2.Empty.SerializeToString,
            message__pb2.Empty.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def send(request,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            insecure=False,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.unary_stream(request, target, '/grpc.MessageBoard/send',
            message__pb2.Message.SerializeToString,
            message__pb2.Message.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

    @staticmethod
    def send_stream(request_iterator,
            target,
            options=(),
            channel_credentials=None,
            call_credentials=None,
            insecure=False,
            compression=None,
            wait_for_ready=None,
            timeout=None,
            metadata=None):
        return grpc.experimental.stream_stream(request_iterator, target, '/grpc.MessageBoard/send_stream',
            message__pb2.Message.SerializeToString,
            message__pb2.Message.FromString,
            options, channel_credentials,
            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

MessageBoardServicer

Bases: object

Missing associated documentation comment in .proto file.

Source code in declearn/communication/grpc/protobufs/message_pb2_grpc.py 
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
class MessageBoardServicer(object):
    """Missing associated documentation comment in .proto file."""

    def ping(self, request, context):
        """Missing associated documentation comment in .proto file."""
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def send(self, request, context):
        """Missing associated documentation comment in .proto file."""
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

    def send_stream(self, request_iterator, context):
        """Missing associated documentation comment in .proto file."""
        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
        context.set_details('Method not implemented!')
        raise NotImplementedError('Method not implemented!')

ping(request, context)

Missing associated documentation comment in .proto file.

Source code in declearn/communication/grpc/protobufs/message_pb2_grpc.py 
37
38
39
40
41
def ping(self, request, context):
    """Missing associated documentation comment in .proto file."""
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

send(request, context)

Missing associated documentation comment in .proto file.

Source code in declearn/communication/grpc/protobufs/message_pb2_grpc.py 
43
44
45
46
47
def send(self, request, context):
    """Missing associated documentation comment in .proto file."""
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

send_stream(request_iterator, context)

Missing associated documentation comment in .proto file.

Source code in declearn/communication/grpc/protobufs/message_pb2_grpc.py 
49
50
51
52
53
def send_stream(self, request_iterator, context):
    """Missing associated documentation comment in .proto file."""
    context.set_code(grpc.StatusCode.UNIMPLEMENTED)
    context.set_details('Method not implemented!')
    raise NotImplementedError('Method not implemented!')

MessageBoardStub

Bases: object

Missing associated documentation comment in .proto file.

Source code in declearn/communication/grpc/protobufs/message_pb2_grpc.py 
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
class MessageBoardStub(object):
    """Missing associated documentation comment in .proto file."""

    def __init__(self, channel):
        """Constructor.

        Args:
            channel: A grpc.Channel.
        """
        self.ping = channel.unary_unary(
                '/grpc.MessageBoard/ping',
                request_serializer=message__pb2.Empty.SerializeToString,
                response_deserializer=message__pb2.Empty.FromString,
                )
        self.send = channel.unary_stream(
                '/grpc.MessageBoard/send',
                request_serializer=message__pb2.Message.SerializeToString,
                response_deserializer=message__pb2.Message.FromString,
                )
        self.send_stream = channel.stream_stream(
                '/grpc.MessageBoard/send_stream',
                request_serializer=message__pb2.Message.SerializeToString,
                response_deserializer=message__pb2.Message.FromString,
                )

__init__(channel)

Constructor.

Args: channel: A grpc.Channel.

Source code in declearn/communication/grpc/protobufs/message_pb2_grpc.py 
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
def __init__(self, channel):
    """Constructor.

    Args:
        channel: A grpc.Channel.
    """
    self.ping = channel.unary_unary(
            '/grpc.MessageBoard/ping',
            request_serializer=message__pb2.Empty.SerializeToString,
            response_deserializer=message__pb2.Empty.FromString,
            )
    self.send = channel.unary_stream(
            '/grpc.MessageBoard/send',
            request_serializer=message__pb2.Message.SerializeToString,
            response_deserializer=message__pb2.Message.FromString,
            )
    self.send_stream = channel.stream_stream(
            '/grpc.MessageBoard/send_stream',
            request_serializer=message__pb2.Message.SerializeToString,
            response_deserializer=message__pb2.Message.FromString,
            )