Loading common_requirements.in +3 −0 Original line number Diff line number Diff line Loading @@ -24,3 +24,6 @@ pytest==6.2.5 pytest-benchmark==3.4.1 python-dateutil==2.8.2 pytest-depends==1.0.1 sqlalchemy sqlalchemy_cockroachdb my_deploy.sh +1 −1 Original line number Diff line number Diff line Loading @@ -20,7 +20,7 @@ export TFS_REGISTRY_IMAGES="http://localhost:32000/tfs/" # Set the list of components, separated by spaces, you want to build images for, and deploy. export TFS_COMPONENTS="context device pathcomp service slice nbi webui load_generator" export TFS_COMPONENTS="context device pathcomp service slice nbi webui load_generator qos_profile" # Uncomment to activate Monitoring (old) #export TFS_COMPONENTS="${TFS_COMPONENTS} monitoring" Loading proto/acl_pb2.py 0 → 100644 +90 −0 Original line number Diff line number Diff line # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: acl.proto """Generated protocol buffer code.""" from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool 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() DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\tacl.proto\x12\x03\x61\x63l\"\xbd\x01\n\x08\x41\x63lMatch\x12\x0c\n\x04\x64scp\x18\x01 \x01(\r\x12\x10\n\x08protocol\x18\x02 \x01(\r\x12\x13\n\x0bsrc_address\x18\x03 \x01(\t\x12\x13\n\x0b\x64st_address\x18\x04 \x01(\t\x12\x10\n\x08src_port\x18\x05 \x01(\r\x12\x10\n\x08\x64st_port\x18\x06 \x01(\r\x12\x18\n\x10start_mpls_label\x18\x07 \x01(\r\x12\x16\n\x0e\x65nd_mpls_label\x18\x08 \x01(\r\x12\x11\n\ttcp_flags\x18\t \x01(\t\"i\n\tAclAction\x12\x31\n\x0e\x66orward_action\x18\x01 \x01(\x0e\x32\x19.acl.AclForwardActionEnum\x12)\n\nlog_action\x18\x02 \x01(\x0e\x32\x15.acl.AclLogActionEnum\"r\n\x08\x41\x63lEntry\x12\x13\n\x0bsequence_id\x18\x01 \x01(\r\x12\x13\n\x0b\x64\x65scription\x18\x02 \x01(\t\x12\x1c\n\x05match\x18\x03 \x01(\x0b\x32\r.acl.AclMatch\x12\x1e\n\x06\x61\x63tion\x18\x04 \x01(\x0b\x32\x0e.acl.AclAction\"\x84\x01\n\nAclRuleSet\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\"\n\x04type\x18\x02 \x01(\x0e\x32\x14.acl.AclRuleTypeEnum\x12\x13\n\x0b\x64\x65scription\x18\x03 \x01(\t\x12\x0f\n\x07user_id\x18\x04 \x01(\t\x12\x1e\n\x07\x65ntries\x18\x05 \x03(\x0b\x32\r.acl.AclEntry*\x99\x01\n\x0f\x41\x63lRuleTypeEnum\x12\x19\n\x15\x41\x43LRULETYPE_UNDEFINED\x10\x00\x12\x14\n\x10\x41\x43LRULETYPE_IPV4\x10\x01\x12\x14\n\x10\x41\x43LRULETYPE_IPV6\x10\x02\x12\x12\n\x0e\x41\x43LRULETYPE_L2\x10\x03\x12\x14\n\x10\x41\x43LRULETYPE_MPLS\x10\x04\x12\x15\n\x11\x41\x43LRULETYPE_MIXED\x10\x05*\x97\x01\n\x14\x41\x63lForwardActionEnum\x12!\n\x1d\x41\x43LFORWARDINGACTION_UNDEFINED\x10\x00\x12\x1c\n\x18\x41\x43LFORWARDINGACTION_DROP\x10\x01\x12\x1e\n\x1a\x41\x43LFORWARDINGACTION_ACCEPT\x10\x02\x12\x1e\n\x1a\x41\x43LFORWARDINGACTION_REJECT\x10\x03*_\n\x10\x41\x63lLogActionEnum\x12\x1a\n\x16\x41\x43LLOGACTION_UNDEFINED\x10\x00\x12\x16\n\x12\x41\x43LLOGACTION_NOLOG\x10\x01\x12\x17\n\x13\x41\x43LLOGACTION_SYSLOG\x10\x02\x62\x06proto3') _ACLRULETYPEENUM = DESCRIPTOR.enum_types_by_name['AclRuleTypeEnum'] AclRuleTypeEnum = enum_type_wrapper.EnumTypeWrapper(_ACLRULETYPEENUM) _ACLFORWARDACTIONENUM = DESCRIPTOR.enum_types_by_name['AclForwardActionEnum'] AclForwardActionEnum = enum_type_wrapper.EnumTypeWrapper(_ACLFORWARDACTIONENUM) _ACLLOGACTIONENUM = DESCRIPTOR.enum_types_by_name['AclLogActionEnum'] AclLogActionEnum = enum_type_wrapper.EnumTypeWrapper(_ACLLOGACTIONENUM) ACLRULETYPE_UNDEFINED = 0 ACLRULETYPE_IPV4 = 1 ACLRULETYPE_IPV6 = 2 ACLRULETYPE_L2 = 3 ACLRULETYPE_MPLS = 4 ACLRULETYPE_MIXED = 5 ACLFORWARDINGACTION_UNDEFINED = 0 ACLFORWARDINGACTION_DROP = 1 ACLFORWARDINGACTION_ACCEPT = 2 ACLFORWARDINGACTION_REJECT = 3 ACLLOGACTION_UNDEFINED = 0 ACLLOGACTION_NOLOG = 1 ACLLOGACTION_SYSLOG = 2 _ACLMATCH = DESCRIPTOR.message_types_by_name['AclMatch'] _ACLACTION = DESCRIPTOR.message_types_by_name['AclAction'] _ACLENTRY = DESCRIPTOR.message_types_by_name['AclEntry'] _ACLRULESET = DESCRIPTOR.message_types_by_name['AclRuleSet'] AclMatch = _reflection.GeneratedProtocolMessageType('AclMatch', (_message.Message,), { 'DESCRIPTOR' : _ACLMATCH, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclMatch) }) _sym_db.RegisterMessage(AclMatch) AclAction = _reflection.GeneratedProtocolMessageType('AclAction', (_message.Message,), { 'DESCRIPTOR' : _ACLACTION, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclAction) }) _sym_db.RegisterMessage(AclAction) AclEntry = _reflection.GeneratedProtocolMessageType('AclEntry', (_message.Message,), { 'DESCRIPTOR' : _ACLENTRY, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclEntry) }) _sym_db.RegisterMessage(AclEntry) AclRuleSet = _reflection.GeneratedProtocolMessageType('AclRuleSet', (_message.Message,), { 'DESCRIPTOR' : _ACLRULESET, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclRuleSet) }) _sym_db.RegisterMessage(AclRuleSet) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None _ACLRULETYPEENUM._serialized_start=569 _ACLRULETYPEENUM._serialized_end=722 _ACLFORWARDACTIONENUM._serialized_start=725 _ACLFORWARDACTIONENUM._serialized_end=876 _ACLLOGACTIONENUM._serialized_start=878 _ACLLOGACTIONENUM._serialized_end=973 _ACLMATCH._serialized_start=19 _ACLMATCH._serialized_end=208 _ACLACTION._serialized_start=210 _ACLACTION._serialized_end=315 _ACLENTRY._serialized_start=317 _ACLENTRY._serialized_end=431 _ACLRULESET._serialized_start=434 _ACLRULESET._serialized_end=566 # @@protoc_insertion_point(module_scope) proto/acl_pb2_grpc.py 0 → 100644 +4 −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 proto/analytics_frontend_pb2.py 0 → 100644 +76 −0 Original line number Diff line number Diff line # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: analytics_frontend.proto """Generated protocol buffer code.""" from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool 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() import context_pb2 as context__pb2 import kpi_manager_pb2 as kpi__manager__pb2 DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x18\x61nalytics_frontend.proto\x12\x12\x61nalytics_frontend\x1a\rcontext.proto\x1a\x11kpi_manager.proto\"0\n\nAnalyzerId\x12\"\n\x0b\x61nalyzer_id\x18\x01 \x01(\x0b\x32\r.context.Uuid\"\xa8\x02\n\x08\x41nalyzer\x12\x16\n\x0e\x61lgorithm_name\x18\x01 \x01(\t\x12)\n\rinput_kpi_ids\x18\x02 \x03(\x0b\x32\x12.kpi_manager.KpiId\x12*\n\x0eoutput_kpi_ids\x18\x03 \x03(\x0b\x32\x12.kpi_manager.KpiId\x12\x41\n\x0eoperation_mode\x18\x04 \x01(\x0e\x32).analytics_frontend.AnalyzerOperationMode\x12\x1c\n\x14\x62\x61tch_min_duration_s\x18\x05 \x01(\x02\x12\x1c\n\x14\x62\x61tch_max_duration_s\x18\x06 \x01(\x02\x12\x16\n\x0e\x62\x61tch_min_size\x18\x07 \x01(\x04\x12\x16\n\x0e\x62\x61tch_max_size\x18\x08 \x01(\x04\"\xb5\x01\n\x0e\x41nalyzerFilter\x12\x33\n\x0b\x61nalyzer_id\x18\x01 \x03(\x0b\x32\x1e.analytics_frontend.AnalyzerId\x12\x17\n\x0f\x61lgorithm_names\x18\x02 \x03(\t\x12)\n\rinput_kpi_ids\x18\x03 \x03(\x0b\x32\x12.kpi_manager.KpiId\x12*\n\x0eoutput_kpi_ids\x18\x04 \x03(\x0b\x32\x12.kpi_manager.KpiId\"C\n\x0c\x41nalyzerList\x12\x33\n\ranalyzer_list\x18\x01 \x03(\x0b\x32\x1c.analytics_frontend.Analyzer*]\n\x15\x41nalyzerOperationMode\x12\x1f\n\x1b\x41NALYZEROPERATIONMODE_BATCH\x10\x00\x12#\n\x1f\x41NALYZEROPERATIONMODE_STREAMING\x10\x01\x32\x88\x02\n\x18\x41nalyticsFrontendService\x12O\n\rStartAnalyzer\x12\x1c.analytics_frontend.Analyzer\x1a\x1e.analytics_frontend.AnalyzerId\"\x00\x12@\n\x0cStopAnalyzer\x12\x1e.analytics_frontend.AnalyzerId\x1a\x0e.context.Empty\"\x00\x12Y\n\x0fSelectAnalyzers\x12\".analytics_frontend.AnalyzerFilter\x1a .analytics_frontend.AnalyzerList\"\x00\x62\x06proto3') _ANALYZEROPERATIONMODE = DESCRIPTOR.enum_types_by_name['AnalyzerOperationMode'] AnalyzerOperationMode = enum_type_wrapper.EnumTypeWrapper(_ANALYZEROPERATIONMODE) ANALYZEROPERATIONMODE_BATCH = 0 ANALYZEROPERATIONMODE_STREAMING = 1 _ANALYZERID = DESCRIPTOR.message_types_by_name['AnalyzerId'] _ANALYZER = DESCRIPTOR.message_types_by_name['Analyzer'] _ANALYZERFILTER = DESCRIPTOR.message_types_by_name['AnalyzerFilter'] _ANALYZERLIST = DESCRIPTOR.message_types_by_name['AnalyzerList'] AnalyzerId = _reflection.GeneratedProtocolMessageType('AnalyzerId', (_message.Message,), { 'DESCRIPTOR' : _ANALYZERID, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.AnalyzerId) }) _sym_db.RegisterMessage(AnalyzerId) Analyzer = _reflection.GeneratedProtocolMessageType('Analyzer', (_message.Message,), { 'DESCRIPTOR' : _ANALYZER, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.Analyzer) }) _sym_db.RegisterMessage(Analyzer) AnalyzerFilter = _reflection.GeneratedProtocolMessageType('AnalyzerFilter', (_message.Message,), { 'DESCRIPTOR' : _ANALYZERFILTER, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.AnalyzerFilter) }) _sym_db.RegisterMessage(AnalyzerFilter) AnalyzerList = _reflection.GeneratedProtocolMessageType('AnalyzerList', (_message.Message,), { 'DESCRIPTOR' : _ANALYZERLIST, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.AnalyzerList) }) _sym_db.RegisterMessage(AnalyzerList) _ANALYTICSFRONTENDSERVICE = DESCRIPTOR.services_by_name['AnalyticsFrontendService'] if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None _ANALYZEROPERATIONMODE._serialized_start=684 _ANALYZEROPERATIONMODE._serialized_end=777 _ANALYZERID._serialized_start=82 _ANALYZERID._serialized_end=130 _ANALYZER._serialized_start=133 _ANALYZER._serialized_end=429 _ANALYZERFILTER._serialized_start=432 _ANALYZERFILTER._serialized_end=613 _ANALYZERLIST._serialized_start=615 _ANALYZERLIST._serialized_end=682 _ANALYTICSFRONTENDSERVICE._serialized_start=780 _ANALYTICSFRONTENDSERVICE._serialized_end=1044 # @@protoc_insertion_point(module_scope) Loading
common_requirements.in +3 −0 Original line number Diff line number Diff line Loading @@ -24,3 +24,6 @@ pytest==6.2.5 pytest-benchmark==3.4.1 python-dateutil==2.8.2 pytest-depends==1.0.1 sqlalchemy sqlalchemy_cockroachdb
my_deploy.sh +1 −1 Original line number Diff line number Diff line Loading @@ -20,7 +20,7 @@ export TFS_REGISTRY_IMAGES="http://localhost:32000/tfs/" # Set the list of components, separated by spaces, you want to build images for, and deploy. export TFS_COMPONENTS="context device pathcomp service slice nbi webui load_generator" export TFS_COMPONENTS="context device pathcomp service slice nbi webui load_generator qos_profile" # Uncomment to activate Monitoring (old) #export TFS_COMPONENTS="${TFS_COMPONENTS} monitoring" Loading
proto/acl_pb2.py 0 → 100644 +90 −0 Original line number Diff line number Diff line # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: acl.proto """Generated protocol buffer code.""" from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool 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() DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\tacl.proto\x12\x03\x61\x63l\"\xbd\x01\n\x08\x41\x63lMatch\x12\x0c\n\x04\x64scp\x18\x01 \x01(\r\x12\x10\n\x08protocol\x18\x02 \x01(\r\x12\x13\n\x0bsrc_address\x18\x03 \x01(\t\x12\x13\n\x0b\x64st_address\x18\x04 \x01(\t\x12\x10\n\x08src_port\x18\x05 \x01(\r\x12\x10\n\x08\x64st_port\x18\x06 \x01(\r\x12\x18\n\x10start_mpls_label\x18\x07 \x01(\r\x12\x16\n\x0e\x65nd_mpls_label\x18\x08 \x01(\r\x12\x11\n\ttcp_flags\x18\t \x01(\t\"i\n\tAclAction\x12\x31\n\x0e\x66orward_action\x18\x01 \x01(\x0e\x32\x19.acl.AclForwardActionEnum\x12)\n\nlog_action\x18\x02 \x01(\x0e\x32\x15.acl.AclLogActionEnum\"r\n\x08\x41\x63lEntry\x12\x13\n\x0bsequence_id\x18\x01 \x01(\r\x12\x13\n\x0b\x64\x65scription\x18\x02 \x01(\t\x12\x1c\n\x05match\x18\x03 \x01(\x0b\x32\r.acl.AclMatch\x12\x1e\n\x06\x61\x63tion\x18\x04 \x01(\x0b\x32\x0e.acl.AclAction\"\x84\x01\n\nAclRuleSet\x12\x0c\n\x04name\x18\x01 \x01(\t\x12\"\n\x04type\x18\x02 \x01(\x0e\x32\x14.acl.AclRuleTypeEnum\x12\x13\n\x0b\x64\x65scription\x18\x03 \x01(\t\x12\x0f\n\x07user_id\x18\x04 \x01(\t\x12\x1e\n\x07\x65ntries\x18\x05 \x03(\x0b\x32\r.acl.AclEntry*\x99\x01\n\x0f\x41\x63lRuleTypeEnum\x12\x19\n\x15\x41\x43LRULETYPE_UNDEFINED\x10\x00\x12\x14\n\x10\x41\x43LRULETYPE_IPV4\x10\x01\x12\x14\n\x10\x41\x43LRULETYPE_IPV6\x10\x02\x12\x12\n\x0e\x41\x43LRULETYPE_L2\x10\x03\x12\x14\n\x10\x41\x43LRULETYPE_MPLS\x10\x04\x12\x15\n\x11\x41\x43LRULETYPE_MIXED\x10\x05*\x97\x01\n\x14\x41\x63lForwardActionEnum\x12!\n\x1d\x41\x43LFORWARDINGACTION_UNDEFINED\x10\x00\x12\x1c\n\x18\x41\x43LFORWARDINGACTION_DROP\x10\x01\x12\x1e\n\x1a\x41\x43LFORWARDINGACTION_ACCEPT\x10\x02\x12\x1e\n\x1a\x41\x43LFORWARDINGACTION_REJECT\x10\x03*_\n\x10\x41\x63lLogActionEnum\x12\x1a\n\x16\x41\x43LLOGACTION_UNDEFINED\x10\x00\x12\x16\n\x12\x41\x43LLOGACTION_NOLOG\x10\x01\x12\x17\n\x13\x41\x43LLOGACTION_SYSLOG\x10\x02\x62\x06proto3') _ACLRULETYPEENUM = DESCRIPTOR.enum_types_by_name['AclRuleTypeEnum'] AclRuleTypeEnum = enum_type_wrapper.EnumTypeWrapper(_ACLRULETYPEENUM) _ACLFORWARDACTIONENUM = DESCRIPTOR.enum_types_by_name['AclForwardActionEnum'] AclForwardActionEnum = enum_type_wrapper.EnumTypeWrapper(_ACLFORWARDACTIONENUM) _ACLLOGACTIONENUM = DESCRIPTOR.enum_types_by_name['AclLogActionEnum'] AclLogActionEnum = enum_type_wrapper.EnumTypeWrapper(_ACLLOGACTIONENUM) ACLRULETYPE_UNDEFINED = 0 ACLRULETYPE_IPV4 = 1 ACLRULETYPE_IPV6 = 2 ACLRULETYPE_L2 = 3 ACLRULETYPE_MPLS = 4 ACLRULETYPE_MIXED = 5 ACLFORWARDINGACTION_UNDEFINED = 0 ACLFORWARDINGACTION_DROP = 1 ACLFORWARDINGACTION_ACCEPT = 2 ACLFORWARDINGACTION_REJECT = 3 ACLLOGACTION_UNDEFINED = 0 ACLLOGACTION_NOLOG = 1 ACLLOGACTION_SYSLOG = 2 _ACLMATCH = DESCRIPTOR.message_types_by_name['AclMatch'] _ACLACTION = DESCRIPTOR.message_types_by_name['AclAction'] _ACLENTRY = DESCRIPTOR.message_types_by_name['AclEntry'] _ACLRULESET = DESCRIPTOR.message_types_by_name['AclRuleSet'] AclMatch = _reflection.GeneratedProtocolMessageType('AclMatch', (_message.Message,), { 'DESCRIPTOR' : _ACLMATCH, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclMatch) }) _sym_db.RegisterMessage(AclMatch) AclAction = _reflection.GeneratedProtocolMessageType('AclAction', (_message.Message,), { 'DESCRIPTOR' : _ACLACTION, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclAction) }) _sym_db.RegisterMessage(AclAction) AclEntry = _reflection.GeneratedProtocolMessageType('AclEntry', (_message.Message,), { 'DESCRIPTOR' : _ACLENTRY, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclEntry) }) _sym_db.RegisterMessage(AclEntry) AclRuleSet = _reflection.GeneratedProtocolMessageType('AclRuleSet', (_message.Message,), { 'DESCRIPTOR' : _ACLRULESET, '__module__' : 'acl_pb2' # @@protoc_insertion_point(class_scope:acl.AclRuleSet) }) _sym_db.RegisterMessage(AclRuleSet) if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None _ACLRULETYPEENUM._serialized_start=569 _ACLRULETYPEENUM._serialized_end=722 _ACLFORWARDACTIONENUM._serialized_start=725 _ACLFORWARDACTIONENUM._serialized_end=876 _ACLLOGACTIONENUM._serialized_start=878 _ACLLOGACTIONENUM._serialized_end=973 _ACLMATCH._serialized_start=19 _ACLMATCH._serialized_end=208 _ACLACTION._serialized_start=210 _ACLACTION._serialized_end=315 _ACLENTRY._serialized_start=317 _ACLENTRY._serialized_end=431 _ACLRULESET._serialized_start=434 _ACLRULESET._serialized_end=566 # @@protoc_insertion_point(module_scope)
proto/acl_pb2_grpc.py 0 → 100644 +4 −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
proto/analytics_frontend_pb2.py 0 → 100644 +76 −0 Original line number Diff line number Diff line # -*- coding: utf-8 -*- # Generated by the protocol buffer compiler. DO NOT EDIT! # source: analytics_frontend.proto """Generated protocol buffer code.""" from google.protobuf.internal import enum_type_wrapper from google.protobuf import descriptor as _descriptor from google.protobuf import descriptor_pool as _descriptor_pool 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() import context_pb2 as context__pb2 import kpi_manager_pb2 as kpi__manager__pb2 DESCRIPTOR = _descriptor_pool.Default().AddSerializedFile(b'\n\x18\x61nalytics_frontend.proto\x12\x12\x61nalytics_frontend\x1a\rcontext.proto\x1a\x11kpi_manager.proto\"0\n\nAnalyzerId\x12\"\n\x0b\x61nalyzer_id\x18\x01 \x01(\x0b\x32\r.context.Uuid\"\xa8\x02\n\x08\x41nalyzer\x12\x16\n\x0e\x61lgorithm_name\x18\x01 \x01(\t\x12)\n\rinput_kpi_ids\x18\x02 \x03(\x0b\x32\x12.kpi_manager.KpiId\x12*\n\x0eoutput_kpi_ids\x18\x03 \x03(\x0b\x32\x12.kpi_manager.KpiId\x12\x41\n\x0eoperation_mode\x18\x04 \x01(\x0e\x32).analytics_frontend.AnalyzerOperationMode\x12\x1c\n\x14\x62\x61tch_min_duration_s\x18\x05 \x01(\x02\x12\x1c\n\x14\x62\x61tch_max_duration_s\x18\x06 \x01(\x02\x12\x16\n\x0e\x62\x61tch_min_size\x18\x07 \x01(\x04\x12\x16\n\x0e\x62\x61tch_max_size\x18\x08 \x01(\x04\"\xb5\x01\n\x0e\x41nalyzerFilter\x12\x33\n\x0b\x61nalyzer_id\x18\x01 \x03(\x0b\x32\x1e.analytics_frontend.AnalyzerId\x12\x17\n\x0f\x61lgorithm_names\x18\x02 \x03(\t\x12)\n\rinput_kpi_ids\x18\x03 \x03(\x0b\x32\x12.kpi_manager.KpiId\x12*\n\x0eoutput_kpi_ids\x18\x04 \x03(\x0b\x32\x12.kpi_manager.KpiId\"C\n\x0c\x41nalyzerList\x12\x33\n\ranalyzer_list\x18\x01 \x03(\x0b\x32\x1c.analytics_frontend.Analyzer*]\n\x15\x41nalyzerOperationMode\x12\x1f\n\x1b\x41NALYZEROPERATIONMODE_BATCH\x10\x00\x12#\n\x1f\x41NALYZEROPERATIONMODE_STREAMING\x10\x01\x32\x88\x02\n\x18\x41nalyticsFrontendService\x12O\n\rStartAnalyzer\x12\x1c.analytics_frontend.Analyzer\x1a\x1e.analytics_frontend.AnalyzerId\"\x00\x12@\n\x0cStopAnalyzer\x12\x1e.analytics_frontend.AnalyzerId\x1a\x0e.context.Empty\"\x00\x12Y\n\x0fSelectAnalyzers\x12\".analytics_frontend.AnalyzerFilter\x1a .analytics_frontend.AnalyzerList\"\x00\x62\x06proto3') _ANALYZEROPERATIONMODE = DESCRIPTOR.enum_types_by_name['AnalyzerOperationMode'] AnalyzerOperationMode = enum_type_wrapper.EnumTypeWrapper(_ANALYZEROPERATIONMODE) ANALYZEROPERATIONMODE_BATCH = 0 ANALYZEROPERATIONMODE_STREAMING = 1 _ANALYZERID = DESCRIPTOR.message_types_by_name['AnalyzerId'] _ANALYZER = DESCRIPTOR.message_types_by_name['Analyzer'] _ANALYZERFILTER = DESCRIPTOR.message_types_by_name['AnalyzerFilter'] _ANALYZERLIST = DESCRIPTOR.message_types_by_name['AnalyzerList'] AnalyzerId = _reflection.GeneratedProtocolMessageType('AnalyzerId', (_message.Message,), { 'DESCRIPTOR' : _ANALYZERID, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.AnalyzerId) }) _sym_db.RegisterMessage(AnalyzerId) Analyzer = _reflection.GeneratedProtocolMessageType('Analyzer', (_message.Message,), { 'DESCRIPTOR' : _ANALYZER, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.Analyzer) }) _sym_db.RegisterMessage(Analyzer) AnalyzerFilter = _reflection.GeneratedProtocolMessageType('AnalyzerFilter', (_message.Message,), { 'DESCRIPTOR' : _ANALYZERFILTER, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.AnalyzerFilter) }) _sym_db.RegisterMessage(AnalyzerFilter) AnalyzerList = _reflection.GeneratedProtocolMessageType('AnalyzerList', (_message.Message,), { 'DESCRIPTOR' : _ANALYZERLIST, '__module__' : 'analytics_frontend_pb2' # @@protoc_insertion_point(class_scope:analytics_frontend.AnalyzerList) }) _sym_db.RegisterMessage(AnalyzerList) _ANALYTICSFRONTENDSERVICE = DESCRIPTOR.services_by_name['AnalyticsFrontendService'] if _descriptor._USE_C_DESCRIPTORS == False: DESCRIPTOR._options = None _ANALYZEROPERATIONMODE._serialized_start=684 _ANALYZEROPERATIONMODE._serialized_end=777 _ANALYZERID._serialized_start=82 _ANALYZERID._serialized_end=130 _ANALYZER._serialized_start=133 _ANALYZER._serialized_end=429 _ANALYZERFILTER._serialized_start=432 _ANALYZERFILTER._serialized_end=613 _ANALYZERLIST._serialized_start=615 _ANALYZERLIST._serialized_end=682 _ANALYTICSFRONTENDSERVICE._serialized_start=780 _ANALYTICSFRONTENDSERVICE._serialized_end=1044 # @@protoc_insertion_point(module_scope)
