org.opendaylight.controller.cluster.datastore.admin

Class ClusterAdminRpcService

java.lang.Object

org.opendaylight.controller.cluster.datastore.admin.ClusterAdminRpcService

All Implemented Interfaces:

ClusterAdminService, org.opendaylight.yangtools.yang.binding.RpcService

public class ClusterAdminRpcService
extends Object
implements ClusterAdminService

Implements the yang RPCs defined in the generated ClusterAdminService interface.

Author:

Thomas Pantelis

Constructor Summary

Constructors

Constructor and Description
ClusterAdminRpcService(DistributedDataStoreInterface configDataStore, DistributedDataStoreInterface operDataStore, org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer serializer)

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddPrefixShardReplicaOutput>>	addPrefixShardReplica(AddPrefixShardReplicaInput input) Adds a replica of a shard to this node and joins it to an existing cluster.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddReplicasForAllShardsOutput>>	addReplicasForAllShards(AddReplicasForAllShardsInput input) Adds replicas on this node for all currently defined shards.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddShardReplicaOutput>>	addShardReplica(AddShardReplicaInput input) Adds a replica of a shard to this node and joins it to an existing cluster.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BackupDatastoreOutput>>	backupDatastore(BackupDatastoreInput input) Creates a backup file of the datastore state
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ChangeMemberVotingStatesForAllShardsOutput>>	changeMemberVotingStatesForAllShards(ChangeMemberVotingStatesForAllShardsInput input) Changes the voting states, either voting or non-voting, of cluster members for all shards.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ChangeMemberVotingStatesForShardOutput>>	changeMemberVotingStatesForShard(ChangeMemberVotingStatesForShardInput input) Changes the voting states, either voting or non-voting, of cluster members for a shard.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlipMemberVotingStatesForAllShardsOutput>>	flipMemberVotingStatesForAllShards(FlipMemberVotingStatesForAllShardsInput input) Flips the voting states of all cluster members for all shards, such that if a member was voting it becomes non-voting and vice versa.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetKnownClientsForAllShardsOutput>>	getKnownClientsForAllShards(GetKnownClientsForAllShardsInput input) Request all shards to report their known frontend clients.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetPrefixShardRoleOutput>>	getPrefixShardRole(GetPrefixShardRoleInput input) Returns the current role for the requested module shard.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetShardRoleOutput>>	getShardRole(GetShardRoleInput input) Returns the current role for the requested module shard.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<LocateShardOutput>>	locateShard(LocateShardInput input) Return the transport-level information about where a shard has a home.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MakeLeaderLocalOutput>>	makeLeaderLocal(MakeLeaderLocalInput input) Attempts to move the shard leader of the given module based shard to the local node.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveAllShardReplicasOutput>>	removeAllShardReplicas(RemoveAllShardReplicasInput input) Removes replicas for all shards on this node.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemovePrefixShardReplicaOutput>>	removePrefixShardReplica(RemovePrefixShardReplicaInput input) Removes an existing replica of a prefix shard from this node via the RemoveServer mechanism as described in the Raft paper.
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveShardReplicaOutput>>	removeShardReplica(RemoveShardReplicaInput input) Removes an existing replica of a shard from this node via the RemoveServer mechanism as described in the Raft paper.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClusterAdminRpcService

public ClusterAdminRpcService(DistributedDataStoreInterface configDataStore,
                              DistributedDataStoreInterface operDataStore,
                              org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer serializer)

Method Detail

addShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddShardReplicaOutput>> addShardReplica(AddShardReplicaInput input)

Description copied from interface: ClusterAdminService

Adds a replica of a shard to this node and joins it to an existing cluster. The shard must already have a module configuration defined for it and there must already be a shard existing on another node with a leader. This RPC first contacts peer member seed nodes searching for a shard. When found, an AddServer message is sent to the shard leader and applied as described in the Raft paper.

Specified by:

addShardReplica in interface ClusterAdminService

removeShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveShardReplicaOutput>> removeShardReplica(RemoveShardReplicaInput input)

Description copied from interface: ClusterAdminService

Removes an existing replica of a shard from this node via the RemoveServer mechanism as described in the Raft paper.

Specified by:

removeShardReplica in interface ClusterAdminService

locateShard

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<LocateShardOutput>> locateShard(LocateShardInput input)

Description copied from interface: ClusterAdminService

Return the transport-level information about where a shard has a home.

Specified by:

locateShard in interface ClusterAdminService

makeLeaderLocal

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<MakeLeaderLocalOutput>> makeLeaderLocal(MakeLeaderLocalInput input)

Description copied from interface: ClusterAdminService

Attempts to move the shard leader of the given module based shard to the local node. The rpc returns a response after handling of the underlying MakeLeaderLocal message completes. This operation fails if there is no current shard leader due to lack of network connectivity or a cluster majority. In addition, if the local node is not up to date with the current leader, an attempt is made to first sync the local node with the leader. If this cannot be achieved within two election timeout periods the operation fails.

Specified by:

makeLeaderLocal in interface ClusterAdminService

addPrefixShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddPrefixShardReplicaOutput>> addPrefixShardReplica(AddPrefixShardReplicaInput input)

Description copied from interface: ClusterAdminService

Adds a replica of a shard to this node and joins it to an existing cluster. There must already be a shard existing on another node with a leader. This RPC first contacts peer member seed nodes searching for a shard. When found, an AddServer message is sent to the shard leader and applied as described in the Raft paper.

Specified by:

addPrefixShardReplica in interface ClusterAdminService

removePrefixShardReplica

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemovePrefixShardReplicaOutput>> removePrefixShardReplica(RemovePrefixShardReplicaInput input)

Description copied from interface: ClusterAdminService

Removes an existing replica of a prefix shard from this node via the RemoveServer mechanism as described in the Raft paper.

Specified by:

removePrefixShardReplica in interface ClusterAdminService

addReplicasForAllShards

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddReplicasForAllShardsOutput>> addReplicasForAllShards(AddReplicasForAllShardsInput input)

Description copied from interface: ClusterAdminService

Adds replicas on this node for all currently defined shards. This is equivalent to issuing an add-shard-replica RPC for all shards.

Specified by:

addReplicasForAllShards in interface ClusterAdminService

removeAllShardReplicas

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveAllShardReplicasOutput>> removeAllShardReplicas(RemoveAllShardReplicasInput input)

Description copied from interface: ClusterAdminService

Removes replicas for all shards on this node. This is equivalent to issuing a remove-shard-replica for all shards and essentially removes this node from a cluster.

Specified by:

removeAllShardReplicas in interface ClusterAdminService

changeMemberVotingStatesForShard

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ChangeMemberVotingStatesForShardOutput>> changeMemberVotingStatesForShard(ChangeMemberVotingStatesForShardInput input)

Description copied from interface: ClusterAdminService

Changes the voting states, either voting or non-voting, of cluster members for a shard. Non-voting members will no longer participate in leader elections and consensus but will be replicated. This is useful for having a set of members serve as a backup cluster in case the primary voting cluster suffers catastrophic failure. This RPC can be issued to any cluster member and will be forwarded to the leader.

Specified by:

changeMemberVotingStatesForShard in interface ClusterAdminService

changeMemberVotingStatesForAllShards

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ChangeMemberVotingStatesForAllShardsOutput>> changeMemberVotingStatesForAllShards(ChangeMemberVotingStatesForAllShardsInput input)

Description copied from interface: ClusterAdminService

Changes the voting states, either voting or non-voting, of cluster members for all shards. Non-voting members will no longer participate in leader elections and consensus but will be replicated. This is useful for having a set of members serve as a backup cluster in case the primary voting cluster suffers catastrophic failure. This RPC can be issued to any cluster member and will be forwarded to the leader.

Specified by:

changeMemberVotingStatesForAllShards in interface ClusterAdminService

flipMemberVotingStatesForAllShards

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlipMemberVotingStatesForAllShardsOutput>> flipMemberVotingStatesForAllShards(FlipMemberVotingStatesForAllShardsInput input)

Description copied from interface: ClusterAdminService

Flips the voting states of all cluster members for all shards, such that if a member was voting it becomes non-voting and vice versa.

Specified by:

flipMemberVotingStatesForAllShards in interface ClusterAdminService

getShardRole

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetShardRoleOutput>> getShardRole(GetShardRoleInput input)

Description copied from interface: ClusterAdminService

Returns the current role for the requested module shard.

Specified by:

getShardRole in interface ClusterAdminService

getPrefixShardRole

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetPrefixShardRoleOutput>> getPrefixShardRole(GetPrefixShardRoleInput input)

Description copied from interface: ClusterAdminService

Returns the current role for the requested module shard.

Specified by:

getPrefixShardRole in interface ClusterAdminService

backupDatastore

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BackupDatastoreOutput>> backupDatastore(BackupDatastoreInput input)

Description copied from interface: ClusterAdminService

Creates a backup file of the datastore state

Specified by:

backupDatastore in interface ClusterAdminService

getKnownClientsForAllShards

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<GetKnownClientsForAllShardsOutput>> getKnownClientsForAllShards(GetKnownClientsForAllShardsInput input)

Description copied from interface: ClusterAdminService

Request all shards to report their known frontend clients. This is useful for determining what generation should a resurrected member node should use.

Specified by:

getKnownClientsForAllShards in interface ClusterAdminService