Commit e474fbcd authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Updated context with RPCs for Slice management

parent 586c8c30

proto/context.proto

+7 −0
Original line number Diff line number Diff line
@@ -53,6 +53,13 @@ service ContextService { 
  rpc RemoveService      (ServiceId   ) returns (       Empty           ) {}

  rpc GetServiceEvents   (Empty       ) returns (stream ServiceEvent    ) {}



  rpc ListSliceIds       (ContextId   ) returns (       SliceIdList     ) {}

  rpc ListSlices         (ContextId   ) returns (       SliceList       ) {}

  rpc GetSlice           (SliceId     ) returns (       Slice           ) {}

  rpc SetSlice           (Slice       ) returns (       SliceId         ) {}

  rpc RemoveSlice        (SliceId     ) returns (       Empty           ) {}

  rpc GetSliceEvents     (Empty       ) returns (stream SliceEvent      ) {}



  rpc ListConnectionIds  (ServiceId   ) returns (       ConnectionIdList) {}

  rpc ListConnections    (ServiceId   ) returns (       ConnectionList  ) {}

  rpc GetConnection      (ConnectionId) returns (       Connection      ) {}

src/compute/proto/context_pb2.py

+68 −8

File changed.

Preview size limit exceeded, changes collapsed.

src/context/proto/context_pb2.py

+68 −8

File changed.

Preview size limit exceeded, changes collapsed.

src/context/proto/context_pb2_grpc.py

+198 −0
Original line number Diff line number Diff line
@@ -164,6 +164,36 @@ class ContextServiceStub(object): 
                request_serializer=context__pb2.Empty.SerializeToString,

                response_deserializer=context__pb2.ServiceEvent.FromString,

                )

        self.ListSliceIds = channel.unary_unary(

                '/context.ContextService/ListSliceIds',

                request_serializer=context__pb2.ContextId.SerializeToString,

                response_deserializer=context__pb2.SliceIdList.FromString,

                )

        self.ListSlices = channel.unary_unary(

                '/context.ContextService/ListSlices',

                request_serializer=context__pb2.ContextId.SerializeToString,

                response_deserializer=context__pb2.SliceList.FromString,

                )

        self.GetSlice = channel.unary_unary(

                '/context.ContextService/GetSlice',

                request_serializer=context__pb2.SliceId.SerializeToString,

                response_deserializer=context__pb2.Slice.FromString,

                )

        self.SetSlice = channel.unary_unary(

                '/context.ContextService/SetSlice',

                request_serializer=context__pb2.Slice.SerializeToString,

                response_deserializer=context__pb2.SliceId.FromString,

                )

        self.RemoveSlice = channel.unary_unary(

                '/context.ContextService/RemoveSlice',

                request_serializer=context__pb2.SliceId.SerializeToString,

                response_deserializer=context__pb2.Empty.FromString,

                )

        self.GetSliceEvents = channel.unary_stream(

                '/context.ContextService/GetSliceEvents',

                request_serializer=context__pb2.Empty.SerializeToString,

                response_deserializer=context__pb2.SliceEvent.FromString,

                )

        self.ListConnectionIds = channel.unary_unary(

                '/context.ContextService/ListConnectionIds',

                request_serializer=context__pb2.ServiceId.SerializeToString,
@@ -379,6 +409,42 @@ class ContextServiceServicer(object): 
        context.set_details('Method not implemented!')

        raise NotImplementedError('Method not implemented!')



    def ListSliceIds(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 ListSlices(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 GetSlice(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 SetSlice(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 RemoveSlice(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 GetSliceEvents(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 ListConnectionIds(self, request, context):

        """Missing associated documentation comment in .proto file."""

        context.set_code(grpc.StatusCode.UNIMPLEMENTED)
@@ -568,6 +634,36 @@ def add_ContextServiceServicer_to_server(servicer, server): 
                    request_deserializer=context__pb2.Empty.FromString,

                    response_serializer=context__pb2.ServiceEvent.SerializeToString,

            ),

            'ListSliceIds': grpc.unary_unary_rpc_method_handler(

                    servicer.ListSliceIds,

                    request_deserializer=context__pb2.ContextId.FromString,

                    response_serializer=context__pb2.SliceIdList.SerializeToString,

            ),

            'ListSlices': grpc.unary_unary_rpc_method_handler(

                    servicer.ListSlices,

                    request_deserializer=context__pb2.ContextId.FromString,

                    response_serializer=context__pb2.SliceList.SerializeToString,

            ),

            'GetSlice': grpc.unary_unary_rpc_method_handler(

                    servicer.GetSlice,

                    request_deserializer=context__pb2.SliceId.FromString,

                    response_serializer=context__pb2.Slice.SerializeToString,

            ),

            'SetSlice': grpc.unary_unary_rpc_method_handler(

                    servicer.SetSlice,

                    request_deserializer=context__pb2.Slice.FromString,

                    response_serializer=context__pb2.SliceId.SerializeToString,

            ),

            'RemoveSlice': grpc.unary_unary_rpc_method_handler(

                    servicer.RemoveSlice,

                    request_deserializer=context__pb2.SliceId.FromString,

                    response_serializer=context__pb2.Empty.SerializeToString,

            ),

            'GetSliceEvents': grpc.unary_stream_rpc_method_handler(

                    servicer.GetSliceEvents,

                    request_deserializer=context__pb2.Empty.FromString,

                    response_serializer=context__pb2.SliceEvent.SerializeToString,

            ),

            'ListConnectionIds': grpc.unary_unary_rpc_method_handler(

                    servicer.ListConnectionIds,

                    request_deserializer=context__pb2.ServiceId.FromString,
@@ -1118,6 +1214,108 @@ class ContextService(object): 
            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def ListSliceIds(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, '/context.ContextService/ListSliceIds',

            context__pb2.ContextId.SerializeToString,

            context__pb2.SliceIdList.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def ListSlices(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, '/context.ContextService/ListSlices',

            context__pb2.ContextId.SerializeToString,

            context__pb2.SliceList.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def GetSlice(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, '/context.ContextService/GetSlice',

            context__pb2.SliceId.SerializeToString,

            context__pb2.Slice.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def SetSlice(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, '/context.ContextService/SetSlice',

            context__pb2.Slice.SerializeToString,

            context__pb2.SliceId.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def RemoveSlice(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, '/context.ContextService/RemoveSlice',

            context__pb2.SliceId.SerializeToString,

            context__pb2.Empty.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def GetSliceEvents(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, '/context.ContextService/GetSliceEvents',

            context__pb2.Empty.SerializeToString,

            context__pb2.SliceEvent.FromString,

            options, channel_credentials,

            insecure, call_credentials, compression, wait_for_ready, timeout, metadata)



    @staticmethod

    def ListConnectionIds(request,

            target,

src/device/proto/context_pb2.py

+68 −8

File changed.

Preview size limit exceeded, changes collapsed.