Package | Description |
---|---|
org.opendaylight.controller.cluster.access.concepts |
This package defines basic concepts used to interact with the CDS backend implementation.
|
org.opendaylight.controller.cluster.databroker.actors.dds |
This package contains implementation required by the DistributedDataStore frontend.
|
org.opendaylight.controller.cluster.datastore | |
org.opendaylight.controller.cluster.datastore.config | |
org.opendaylight.controller.cluster.datastore.entityownership.messages | |
org.opendaylight.controller.cluster.datastore.identifiers | |
org.opendaylight.controller.cluster.datastore.messages | |
org.opendaylight.controller.cluster.datastore.utils | |
org.opendaylight.controller.cluster.sharding |
Modifier and Type | Method and Description |
---|---|
static MemberName |
MemberName.forName(String name) |
MemberName |
FrontendIdentifier.getMemberName() |
static MemberName |
MemberName.readFrom(DataInput in) |
Modifier and Type | Method and Description |
---|---|
int |
MemberName.compareTo(MemberName obj) |
static FrontendIdentifier |
FrontendIdentifier.create(MemberName memberName,
FrontendType clientType) |
Modifier and Type | Method and Description |
---|---|
static akka.actor.Props |
DistributedDataStoreClientActor.props(MemberName memberName,
String storeName,
ActorContext ctx) |
static akka.actor.Props |
SimpleDataStoreClientActor.props(MemberName memberName,
String storeName,
ActorContext ctx,
String shardName) |
Modifier and Type | Method and Description |
---|---|
MemberName |
ClusterWrapperImpl.getCurrentMemberName() |
MemberName |
ClusterWrapper.getCurrentMemberName() |
Modifier and Type | Method and Description |
---|---|
Collection<MemberName> |
ConfigurationImpl.getMembersFromShardName(String shardName) |
Collection<MemberName> |
Configuration.getMembersFromShardName(String shardName)
Returns the member replicas for the given shard name.
|
Set<MemberName> |
ShardConfig.getReplicas() |
Collection<MemberName> |
ModuleShardConfiguration.getShardMemberNames() |
Collection<MemberName> |
PrefixShardConfiguration.getShardMemberNames() |
Collection<MemberName> |
ConfigurationImpl.getUniqueMemberNamesForAllShards() |
Collection<MemberName> |
Configuration.getUniqueMemberNamesForAllShards()
Returns a unique set of all member names configured for all shards.
|
Modifier and Type | Method and Description |
---|---|
void |
ConfigurationImpl.addMemberReplicaForShard(String shardName,
MemberName newMemberName) |
void |
Configuration.addMemberReplicaForShard(String shardName,
MemberName memberName)
Adds the given member as the new replica for the given shardName.
|
Collection<String> |
ConfigurationImpl.getMemberShardNames(MemberName memberName) |
Collection<String> |
Configuration.getMemberShardNames(MemberName memberName)
Returns all the shard names that belong on the member by the given name.
|
void |
ConfigurationImpl.removeMemberReplicaForShard(String shardName,
MemberName newMemberName) |
void |
Configuration.removeMemberReplicaForShard(String shardName,
MemberName memberName)
Removes the given member as a replica for the given shardName.
|
Modifier and Type | Method and Description |
---|---|
ModuleConfig.Builder |
ModuleConfig.Builder.shardConfig(String shardName,
Collection<MemberName> replicas) |
Constructor and Description |
---|
ModuleShardConfiguration(URI namespace,
String moduleName,
String shardName,
String shardStrategyName,
Collection<MemberName> shardMemberNames)
Constructs a new instance.
|
PrefixShardConfiguration(org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix,
String shardStrategyName,
Collection<MemberName> shardMemberNames) |
ShardConfig(String name,
Collection<MemberName> replicas) |
Modifier and Type | Method and Description |
---|---|
MemberName |
RemoveAllCandidates.getMemberName() |
Constructor and Description |
---|
RemoveAllCandidates(MemberName memberName) |
Modifier and Type | Method and Description |
---|---|
MemberName |
ShardIdentifier.getMemberName() |
Modifier and Type | Method and Description |
---|---|
static ShardIdentifier |
ShardIdentifier.create(String shardName,
MemberName memberName,
String type) |
ShardIdentifier.Builder |
ShardIdentifier.Builder.memberName(MemberName newMemberName) |
Modifier and Type | Method and Description |
---|---|
MemberName |
RemovePrefixShardReplica.getMemberName() |
MemberName |
RemoveShardReplica.getMemberName() |
MemberName |
PeerUp.getMemberName() |
MemberName |
PeerDown.getMemberName() |
Constructor and Description |
---|
PeerDown(MemberName memberName,
String peerId) |
PeerUp(MemberName memberName,
String peerId) |
RemovePrefixShardReplica(org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier prefix,
MemberName memberName)
Constructor.
|
RemoveShardReplica(String shardName,
MemberName memberName)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
MemberName |
ActorContext.getCurrentMemberName() |
Modifier and Type | Method and Description |
---|---|
static ShardIdentifier |
ClusterUtils.getShardIdentifier(MemberName memberName,
org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix) |
Modifier and Type | Method and Description |
---|---|
String |
ShardingServiceAddressResolver.resolve(MemberName memberName) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<DistributedShardFactory.DistributedShardRegistration> |
DistributedShardFactory.createDistributedShard(org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix,
Collection<MemberName> replicaMembers)
Register a new shard that is rooted at the desired prefix with replicas on the provided members.
|
CompletionStage<DistributedShardFactory.DistributedShardRegistration> |
DistributedShardedDOMDataTree.createDistributedShard(org.opendaylight.mdsal.dom.api.DOMDataTreeIdentifier prefix,
Collection<MemberName> replicaMembers) |
Constructor and Description |
---|
PrefixedShardConfigUpdateHandler(akka.actor.ActorRef handlingActor,
MemberName memberName) |
ShardConfigHandler(MemberName memberName,
org.opendaylight.mdsal.common.api.LogicalDatastoreType type,
akka.actor.ActorRef handlingActor) |
ShardingServiceAddressResolver(String shardingServiceActorIdentifier,
MemberName localMemberName) |
Copyright © 2019 OpenDaylight. All rights reserved.