aboutsummaryrefslogtreecommitdiffstats
path: root/ms/blueprintsprocessor/modules/commons
AgeCommit message (Collapse)AuthorFilesLines
2020-02-12Cluster co-ordination with Hazelcast.Brinda Santh18-551/+631
Remove Atomix implementation, due to Kubernetes clustering issues. Cluster environment property changes. Issue-ID: CCSDK-2011 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I23f40c92c0adc6b3ab8690871385f78525c76433
2020-02-01Expose rest API with non blocking call.Brinda Santh1-0/+28
Convert Mono and Flux to coroutines Convert reactor mdc to coroutine mdc Issue-ID: CCSDK-2052 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Ic58c0b74866d28fd2d803b96626b08f8e8b2db56
2020-01-31Spring boot, Kotlin version upgradesBrinda Santh1-1/+1
Dependent Patch : https://gerrit.onap.org/r/c/ccsdk/parent/+/100990 Fixed Jackson set method according to latest version. Fixed Security properties issues for failed JUnit test cases. Reused maven properties from parent for Spring boot, Nats, Kafka, etc Issue-ID: CCSDK-1737 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I04bb0e535161e05897f587a0f08a2689e10c5f41
2020-01-17Fix scheduler shutdown config function.Brinda Santh1-1/+1
Optimize application name accessing in Docker Compose. Issue-ID: CCSDK-1917 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I6b055de7ef5a8ac4a0c103499997ed272bd74ac6
2020-01-16Prioritization Optional NATS consumer supportBrinda Santh7-8/+114
Add prioritization NATS consumer service and configuration data beans. Optimizing message prioritization service interface. Added Integration testing for NATS simulation. Updated sample docker compose for NATS support Issue-ID: CCSDK-1917 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Icd21e5e2ab7b64d6e6e4b0610599ca947555ee15
2020-01-13Add uri-encoding to webclientJozsef Csongvai1-6/+9
Path params are not uri-encoded, which can cause failed rest calls if resolved params include characters such as whitespace Issue-ID: CCSDK-2024 Change-Id: Iac57219260ac94897e09e3cb9d1d5884d86b83ae Signed-off-by: Jozsef Csongvai <jozsef.csongvai@bell.ca>
2020-01-08Rest endpoint for message PrioritizationBrinda Santh1-0/+8
Refactored to support both Kafka and Rest endpoint prioritization. Simplified number for Kafka processors. Issue-ID: CCSDK-1917 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Iba77ed94be3398940840ff01a298f0bec785401f
2020-01-07Include correlationId in group lock.Brinda Santh2-14/+37
Message prioritization optimization by checking and including correlation Id, so that non related correlation message won't get locked. Optimized Atomix Junit Test cases. Issue-ID: CCSDK-2011 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I090ed4c193c7f9af4014cfeee4c6208c12b542c1
2020-01-02Message Prioritization message group lock.Brinda Santh2-0/+8
Implementation to avoid concurrent procession of message group while prioritization. Sample message prioritization Kafka listener properties. Issue-ID: CCSDK-2011 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Ifbf39985b03c662b6ccf7740be711cfeb7bfbebb
2019-12-31Flexible DSL Types and Templates definition.Brinda Santh12-62/+183
Easy search definitions Types and Templates inside ServiceTemplate DSL builder. Unit test modifications to support this change. Issue-ID: CCSDK-1054 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Ie944ff5f75f80c852555306e1a4e0fa7f5b803d7
2019-12-30Runtime services for Relationship Type and TemplatesBrinda Santh5-2/+497
Added and improved blueprint runtime service property resolution api. Relationship template CBA sample Performance improvement on Artifact resolutions. Added connection config DSL for DB, GRPC connections. Added starter relationship connection config models. Issue-ID: CCSDK-1054 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I73e1deed708dc924352867ddd1d1b2271c8ea106
2019-12-30Relationship Type and Templates modelsBrinda Santh12-62/+852
Enrichment Support for Relationship Types and Templates. Relationship DSL support for ConnectTo connections ( RestClient, SshClient, MessageProducer, MessageConsume, Nats) Moved datatype map from collection to complex type Issue-ID: CCSDK-1054 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I0f18db2cb52e1e93dfab04498b8298587cba2540
2019-12-30Cluster partition master APIBrinda Santh9-26/+81
Added cluster lock close method. Added NATS connection name and default services. Junit test cases improvements. Issue-ID: CCSDK-2011 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I44c7c1aaeae2ddbf768903152fb00bc160172fc1
2019-12-26add logging to value not found from propertiesOleg Mitsura1-1/+10
Issue-ID: CCSDK-1995 rev1: commit rev2: formatting rev3: cleanup rev4: review comment from Brinda Signed-off-by: Oleg Mitsura <oleg.mitsura@amdocs.com> Change-Id: I5a575dad5191b72934667d2c4e965882ccc2a905
2019-12-23Cluster distributed lock service.Brinda Santh5-34/+183
Included and fixed clustered env properties and utils. Fixed docker compose instance sequence numbers. Issue-ID: CCSDK-2011 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Ie28935ae7cb3de8c77cd7110993304eb49799b6c
2019-12-19Cluster communication channelsBrinda Santh14-5/+855
Add NATS property and library services both . NATS Messaging Services with Token Auth and TLS Auth implementation Docker Compose for NATS Streaming instance. Documentation : https://docs.nats.io/ Issue-ID: CCSDK-2007 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Ieebaa8f2b18ae89d02a4f38a8027eda495a9db43
2019-12-16Cluster distributed data storeBrinda Santh9-0/+480
Add experimental cluster co-ordination service using Atomic framework. Included distributed data store creation utilities. Sample docker compose data cluster between cds controller and resource-resolution instances. Issue-ID: CCSDK-2000 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I4de00e773a996e08fd1d260fc27ed18832433883
2019-12-11Metadata for name, version, tags and typeBrinda Santh3-13/+18
Mandate Tosca.meta template name, version, type and tags. Auto copy metadata from Tosca.meta to ServiceTemplate definitions. Optimize Blueprint context and runtime creation from file path. Removed attached CBA zip file in test repository dirs Issue-ID: CCSDK-1992 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I5d9d7a4599234a38d431328dbd9b74bd831e0115
2019-12-09Cli executor doesn't keep/support execution contextSteve Siani4-53/+284
Issue-ID: CCSDK-1927 Signed-off-by: Steve Siani <alphonse.steve.siani.djissitchi@ibm.com> Change-Id: Ib417bfd62662676fe7520a5500df82ade716f66c
2019-12-06Refractor controller blueprint modulesBrinda Santh7-16/+16
Move controller blueprints modules to blueprints processor and change the maven group name. Fix test cba and model type paths Fix dependencies issues. Issue-ID: CCSDK-1663 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I3654e6f04811470327acba90e8a452b66e3e189b
2019-12-06Remote Script Executor ComponentBrinda Santh7-36/+164
Define and Implement component-remote-script-executor component and DSL. Get the timeout from model definitions fix the dat pattern issues Define API data extension functions. Issue-ID: CCSDK-1975 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I41a429eb21a050e5ab512a7a73a394b975543f31
2019-11-29Upgrade py executor ms GRPC version.Brinda Santh2-75/+85
Regenerate TLS certs with config file. Issue-ID: CCSDK-1737 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I2b0982c4e230524ad1e58f150da2a05e4474a0fa
2019-11-29Optimize spring data JPA UT.Brinda Santh7-50/+80
Test case based database configuration, so that we can define what repositories and entities can be used for testing. Issue-ID: CCSDK-1735 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I4f8a7eb4ed47fec9ab17eb9552648ebd0de01236
2019-11-27Upgrade CDS GRPC implementations.Brinda Santh8-37/+38
Dependent on : https://gerrit.onap.org/r/c/ccsdk/parent/+/98823 Issue-ID: CCSDK-1737 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I0b5087f7e98490d7066f389af29424aed40a6520
2019-11-26Formatting Code base with ktlintSingal, Kapil (ks220y)87-838/+1216
No Business logic change, just the code format. Competible with IntelliJ: https://github.com/pinterest/ktlint#option-3 To format run: mvn process-sources -P format Issue-ID: CCSDK-1947 Signed-off-by: Singal, Kapil (ks220y) <ks220y@att.com> Change-Id: Ic9e9209fb7023d77f434693ad5a01229f8d09331
2019-11-19Merge "add service for searching in meta data pageable"Brinda Santh Muthuramalingam1-0/+24
2019-11-18Property based GRPC server service.Brinda Santh3-1/+33
Issue-ID: CCSDK-1747 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I948d4fac974a0d6d0c855ad4e24766a9ce6b7a6a
2019-11-18add service for searching in meta data pageableShaaban Ebrahim1-0/+24
Issue-ID: CCSDK-1770 Signed-off-by: Shaaban Ebrahim <shaaban.eltanany.ext@orange.com> Change-Id: Ibf718314f2f818108af3133641ab7be48c334dce
2019-11-18Fix Message Prioritization merge conflictsBrinda Santh2-4/+4
Issue-ID: CCSDK-1917 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I92cdca04036c23c212b7b333ca14455eef20555c
2019-11-18Merge "Add message prioritization module"Dan Timoney3-0/+209
2019-11-18Merge "Add Kafka Streams consumer service"Dan Timoney9-2/+356
2019-11-18Merge "Convert component functions IT to UT."Dan Timoney19-135/+101
2019-11-14Removed deprecated class. The correct implementation isSebastien Premont-Tendland1-127/+0
in the class BlueprintProcessorCatalogServiceImpl. Issue-ID: CCSDK-1924 Signed-off-by: Sebastien Premont-Tendland <sebastien.premont@bell.ca> Change-Id: I0d4ccfb69979ec3be35a46f154cd20586175d671
2019-11-13Add message prioritization moduleBrinda Santh3-0/+209
Kafka streams based solution for message prioritization using database store. Implement initial Abstract Processors, Puntuations and sample Topology for easy plug and play based on situations Issue-ID: CCSDK-1917 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I9c135604574cc3c642186545e076d6a7c60048d4
2019-11-09Convert component functions IT to UT.Brinda Santh19-135/+101
Issue-ID: CCSDK-1735 Convert Netconf and Restconf Executor IT to UT. Remove duplicate BluePrintProperties. Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I2eafdbabb17a4df72541ab93c46e7fc9eb0fe8d7
2019-11-08Add Kafka Streams consumer serviceBrinda Santh9-2/+356
Issue-ID: CCSDK-1914 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I8d2b51c66e1304decadbb55656fe8a0b4c018feb
2019-11-07Add rest client invocation log tracing.Brinda Santh2-1/+19
Issue-ID: CCSDK-1046 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Ie44a1b2628132aa44bc923a4d622544db03b46b0
2019-11-07Fix missing status event type workflow response.Brinda Santh5-16/+276
Issue-ID: CCSDK-1896 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: Iffb4c5e9d4e5788895bda6c7ee4197ee9e0bd60e
2019-11-07Merge "Extension support for db configuration."Dan Timoney8-9/+13
2019-11-07Merge "Refractor rest log tracing filter for reuse."Dan Timoney1-0/+38
2019-11-06add search by meta data in cds-ui server and blueprint processorShaaban Ebrahim1-1/+18
Issue-ID: CCSDK-1770 Signed-off-by: Shaaban Ebrahim <shaaban.eltanany.ext@orange.com> Change-Id: I8ac77ab4903e3141d065a61bf28404f3d16077cd
2019-11-04Extension support for db configuration.Brinda Santh8-9/+13
Issue-ID: CCSDK-1046 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I404855eac4520f79ac33f70710dcdb6ae285891d
2019-11-04Removing dead code... DME2 does nothing...Oleg Mitsura5-57/+4
Issue-ID: CCSDK-1897 Signed-off-by: Oleg Mitsura <oleg.mitsura@amdocs.com> Change-Id: I5b9abb83f9c2e2a4329a393fb8c0fa10801a770c
2019-11-01Refractor rest log tracing filter for reuse.Brinda Santh1-0/+38
Issue-ID: CCSDK-1046 Signed-off-by: Brinda Santh <bs2796@att.com> Change-Id: I0ef0627851041b80f63c907c165c9eff5972a973
2019-10-31Merge "Add message consumer dynamic functions."Dan Timoney5-15/+134
2019-10-31Merge "Add Message tracing logger service."Dan Timoney8-7/+208
2019-10-31Merge "Add Message Header support for tracing."Dan Timoney6-59/+86
2019-10-31Merge "Py executor grpc TLS server authentication."Dan Timoney6-84/+88
2019-10-31Merge "Add grpc TLS property lib services."Dan Timoney13-12/+567
2019-10-31Merge "Add GRPC log tracing service."Dan Timoney7-69/+305