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

Context component: 

- regenerated python code from proto files
parent 293cef5d

src/context/proto/acl_pb2_grpc.py

deleted100644 → 0
+0 −4
Original line number Diff line number Diff line 
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!

"""Client and server classes corresponding to protobuf-defined services."""

import grpc

src/context/proto/context_pb2.py

+2 −2
Original line number Diff line number Diff line
@@ -12,8 +12,8 @@ from google.protobuf import symbol_database as _symbol_database 
_sym_db = _symbol_database.Default()





import acl_pb2 as acl__pb2

import kpi_sample_types_pb2 as kpi__sample__types__pb2

from . import acl_pb2 as acl__pb2

from . import kpi_sample_types_pb2 as kpi__sample__types__pb2





DESCRIPTOR = _descriptor.FileDescriptor(

src/context/proto/context_pb2_grpc.py

+1 −1
Original line number Diff line number Diff line
@@ -2,7 +2,7 @@ 
"""Client and server classes corresponding to protobuf-defined services."""

import grpc



import context_pb2 as context__pb2

from . import context_pb2 as context__pb2





class ContextServiceStub(object):

src/context/proto/context_policy_pb2.py

0 → 100644
+99 −0
Original line number Diff line number Diff line 
# -*- coding: utf-8 -*-

# Generated by the protocol buffer compiler.  DO NOT EDIT!

# source: context-policy.proto

"""Generated protocol buffer code."""

from google.protobuf import descriptor as _descriptor

from google.protobuf import message as _message

from google.protobuf import reflection as _reflection

from google.protobuf import symbol_database as _symbol_database

# @@protoc_insertion_point(imports)



_sym_db = _symbol_database.Default()





from . import context_pb2 as context__pb2

from . import policy_pb2 as policy__pb2





DESCRIPTOR = _descriptor.FileDescriptor(

  name='context-policy.proto',

  package='context_policy',

  syntax='proto3',

  serialized_options=None,

  create_key=_descriptor._internal_create_key,

  serialized_pb=b'\n\x14\x63ontext-policy.proto\x12\x0e\x63ontext_policy\x1a\rcontext.proto\x1a\x0cpolicy.proto2\xd4\x02\n\x14\x43ontextPolicyService\x12?\n\x11ListPolicyRuleIds\x12\x0e.context.Empty\x1a\x18.policy.PolicyRuleIdList\"\x00\x12;\n\x0fListPolicyRules\x12\x0e.context.Empty\x1a\x16.policy.PolicyRuleList\"\x00\x12@\n\rGetPolicyRule\x12\x14.policy.PolicyRuleId\x1a\x17.policy.PolicyRuleBasic\"\x00\x12@\n\rSetPolicyRule\x12\x17.policy.PolicyRuleBasic\x1a\x14.policy.PolicyRuleId\"\x00\x12:\n\x10RemovePolicyRule\x12\x14.policy.PolicyRuleId\x1a\x0e.context.Empty\"\x00\x62\x06proto3'

  ,

  dependencies=[context__pb2.DESCRIPTOR,policy__pb2.DESCRIPTOR,])







_sym_db.RegisterFileDescriptor(DESCRIPTOR)







_CONTEXTPOLICYSERVICE = _descriptor.ServiceDescriptor(

  name='ContextPolicyService',

  full_name='context_policy.ContextPolicyService',

  file=DESCRIPTOR,

  index=0,

  serialized_options=None,

  create_key=_descriptor._internal_create_key,

  serialized_start=70,

  serialized_end=410,

  methods=[

  _descriptor.MethodDescriptor(

    name='ListPolicyRuleIds',

    full_name='context_policy.ContextPolicyService.ListPolicyRuleIds',

    index=0,

    containing_service=None,

    input_type=context__pb2._EMPTY,

    output_type=policy__pb2._POLICYRULEIDLIST,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='ListPolicyRules',

    full_name='context_policy.ContextPolicyService.ListPolicyRules',

    index=1,

    containing_service=None,

    input_type=context__pb2._EMPTY,

    output_type=policy__pb2._POLICYRULELIST,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='GetPolicyRule',

    full_name='context_policy.ContextPolicyService.GetPolicyRule',

    index=2,

    containing_service=None,

    input_type=policy__pb2._POLICYRULEID,

    output_type=policy__pb2._POLICYRULEBASIC,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='SetPolicyRule',

    full_name='context_policy.ContextPolicyService.SetPolicyRule',

    index=3,

    containing_service=None,

    input_type=policy__pb2._POLICYRULEBASIC,

    output_type=policy__pb2._POLICYRULEID,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

  _descriptor.MethodDescriptor(

    name='RemovePolicyRule',

    full_name='context_policy.ContextPolicyService.RemovePolicyRule',

    index=4,

    containing_service=None,

    input_type=policy__pb2._POLICYRULEID,

    output_type=context__pb2._EMPTY,

    serialized_options=None,

    create_key=_descriptor._internal_create_key,

  ),

])

_sym_db.RegisterServiceDescriptor(_CONTEXTPOLICYSERVICE)



DESCRIPTOR.services_by_name['ContextPolicyService'] = _CONTEXTPOLICYSERVICE



# @@protoc_insertion_point(module_scope)

src/context/proto/context_policy_pb2_grpc.py

0 → 100644
+202 −0
Original line number Diff line number Diff line 
# Generated by the gRPC Python protocol compiler plugin. DO NOT EDIT!

"""Client and server classes corresponding to protobuf-defined services."""

import grpc



from . import context_pb2 as context__pb2

from . import policy_pb2 as policy__pb2





class ContextPolicyServiceStub(object):

    """created as a separate service to prevent import-loops in context and policy

    """



    def __init__(self, channel):

        """Constructor.



        Args:

            channel: A grpc.Channel.

        """

        self.ListPolicyRuleIds = channel.unary_unary(

                '/context_policy.ContextPolicyService/ListPolicyRuleIds',

                request_serializer=context__pb2.Empty.SerializeToString,

                response_deserializer=policy__pb2.PolicyRuleIdList.FromString,

                )

        self.ListPolicyRules = channel.unary_unary(

                '/context_policy.ContextPolicyService/ListPolicyRules',

                request_serializer=context__pb2.Empty.SerializeToString,

                response_deserializer=policy__pb2.PolicyRuleList.FromString,

                )

        self.GetPolicyRule = channel.unary_unary(

                '/context_policy.ContextPolicyService/GetPolicyRule',

                request_serializer=policy__pb2.PolicyRuleId.SerializeToString,

                response_deserializer=policy__pb2.PolicyRuleBasic.FromString,

                )

        self.SetPolicyRule = channel.unary_unary(

                '/context_policy.ContextPolicyService/SetPolicyRule',

                request_serializer=policy__pb2.PolicyRuleBasic.SerializeToString,

                response_deserializer=policy__pb2.PolicyRuleId.FromString,

                )

        self.RemovePolicyRule = channel.unary_unary(

                '/context_policy.ContextPolicyService/RemovePolicyRule',

                request_serializer=policy__pb2.PolicyRuleId.SerializeToString,

                response_deserializer=context__pb2.Empty.FromString,

                )





class ContextPolicyServiceServicer(object):

    """created as a separate service to prevent import-loops in context and policy

    """



    def ListPolicyRuleIds(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 ListPolicyRules(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 GetPolicyRule(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 SetPolicyRule(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 RemovePolicyRule(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 add_ContextPolicyServiceServicer_to_server(servicer, server):

    rpc_method_handlers = {

            'ListPolicyRuleIds': grpc.unary_unary_rpc_method_handler(

                    servicer.ListPolicyRuleIds,

                    request_deserializer=context__pb2.Empty.FromString,

                    response_serializer=policy__pb2.PolicyRuleIdList.SerializeToString,

            ),

            'ListPolicyRules': grpc.unary_unary_rpc_method_handler(

                    servicer.ListPolicyRules,

                    request_deserializer=context__pb2.Empty.FromString,

                    response_serializer=policy__pb2.PolicyRuleList.SerializeToString,

            ),

            'GetPolicyRule': grpc.unary_unary_rpc_method_handler(

                    servicer.GetPolicyRule,

                    request_deserializer=policy__pb2.PolicyRuleId.FromString,

                    response_serializer=policy__pb2.PolicyRuleBasic.SerializeToString,

            ),

            'SetPolicyRule': grpc.unary_unary_rpc_method_handler(

                    servicer.SetPolicyRule,

                    request_deserializer=policy__pb2.PolicyRuleBasic.FromString,

                    response_serializer=policy__pb2.PolicyRuleId.SerializeToString,

            ),

            'RemovePolicyRule': grpc.unary_unary_rpc_method_handler(

                    servicer.RemovePolicyRule,

                    request_deserializer=policy__pb2.PolicyRuleId.FromString,

                    response_serializer=context__pb2.Empty.SerializeToString,

            ),

    }

    generic_handler = grpc.method_handlers_generic_handler(

            'context_policy.ContextPolicyService', rpc_method_handlers)

    server.add_generic_rpc_handlers((generic_handler,))





 # This class is part of an EXPERIMENTAL API.

class ContextPolicyService(object):

    """created as a separate service to prevent import-loops in context and policy

    """



    @staticmethod

    def ListPolicyRuleIds(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_policy.ContextPolicyService/ListPolicyRuleIds',

            context__pb2.Empty.SerializeToString,

            policy__pb2.PolicyRuleIdList.FromString,

            options, channel_credentials,

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



    @staticmethod

    def ListPolicyRules(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_policy.ContextPolicyService/ListPolicyRules',

            context__pb2.Empty.SerializeToString,

            policy__pb2.PolicyRuleList.FromString,

            options, channel_credentials,

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



    @staticmethod

    def GetPolicyRule(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_policy.ContextPolicyService/GetPolicyRule',

            policy__pb2.PolicyRuleId.SerializeToString,

            policy__pb2.PolicyRuleBasic.FromString,

            options, channel_credentials,

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



    @staticmethod

    def SetPolicyRule(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_policy.ContextPolicyService/SetPolicyRule',

            policy__pb2.PolicyRuleBasic.SerializeToString,

            policy__pb2.PolicyRuleId.FromString,

            options, channel_credentials,

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



    @staticmethod

    def RemovePolicyRule(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_policy.ContextPolicyService/RemovePolicyRule',

            policy__pb2.PolicyRuleId.SerializeToString,

            context__pb2.Empty.FromString,

            options, channel_credentials,

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