diff options
Diffstat (limited to 'ms/blueprintsprocessor/modules/commons/processor-core/src')
-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() } |