Commit 728bfc57 authored by Bashar's avatar Bashar

Added ML-Model System Components

parent 51d9b90f
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ChangeListManager">
<list default="true" id="b80be3d1-f1d4-4ae8-a7ab-73234eebd01a" name="Changes" comment="">
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/Processing/src/main/java/com/example/Processing/entities/EnrichedTrap.java" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/Processing/src/main/java/com/example/Processing/entities/EnrichedTrap.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/Processing/src/main/java/com/example/Processing/services/ElasticService.java" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/Processing/src/main/java/com/example/Processing/services/ElasticService.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/Processing/src/main/resources/utils/policy.json" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/Processing/src/main/resources/utils/policy.json" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/SnmpReceiverApplication.java" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/SnmpReceiverApplication.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/component/SnmpListener.java" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/component/SnmpListener.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/src/main/resources/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/src/main/resources/application.properties" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/target/classes/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/target/classes/application.properties" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/target/classes/com/example/SnmpReciever/SnmpReceiverApplication.class" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/target/classes/com/example/SnmpReciever/SnmpReceiverApplication.class" afterDir="false" />
<change beforePath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/target/classes/com/example/SnmpReciever/component/SnmpListener.class" beforeDir="false" afterPath="$PROJECT_DIR$/SNMP_Pipeline/SnmpReciever/target/classes/com/example/SnmpReciever/component/SnmpListener.class" afterDir="false" />
</list>
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" />
</component>
<component name="Git.Settings">
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
</component>
<component name="ProjectId" id="2TJbSnMj4iI9QrtArEhKJmBZSmX" />
<component name="ProjectViewState">
<option name="hideEmptyMiddlePackages" value="true" />
<option name="showLibraryContents" value="true" />
</component>
<component name="PropertiesComponent">{
&quot;keyToString&quot;: {
&quot;RunOnceActivity.OpenProjectViewOnStart&quot;: &quot;true&quot;,
&quot;RunOnceActivity.ShowReadmeOnStart&quot;: &quot;true&quot;
}
}</component>
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
<component name="Vcs.Log.Tabs.Properties">
<option name="TAB_STATES">
<map>
<entry key="MAIN">
<value>
<State />
</value>
</entry>
</map>
</option>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="AutoImportSettings">
<option name="autoReloadType" value="SELECTIVE" />
</component>
<component name="ChangeListManager">
<list default="true" id="8598d397-300e-41fb-884a-064d6ea49cb9" name="Changes" comment="">
<change beforePath="$PROJECT_DIR$/../SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/SnmpListener.java" beforeDir="false" afterPath="$PROJECT_DIR$/../SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/SnmpListener.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/../SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/services/KafkaService.java" beforeDir="false" afterPath="$PROJECT_DIR$/../SNMP_Pipeline/SnmpReciever/src/main/java/com/example/SnmpReciever/services/KafkaService.java" afterDir="false" />
<change beforePath="$PROJECT_DIR$/../SNMP_Pipeline/SnmpReciever/src/main/resources/application.properties" beforeDir="false" afterPath="$PROJECT_DIR$/../SNMP_Pipeline/SnmpReciever/src/main/resources/application.properties" afterDir="false" />
<change beforePath="$PROJECT_DIR$/../SNMP_Pipeline/kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/services/RethinkDBService.class" beforeDir="false" afterPath="$PROJECT_DIR$/../SNMP_Pipeline/kafkaConsumerSNMP/target/classes/com/example/kafkaConsumerSNMP/services/RethinkDBService.class" afterDir="false" />
</list>
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" />
</component>
<component name="Git.Settings">
<option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$/.." />
</component>
<component name="ProjectId" id="2SCsRaeT2belHdAgTRAhh4I6p81" />
<component name="ProjectViewState">
<option name="hideEmptyMiddlePackages" value="true" />
<option name="showLibraryContents" value="true" />
</component>
<component name="PropertiesComponent">{
&quot;keyToString&quot;: {
&quot;RunOnceActivity.OpenProjectViewOnStart&quot;: &quot;true&quot;,
&quot;RunOnceActivity.ShowReadmeOnStart&quot;: &quot;true&quot;
}
}</component>
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
<component name="Vcs.Log.Tabs.Properties">
<option name="TAB_STATES">
<map>
<entry key="MAIN">
<value>
<State />
</value>
</entry>
</map>
</option>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="AutoImportSettings">
<option name="autoReloadType" value="SELECTIVE" />
</component>
<component name="ChangeListManager">
<list default="true" id="ee566820-41c3-4b00-b503-2c67f6bff446" name="Changes" comment="" />
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" />
</component>
<component name="MavenImportPreferences">
<option name="generalSettings">
<MavenGeneralSettings>
<option name="useMavenConfig" value="true" />
</MavenGeneralSettings>
</option>
</component>
<component name="ProjectId" id="2ToSrVjBo2tCVkShhA3ZMGGwlxw" />
<component name="ProjectViewState">
<option name="hideEmptyMiddlePackages" value="true" />
<option name="showLibraryContents" value="true" />
</component>
<component name="PropertiesComponent"><![CDATA[{
"keyToString": {
"RunOnceActivity.OpenProjectViewOnStart": "true",
"RunOnceActivity.ShowReadmeOnStart": "true"
}
}]]></component>
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
</project>
\ No newline at end of file
# Default ignored files
/shelf/
/workspace.xml
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile default="true" name="Default" enabled="true" />
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="event-correlation-service" />
</profile>
</annotationProcessing>
</component>
<component name="JavacSettings">
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="event-correlation-service" options="-parameters" />
</option>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
# Read Me First
The following was discovered as part of building this project:
* The original package name 'com.example.event-correlation-service' is invalid and this project uses 'com.example.eventcorrelationservice' instead.
# Getting Started
### Reference Documentation
For further reference, please consider the following sections:
* [Official Apache Maven documentation](https://maven.apache.org/guides/index.html)
* [Spring Boot Maven Plugin Reference Guide](https://docs.spring.io/spring-boot/docs/3.1.2/maven-plugin/reference/html/)
* [Create an OCI image](https://docs.spring.io/spring-boot/docs/3.1.2/maven-plugin/reference/html/#build-image)
server.port=7373
spring.application.name=FEEDBACK-SERVICE
eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
#eureka.instance.hostname=192.168.24.47
\ No newline at end of file
{
"index_patterns": ["knowledge-base*"],
"composed_of": [ "knowledge-base-setting", "knowledge-base-mapping"],
"priority": 700,
"_meta": {
"description": "Template for my knowledge base data",
"my-custom-meta-field": "More arbitrary metadata"
}
}
\ No newline at end of file
{
"mappings": {
"properties": {
"Device_uptime": {
"type": "wildcard"
},
"EX_Bits_received": {
"type": "wildcard"
},
"EX_Bits_sent": {
"type": "wildcard"
},
"EX_Inbound_packets_discarded": {
"type": "wildcard"
},
"EX_Inbound_packets_with_errors": {
"type": "wildcard"
},
"EX_Interface_type": {
"type": "wildcard"
},
"EX_Operational_status": {
"type": "wildcard"
},
"EX_Outbound_packets_discarded": {
"type": "wildcard"
},
"EX_Outbound_packets_with_errors": {
"type": "wildcard"
},
"EX_Speed": {
"type": "wildcard"
},
"ICMP_loss": {
"type": "wildcard"
},
"ICMP_ping": {
"type": "wildcard"
},
"ICMP_response_time": {
"type": "wildcard"
},
"IN_Bits_received": {
"type": "wildcard"
},
"IN_Bits_sent": {
"type": "wildcard"
},
"IN_Inbound_packets_discarded": {
"type": "wildcard"
},
"IN_Inbound_packets_with_errors": {
"type": "wildcard"
},
"IN_Interface_type": {
"type": "wildcard"
},
"IN_Operational_status": {
"type": "wildcard"
},
"IN_Outbound_packets_discarded": {
"type": "wildcard"
},
"IN_Outbound_packets_with_errors": {
"type": "wildcard"
},
"IN_Speed": {
"type": "wildcard"
},
"P_Bits_received": {
"type": "wildcard"
},
"P_Bits_sent": {
"type": "wildcard"
},
"P_Inbound_packets_discarded": {
"type": "wildcard"
},
"P_Inbound_packets_with_errors": {
"type": "wildcard"
},
"P_Interface_type": {
"type": "wildcard"
},
"P_Operational_status": {
"type": "wildcard"
},
"P_Outbound_packets_discarded": {
"type": "wildcard"
},
"P_Outbound_packets_with_errors": {
"type": "wildcard"
},
"P_Speed": {
"type": "wildcard"
},
"SNMP_availability": {
"type": "wildcard"
},
"class": {
"type": "wildcard"
},
"range": {
"type": "wildcard"
},
"timestamp": {
"type": "date",
"format": "date_optional_time||epoch_second"
}
}
}
}
\ No newline at end of file
{
"phases": {
"hot": {
"min_age": "0ms",
"actions": {
"set_priority": {
"priority": 100
},
"rollover": {
"max_primary_shard_size": "50gb",
"max_age": "60m"
}
}
},
"warm": {
"min_age": "60m",
"actions": {
"set_priority": {
"priority": 50
}
}
},
"cold": {
"min_age": "60m",
"actions": {
"set_priority": {
"priority": 0
}
}
}
}
}
\ No newline at end of file
{
"settings": {
"index.lifecycle.name": "knowledge-base-policy",
"index.number_of_shards": 1,
"index.number_of_replicas": 0
}
}
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ChangeListManager">
<list default="true" id="86fae3e4-0459-41fd-9a67-3882ba2fba07" name="Changes" comment="" />
<option name="SHOW_DIALOG" value="false" />
<option name="HIGHLIGHT_CONFLICTS" value="true" />
<option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
<option name="LAST_RESOLUTION" value="IGNORE" />
</component>
<component name="FileTemplateManagerImpl">
<option name="RECENT_TEMPLATES">
<list>
<option value="Python Script" />
</list>
</option>
</component>
<component name="GitSEFilterConfiguration">
<file-type-list>
<filtered-out-file-type name="LOCAL_BRANCH" />
<filtered-out-file-type name="REMOTE_BRANCH" />
<filtered-out-file-type name="TAG" />
<filtered-out-file-type name="COMMIT_BY_MESSAGE" />
</file-type-list>
</component>
<component name="MarkdownSettingsMigration">
<option name="stateVersion" value="1" />
</component>
<component name="ProjectId" id="2T7pr1RyWmnylkcTQkZoUYymmpo" />
<component name="ProjectViewState">
<option name="hideEmptyMiddlePackages" value="true" />
<option name="showLibraryContents" value="true" />
</component>
<component name="PropertiesComponent">
<property name="RunOnceActivity.OpenProjectViewOnStart" value="true" />
<property name="RunOnceActivity.ShowReadmeOnStart" value="true" />
<property name="last_opened_file_path" value="$PROJECT_DIR$" />
</component>
<component name="RecentsManager">
<key name="CopyFile.RECENT_KEYS">
<recent name="C:\Users\HP\PycharmProjects\model-service" />
</key>
</component>
<component name="RunManager" selected="Python.main">
<configuration name="eureka" type="PythonConfigurationType" factoryName="Python" temporary="true" nameIsGenerated="true">
<module name="model-service" />
<option name="INTERPRETER_OPTIONS" value="" />
<option name="PARENT_ENVS" value="true" />
<envs>
<env name="PYTHONUNBUFFERED" value="1" />
</envs>
<option name="SDK_HOME" value="" />
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
<option name="IS_MODULE_SDK" value="true" />
<option name="ADD_CONTENT_ROOTS" value="true" />
<option name="ADD_SOURCE_ROOTS" value="true" />
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/eureka.py" />
<option name="PARAMETERS" value="" />
<option name="SHOW_COMMAND_LINE" value="false" />
<option name="EMULATE_TERMINAL" value="false" />
<option name="MODULE_MODE" value="false" />
<option name="REDIRECT_INPUT" value="false" />
<option name="INPUT_FILE" value="" />
<method v="2" />
</configuration>
<configuration name="main" type="PythonConfigurationType" factoryName="Python" nameIsGenerated="true">
<module name="model-service" />
<option name="INTERPRETER_OPTIONS" value="" />
<option name="PARENT_ENVS" value="true" />
<envs>
<env name="PYTHONUNBUFFERED" value="1" />
</envs>
<option name="SDK_HOME" value="" />
<option name="WORKING_DIRECTORY" value="$PROJECT_DIR$" />
<option name="IS_MODULE_SDK" value="true" />
<option name="ADD_CONTENT_ROOTS" value="true" />
<option name="ADD_SOURCE_ROOTS" value="true" />
<option name="SCRIPT_NAME" value="$PROJECT_DIR$/main.py" />
<option name="PARAMETERS" value="" />
<option name="SHOW_COMMAND_LINE" value="false" />
<option name="EMULATE_TERMINAL" value="false" />
<option name="MODULE_MODE" value="false" />
<option name="REDIRECT_INPUT" value="false" />
<option name="INPUT_FILE" value="" />
<method v="2" />
</configuration>
<recent_temporary>
<list>
<item itemvalue="Python.eureka" />
</list>
</recent_temporary>
</component>
<component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
<component name="TaskManager">
<task active="true" id="Default" summary="Default task">
<changelist id="86fae3e4-0459-41fd-9a67-3882ba2fba07" name="Changes" comment="" />
<created>1690404170065</created>
<option name="number" value="Default" />
<option name="presentableId" value="Default" />
<updated>1690404170065</updated>
</task>
<servers />
</component>
</project>
\ No newline at end of file
# Default ignored files
/shelf/
/workspace.xml
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile default="true" name="Default" enabled="true" />
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="stream-service" />
</profile>
</annotationProcessing>
</component>
<component name="JavacSettings">
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="stream-service" options="-parameters" />
</option>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
# Getting Started
### Reference Documentation
For further reference, please consider the following sections:
* [Official Apache Maven documentation](https://maven.apache.org/guides/index.html)
* [Spring Boot Maven Plugin Reference Guide](https://docs.spring.io/spring-boot/docs/3.1.1/maven-plugin/reference/html/)
* [Create an OCI image](https://docs.spring.io/spring-boot/docs/3.1.1/maven-plugin/reference/html/#build-image)
This diff is collapsed.
server.port = 7777
spring.kafka.bootstrap-servers=http://172.29.3.220:9092
spring.kafka.template.default-topic=Stream-Instance
spring.kafka.consumer.group-id= Stream-Instance-Id
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.cloud.circuitbreaker.resilience4j.enabled=true
management.health.circuitbreakers.enabled=true
management.health.elasticsearch.enabled=false
management.endpoints.web.exposure.include=*
management.endpoint.health.show-details=always
#Resilinece4j Properties
resilience4j.circuitbreaker.instances.model-service.registerHealthIndicator=true
resilience4j.circuitbreaker.instances.model-service.event-consumer-buffer-size=10
resilience4j.circuitbreaker.instances.model-service.slidingWindowType=COUNT_BASED
resilience4j.circuitbreaker.instances.model-service.slidingWindowSize=5
resilience4j.circuitbreaker.instances.model-service.failureRateThreshold=30
resilience4j.circuitbreaker.instances.model-service.waitDurationInOpenState=5s
resilience4j.circuitbreaker.instances.model-service.permittedNumberOfCallsInHalfOpenState=3
resilience4j.circuitbreaker.instances.model-service.automaticTransitionFromOpenToHalfOpenEnabled=true
##Resilience4J Timeout Properties
#resilience4j.timelimiter.instances.model-service.timeout-duration=3s
#
##Resilience4J Retry Properties
#resilience4j.retry.instances.model-service.max-attempts=3
#resilience4j.retry.instances.model-service.wait-duration=5s
spring.application.name=MODEL-STREAM-SERVICE
eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
eureka.instance.hostname=192.168.24.47
\ No newline at end of file
{
"index_patterns": ["model-data-stream*"],
"data_stream": { },
"composed_of": [ "model-setting", "model-mapping"],
"priority": 670,
"_meta": {
"description": "Template for my time series data",
"my-custom-meta-field": "More arbitrary metadata"
}
}
\ No newline at end of file
{
"mappings": {
"properties": {
"Device_uptime": {
"type": "wildcard"
},
"EX_Bits_received": {
"type": "wildcard"
},
"EX_Bits_sent": {
"type": "wildcard"
},
"EX_Inbound_packets_discarded": {
"type": "wildcard"
},
"EX_Inbound_packets_with_errors": {
"type": "wildcard"
},
"EX_Interface_type": {
"type": "wildcard"
},
"EX_Operational_status": {
"type": "wildcard"
},
"EX_Outbound_packets_discarded": {
"type": "wildcard"
},
"EX_Outbound_packets_with_errors": {
"type": "wildcard"
},
"EX_Speed": {
"type": "wildcard"
},
"ICMP_loss": {
"type": "wildcard"
},
"ICMP_ping": {
"type": "wildcard"
},
"ICMP_response_time": {
"type": "wildcard"
},
"IN_Bits_received": {
"type": "wildcard"
},
"IN_Bits_sent": {
"type": "wildcard"
},
"IN_Inbound_packets_discarded": {
"type": "wildcard"
},
"IN_Inbound_packets_with_errors": {
"type": "wildcard"
},
"IN_Interface_type": {
"type": "wildcard"
},
"IN_Operational_status": {
"type": "wildcard"
},
"IN_Outbound_packets_discarded": {
"type": "wildcard"
},
"IN_Outbound_packets_with_errors": {
"type": "wildcard"
},
"IN_Speed": {
"type": "wildcard"
},
"P_Bits_received": {
"type": "wildcard"
},
"P_Bits_sent": {
"type": "wildcard"
},
"P_Inbound_packets_discarded": {
"type": "wildcard"
},
"P_Inbound_packets_with_errors": {
"type": "wildcard"
},
"P_Interface_type": {
"type": "wildcard"
},
"P_Operational_status": {
"type": "wildcard"
},
"P_Outbound_packets_discarded": {
"type": "wildcard"
},
"P_Outbound_packets_with_errors": {
"type": "wildcard"
},
"P_Speed": {
"type": "wildcard"
},
"SNMP_availability": {
"type": "wildcard"
},
"class": {
"type": "wildcard"
},
"range": {
"type": "wildcard"
},
"timestamp": {
"type": "date",
"format": "date_optional_time||epoch_second"
},
"@timestamp": {
"type": "date",
"format": "date_optional_time||epoch_second"
}
}
}
}
\ No newline at end of file
{
"phases": {
"hot": {
"min_age": "0ms",
"actions": {
"set_priority": {
"priority": 100
},
"rollover": {
"max_primary_shard_size": "50gb",
"max_age": "60m"
}
}
},
"warm": {
"min_age": "60m",
"actions": {
"set_priority": {
"priority": 50
}
}
},
"cold": {
"min_age": "60m",
"actions": {
"set_priority": {
"priority": 0
}
}
}
}
}
\ No newline at end of file
{
"settings": {
"index.lifecycle.name": "model-policy",
"index.number_of_shards": 1,
"index.number_of_replicas": 0
}
}
\ No newline at end of file
# Default ignored files
/shelf/
/workspace.xml
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile default="true" name="Default" enabled="true" />
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="structuring-service" />
</profile>
</annotationProcessing>
</component>
<component name="JavacSettings">
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="structuring-service" options="-parameters" />
</option>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
# Read Me First
The following was discovered as part of building this project:
* The original package name 'com.example.structuring-service' is invalid and this project uses 'com.example.structuringservice' instead.
# Getting Started
### Reference Documentation
For further reference, please consider the following sections:
* [Official Apache Maven documentation](https://maven.apache.org/guides/index.html)
* [Spring Boot Maven Plugin Reference Guide](https://docs.spring.io/spring-boot/docs/3.1.2/maven-plugin/reference/html/)
* [Create an OCI image](https://docs.spring.io/spring-boot/docs/3.1.2/maven-plugin/reference/html/#build-image)
This diff is collapsed.
server.port = 11303
spring.kafka.bootstrap-servers=http://172.29.3.220:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.template.default-topic=Stream-Raw
spring.kafka.consumer.group-id= Stream-Raw-Id
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.application.name=STRUCTURING-SERVICE
eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
eureka.instance.hostname=192.168.24.47
\ No newline at end of file
# Default ignored files
/shelf/
/workspace.xml
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile default="true" name="Default" enabled="true" />
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="testing-service" />
</profile>
</annotationProcessing>
</component>
<component name="JavacSettings">
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="testing-service" options="-parameters" />
</option>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
# Read Me First
The following was discovered as part of building this project:
* The original package name 'com.example.testing-service' is invalid and this project uses 'com.example.testingservice' instead.
# Getting Started
### Reference Documentation
For further reference, please consider the following sections:
* [Official Apache Maven documentation](https://maven.apache.org/guides/index.html)
* [Spring Boot Maven Plugin Reference Guide](https://docs.spring.io/spring-boot/docs/3.1.2/maven-plugin/reference/html/)
* [Create an OCI image](https://docs.spring.io/spring-boot/docs/3.1.2/maven-plugin/reference/html/#build-image)
server.port=11111
spring.kafka.bootstrap-servers=http://172.29.3.220:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.application.name=TESTING-SERVICE
eureka.client.serviceUrl.defaultZone=http://192.168.27.227:8761/eureka
This diff is collapsed.
# Default ignored files
/shelf/
/workspace.xml
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="CompilerConfiguration">
<annotationProcessing>
<profile name="Maven default annotation processors profile" enabled="true">
<sourceOutputDir name="target/generated-sources/annotations" />
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
<outputRelativeToContentRoot value="true" />
<module name="Processing" />
</profile>
</annotationProcessing>
</component>
<component name="JavacSettings">
<option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="Processing" options="-parameters" />
</option>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="Encoding">
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="RemoteRepositoriesConfiguration">
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Central Repository" />
<option name="url" value="https://repo.maven.apache.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="central" />
<option name="name" value="Maven Central repository" />
<option name="url" value="https://repo1.maven.org/maven2" />
</remote-repository>
<remote-repository>
<option name="id" value="jboss.community" />
<option name="name" value="JBoss Community repository" />
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
</remote-repository>
</component>
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ExternalStorageConfigurationManager" enabled="true" />
<component name="MavenProjectsManager">
<option name="originalFiles">
<list>
<option value="$PROJECT_DIR$/pom.xml" />
</list>
</option>
</component>
<component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="17" project-jdk-type="JavaSDK" />
</project>
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="$PROJECT_DIR$/../.." vcs="Git" />
</component>
</project>
\ No newline at end of file
# Getting Started
### Reference Documentation
For further reference, please consider the following sections:
* [Official Apache Maven documentation](https://maven.apache.org/guides/index.html)
* [Spring Boot Maven Plugin Reference Guide](https://docs.spring.io/spring-boot/docs/3.1.1/maven-plugin/reference/html/)
* [Create an OCI image](https://docs.spring.io/spring-boot/docs/3.1.1/maven-plugin/reference/html/#build-image)
This diff is collapsed.
spring.kafka.bootstrap-servers=http://172.29.3.220:9092
spring.kafka.template.default-topic=EnrichedTrap
spring.kafka.consumer.group-id= EnrichedTrapId
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
server.port = 0
workingPath = ./Processing/src/main/resources/utils
{
"index_patterns": ["traps-data-stream*"],
"data_stream": { },
"composed_of": [ "traps_setting", "traps_mapping"],
"priority": 670,
"_meta": {
"description": "Template for my time series data",
"my-custom-meta-field": "More arbitrary metadata"
}
}
\ No newline at end of file
{
"mappings": {
"properties": {
"@timestamp": {
"type": "date",
"format": "date_optional_time||epoch_millis"
},
"enterprise": {
"type": "text"
},
"agentAddress": {
"type": "text"
},
"genericTrap": {
"type": "long"
},
"specificTrap": {
"type": "long"
},
"severity": {
"type": "text"
},
"variableBindings": {
"type": "nested",
"properties": {
"oid": {
"type": "keyword"
},
"value": {
"type": "text"
}
}
},
"location": {
"type": "geo_point"
}
}
}
}
\ No newline at end of file
{
"phases": {
"hot": {
"min_age": "0ms",
"actions": {
"set_priority": {
"priority": 100
},
"rollover": {
"max_primary_shard_size": "50gb",
"max_age": "60m"
}
}
},
"warm": {
"min_age": "60m",
"actions": {
"set_priority": {
"priority": 50
}
}
},
"cold": {
"min_age": "60m",
"actions": {
"set_priority": {
"priority": 0
}
}
},
"delete": {
"min_age": "1d",
"actions": {
"delete": {
}
}
}
}
}
\ No newline at end of file
{
"settings": {
"index.lifecycle.name": "Traps_Policy",
"index.number_of_shards": 1,
"index.number_of_replicas": 0
}
}
\ No newline at end of file
......@@ -87,6 +87,10 @@ public class SnmpListener implements CommandResponder {
MessageDispatcher mDispatcher = new MultiThreadedMessageDispatcher(
threadPool, new MessageDispatcherImpl());
// Create Target
CommunityTarget target = new CommunityTarget();
target.setCommunity(new OctetString(community));
// add message processing models
mDispatcher.addMessageProcessingModel(new MPv1());
mDispatcher.addMessageProcessingModel(new MPv2c());
......@@ -95,13 +99,9 @@ public class SnmpListener implements CommandResponder {
SecurityProtocols.getInstance().addDefaultProtocols();
SecurityProtocols.getInstance().addPrivacyProtocol(new Priv3DES());
// Create Target
CommunityTarget target = new CommunityTarget();
target.setCommunity(new OctetString(community));
Snmp snmp = new Snmp(mDispatcher, transport);
snmp.addCommandResponder(this);
transport.listen();
System.out.println("Listening on " + address);
try {
......
......@@ -2,9 +2,6 @@ server.port = 0
spring.kafka.bootstrap-servers=http://172.29.3.220:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.listener.address=localhost/1625
spring.listener.address=192.168.26.20/1625
spring.listener.threads=20
spring.listener.community=public
spring.application.name=TRAP-LISTENER-SERVICE
eureka.client.serviceUrl.defaultZone=http://localhost:8761/eureka
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment