New test case are added

# limitations under the License.

from common.proto import telemetry_frontend_pb2

# from common.proto.kpi_manager_pb2 import kpi_id

# from common.proto.kpi_sample_types_pb2 import KpiSampleType

from common.proto.kpi_sample_types_pb2 import KpiSampleType

def collector_id():

def create_collector_id(coll_id_str):

    _collector_id                   = telemetry_frontend_pb2.CollectorId()

    _collector_id.collector_id.uuid = str(1)

    _collector_id.collector_id.uuid = str(coll_id_str)

    return _collector_id

def create_collector_request(coll_id_str):

    _create_collector_request.interval_s                     = float(-1)

    return _create_collector_request

def create_collector_filter(filter):

def create_collector_request_a():

    _create_collector_request_a                    = telemetry_frontend_pb2.Collector()

    _create_collector_request_a.kpi_id.kpi_id.uuid = "-1"

    return _create_collector_request_a

def create_collector_request_b(str_kpi_id, coll_duration_s, coll_interval_s):

    _create_collector_request_b                    = telemetry_frontend_pb2.Collector()

    _create_collector_request_b.kpi_id.kpi_id.uuid = str_kpi_id

    _create_collector_request_b.duration_s         = coll_duration_s

    _create_collector_request_b.interval_s         = coll_interval_s

    return _create_collector_request_b

def create_collector_filter():

    _create_collector_filter = telemetry_frontend_pb2.CollectorFilter()

    new_collector_id                       = _create_collector_filter.collector_id.add()

    new_collector_id.collector_id.uuid     = "COLL1"

    new_kpi_id                             = _create_collector_filter.kpi_id.add()

    new_kpi_id.kpi_id.uuid                 = "KPI1"

    new_device_id                          = _create_collector_filter.device_id.add()

    new_device_id.device_uuid.uuid         = 'DEV1'

    new_service_id                         = _create_collector_filter.service_id.add()

    new_service_id.service_uuid.uuid       = 'SERV1'

    new_slice_id                           = _create_collector_filter.slice_id.add()

    new_slice_id.slice_uuid.uuid           = 'SLC1'

    new_endpoint_id                        = _create_collector_filter.endpoint_id.add()

    new_endpoint_id.endpoint_uuid.uuid     = 'END1'

    new_connection_id                      = _create_collector_filter.connection_id.add()

    new_connection_id.connection_uuid.uuid = 'CON1'

    _create_collector_filter.kpi_sample_type.append(KpiSampleType.KPISAMPLETYPE_PACKETS_RECEIVED)

    return _create_collector_filter

def create_collector_list():

    _create_collector_list = telemetry_frontend_pb2.CollectorList()

    return _create_collector_list

 No newline at end of file