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()
 }