diff options
| author |   Brinda Santh <bs2796@att.com> | 2019-12-26 15:15:27 -0500 |
|---|---|---|
| committer |   KAPIL SINGAL <ks220y@att.com> | 2019-12-30 17:49:04 +0000 |
| commit | 730c940a84b9056fed993ccef08dc5ec4053db21 (patch) | |
| tree | b871a51191314e08749c11688578d79841814732 /ms/blueprintsprocessor/modules/commons/processor-core/src/main | |
| parent | e4ceeb2f026833c63d1a6386e00c154cb804a629 (diff) | |
Cluster partition master API
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
Diffstat (limited to 'ms/blueprintsprocessor/modules/commons/processor-core/src/main')
| -rw-r--r-- | ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/service/BluePrintClusterService.kt | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/service/BluePrintClusterService.kt b/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/service/BluePrintClusterService.kt index 6fd443624..21fcfc509 100644 --- a/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/service/BluePrintClusterService.kt +++ b/ms/blueprintsprocessor/modules/commons/processor-core/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/core/service/BluePrintClusterService.kt @@ -26,6 +26,9 @@ interface BluePrintClusterService { fun clusterJoined(): Boolean + /** Returns [partitionGroup] master member */ + suspend fun masterMember(partitionGroup: String): ClusterMember + /** Returns all the data cluster members */ suspend fun allMembers(): Set<ClusterMember> @@ -58,4 +61,5 @@ interface ClusterLock { suspend fun tryLock(timeout: Long): Boolean suspend fun unLock() fun isLocked(): Boolean + fun close() } |