public class MdsalLowLevelTestProvider extends Object implements OdlMdsalLowlevelControlService
Constructor and Description |
---|
MdsalLowLevelTestProvider(RpcProviderRegistry rpcRegistry,
DOMRpcProviderService domRpcService,
org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider singletonService,
org.opendaylight.mdsal.dom.api.DOMSchemaService schemaService,
org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer bindingNormalizedNodeSerializer,
NotificationPublishService notificationPublishService,
NotificationService notificationService,
DOMDataBroker domDataBroker,
org.opendaylight.mdsal.dom.api.DOMDataTreeService domDataTreeService,
DistributedShardFactory distributedShardFactory,
DistributedDataStoreInterface configDataStore,
ActorSystemProvider actorSystemProvider) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddShardReplicaOutput>> |
addShardReplica(AddShardReplicaInput input)
A specialised copy of cluster-admin:add-shard-replica.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BecomePrefixLeaderOutput>> |
becomePrefixLeader(BecomePrefixLeaderInput input)
Upon receiving this, the member shall ask the appropriate API to become Leader
of the given shard (presumably the llt:list-ints one, created by
produce-transactions) and return immediatelly.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CheckPublishNotificationsOutput>> |
checkPublishNotifications(CheckPublishNotificationsInput input)
Upon receiving this, the member shall immediatelly return the current tracking
data related to the current (or previous) task started by
start-publish-notifications with this id.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreatePrefixShardOutput>> |
createPrefixShard(CreatePrefixShardInput input)
Upon receiving this, the member creates a prefix shard at the
instance-identifier, with replicas on the required members.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeconfigureIdIntsShardOutput>> |
deconfigureIdIntsShard(DeconfigureIdIntsShardInput input)
Upon receiving this, the member shall ask the appropriate API to remove the
llt:id-ints shard (presumably created by produce-transactions) and return
immediatelly.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsClientAbortedOutput>> |
isClientAborted(IsClientAbortedInput input)
Return state of cds-access-client.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProduceTransactionsOutput>> |
produceTransactions(ProduceTransactionsInput input)
Upon receiving this, the member shall make sure the outer list item of
llt:in-ints exists for the given id, make sure a shard for the whole (config)
id-ints is created (by creating and closing producer for the whole id-ints), and
create a DOMDataTreeProducer for that item (using that shard).
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterBoundConstantOutput>> |
registerBoundConstant(RegisterBoundConstantInput input)
Upon receiving this, the member has to create and register a bound
llt:get-contexted-constant implementation (routed RPC).
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterConstantOutput>> |
registerConstant(RegisterConstantInput input)
Upon receiving this, the member has to create llt:get-constant implementation
(global RPC).
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterDefaultConstantOutput>> |
registerDefaultConstant(RegisterDefaultConstantInput input)
Upon receiving this, the member has to create and register a default
llt:get-contexted-constant implementation (routed RPC).
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterFlappingSingletonOutput>> |
registerFlappingSingleton(RegisterFlappingSingletonInput input)
Upon receiving this, the member checks whether it has already created a
'flapping' application implementation and 'active' flag is set, and fails if
yes.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterSingletonConstantOutput>> |
registerSingletonConstant(RegisterSingletonConstantInput input)
Upon receiving this, the member checks whether it has already registered a
singleton application, and fails if yes.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemovePrefixShardOutput>> |
removePrefixShard(RemovePrefixShardInput input)
Upon receiving this, the member removes the prefix based shard identifier by
this prefix.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveShardReplicaOutput>> |
removeShardReplica(RemoveShardReplicaInput input)
A specialised copy of cluster-admin:remove-shard-replica.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownPrefixShardReplicaOutput>> |
shutdownPrefixShardReplica(ShutdownPrefixShardReplicaInput input)
Upon receiving this, the member will try to gracefully shutdown local
configuration data store prefix-based shard replica.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownShardReplicaOutput>> |
shutdownShardReplica(ShutdownShardReplicaInput input)
Upon receiving this, the member will try to gracefully shutdown local
configuration data store module-based shard replica.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<StartPublishNotificationsOutput>> |
startPublishNotifications(StartPublishNotificationsInput input)
Upon receiving this, the member checks whether it is already in the middle of
publishing, for this id, and fails if yes.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDdtlOutput>> |
subscribeDdtl(SubscribeDdtlInput input)
Upon receiving this, the member checks whether it has already subscribed and
fails if yes.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDtclOutput>> |
subscribeDtcl(SubscribeDtclInput input)
Upon receiving this, the member checks whether it has already subscribed and
fails if yes.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeYnlOutput>> |
subscribeYnl(SubscribeYnlInput input)
Upon receiving this, the member checks whether it has already subscribed a yang
listener for the given id, and fails if yes.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterBoundConstantOutput>> |
unregisterBoundConstant(UnregisterBoundConstantInput input)
Upon receiving this, the member has to unregister any llt:get-contexted-constant
implementations bound to the context.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterConstantOutput>> |
unregisterConstant(UnregisterConstantInput input)
Upon receiving this, the member has to unregister any llt:get-constant
implementations it has registered.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterDefaultConstantOutput>> |
unregisterDefaultConstant(UnregisterDefaultConstantInput input)
Upon receiving this, the member has to unregister any llt:get-contexted-constant
default implementations it has registered.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterFlappingSingletonOutput>> |
unregisterFlappingSingleton(UnregisterFlappingSingletonInput input)
Upon receiving this, the member checks whether it has created a flapping
application, and fails if no.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterSingletonConstantOutput>> |
unregisterSingletonConstant(UnregisterSingletonConstantInput input)
Upon receiving this, the member checks whether it has currently registered a
singleton application, and fails if no.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDdtlOutput>> |
unsubscribeDdtl(UnsubscribeDdtlInput input)
Upon receiving this, the member checks whether it has currently subscribed a
DOMDataTreeListener for llt:id-ints changes, and fails if no.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDtclOutput>> |
unsubscribeDtcl(UnsubscribeDtclInput input)
Upon receiving this, the member checks whether it has currently subscribed a
Data Tree Change Listener for llt:id-ints changes, and fails if no.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeYnlOutput>> |
unsubscribeYnl(UnsubscribeYnlInput input)
Upon receiving this, the member checks whether it has currently subscribed a
yang listener for the given id, and fails if no.
|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<WriteTransactionsOutput>> |
writeTransactions(WriteTransactionsInput input)
Upon receiving this, the member shall make sure the outer list item of
llt:id-ints exists for the given id, and then start creating (one by one) and
submitting transactions to randomly add or delete items on the inner list for
that id.
|
public MdsalLowLevelTestProvider(RpcProviderRegistry rpcRegistry, DOMRpcProviderService domRpcService, org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider singletonService, org.opendaylight.mdsal.dom.api.DOMSchemaService schemaService, org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer bindingNormalizedNodeSerializer, NotificationPublishService notificationPublishService, NotificationService notificationService, DOMDataBroker domDataBroker, org.opendaylight.mdsal.dom.api.DOMDataTreeService domDataTreeService, DistributedShardFactory distributedShardFactory, DistributedDataStoreInterface configDataStore, ActorSystemProvider actorSystemProvider)
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterSingletonConstantOutput>> unregisterSingletonConstant(UnregisterSingletonConstantInput input)
OdlMdsalLowlevelControlService
unregisterSingletonConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<StartPublishNotificationsOutput>> startPublishNotifications(StartPublishNotificationsInput input)
OdlMdsalLowlevelControlService
startPublishNotifications
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDtclOutput>> subscribeDtcl(SubscribeDtclInput input)
OdlMdsalLowlevelControlService
subscribeDtcl
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<WriteTransactionsOutput>> writeTransactions(WriteTransactionsInput input)
OdlMdsalLowlevelControlService
writeTransactions
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<IsClientAbortedOutput>> isClientAborted(IsClientAbortedInput input)
OdlMdsalLowlevelControlService
isClientAborted
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveShardReplicaOutput>> removeShardReplica(RemoveShardReplicaInput input)
OdlMdsalLowlevelControlService
removeShardReplica
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeYnlOutput>> subscribeYnl(SubscribeYnlInput input)
OdlMdsalLowlevelControlService
subscribeYnl
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemovePrefixShardOutput>> removePrefixShard(RemovePrefixShardInput input)
OdlMdsalLowlevelControlService
removePrefixShard
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<BecomePrefixLeaderOutput>> becomePrefixLeader(BecomePrefixLeaderInput input)
OdlMdsalLowlevelControlService
becomePrefixLeader
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterBoundConstantOutput>> unregisterBoundConstant(UnregisterBoundConstantInput input)
OdlMdsalLowlevelControlService
unregisterBoundConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterSingletonConstantOutput>> registerSingletonConstant(RegisterSingletonConstantInput input)
OdlMdsalLowlevelControlService
registerSingletonConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterDefaultConstantOutput>> registerDefaultConstant(RegisterDefaultConstantInput input)
OdlMdsalLowlevelControlService
registerDefaultConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterConstantOutput>> unregisterConstant(UnregisterConstantInput input)
OdlMdsalLowlevelControlService
unregisterConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterFlappingSingletonOutput>> unregisterFlappingSingleton(UnregisterFlappingSingletonInput input)
OdlMdsalLowlevelControlService
unregisterFlappingSingleton
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddShardReplicaOutput>> addShardReplica(AddShardReplicaInput input)
OdlMdsalLowlevelControlService
addShardReplica
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<SubscribeDdtlOutput>> subscribeDdtl(SubscribeDdtlInput input)
OdlMdsalLowlevelControlService
subscribeDdtl
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterBoundConstantOutput>> registerBoundConstant(RegisterBoundConstantInput input)
OdlMdsalLowlevelControlService
registerBoundConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterFlappingSingletonOutput>> registerFlappingSingleton(RegisterFlappingSingletonInput input)
OdlMdsalLowlevelControlService
registerFlappingSingleton
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDtclOutput>> unsubscribeDtcl(UnsubscribeDtclInput input)
OdlMdsalLowlevelControlService
unsubscribeDtcl
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CreatePrefixShardOutput>> createPrefixShard(CreatePrefixShardInput input)
OdlMdsalLowlevelControlService
createPrefixShard
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<DeconfigureIdIntsShardOutput>> deconfigureIdIntsShard(DeconfigureIdIntsShardInput input)
OdlMdsalLowlevelControlService
deconfigureIdIntsShard
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeYnlOutput>> unsubscribeYnl(UnsubscribeYnlInput input)
OdlMdsalLowlevelControlService
unsubscribeYnl
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<CheckPublishNotificationsOutput>> checkPublishNotifications(CheckPublishNotificationsInput input)
OdlMdsalLowlevelControlService
checkPublishNotifications
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ProduceTransactionsOutput>> produceTransactions(ProduceTransactionsInput input)
OdlMdsalLowlevelControlService
produceTransactions
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownShardReplicaOutput>> shutdownShardReplica(ShutdownShardReplicaInput input)
OdlMdsalLowlevelControlService
shutdownShardReplica
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ShutdownPrefixShardReplicaOutput>> shutdownPrefixShardReplica(ShutdownPrefixShardReplicaInput input)
OdlMdsalLowlevelControlService
shutdownPrefixShardReplica
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterConstantOutput>> registerConstant(RegisterConstantInput input)
OdlMdsalLowlevelControlService
registerConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnregisterDefaultConstantOutput>> unregisterDefaultConstant(UnregisterDefaultConstantInput input)
OdlMdsalLowlevelControlService
unregisterDefaultConstant
in interface OdlMdsalLowlevelControlService
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<UnsubscribeDdtlOutput>> unsubscribeDdtl(UnsubscribeDdtlInput input)
OdlMdsalLowlevelControlService
unsubscribeDdtl
in interface OdlMdsalLowlevelControlService
Copyright © 2019 OpenDaylight. All rights reserved.