public class ResourceBatchingManager extends Object implements AutoCloseable
Modifier and Type | Class and Description |
---|---|
static class |
ResourceBatchingManager.ShardResource |
Constructor and Description |
---|
ResourceBatchingManager() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
com.google.common.util.concurrent.ListenableFuture<Void> |
delete(ResourceBatchingManager.ShardResource shardResource,
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier) |
void |
delete(String resourceType,
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier) |
void |
deregisterBatchableResource(String resourceType) |
static ResourceBatchingManager |
getInstance() |
com.google.common.util.concurrent.ListenableFuture<Void> |
merge(ResourceBatchingManager.ShardResource shardResource,
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier,
org.opendaylight.yangtools.yang.binding.DataObject updatedData) |
void |
merge(String resourceType,
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier,
org.opendaylight.yangtools.yang.binding.DataObject updatedData) |
com.google.common.util.concurrent.ListenableFuture<Void> |
put(ResourceBatchingManager.ShardResource shardResource,
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier,
org.opendaylight.yangtools.yang.binding.DataObject updatedData) |
void |
put(String resourceType,
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier,
org.opendaylight.yangtools.yang.binding.DataObject updatedData) |
<T extends org.opendaylight.yangtools.yang.binding.DataObject> |
read(String resourceType,
org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> identifier)
Reads the identifier of the given resource type.
|
void |
registerBatchableResource(String resourceType,
BlockingQueue<ActionableResource> resQueue,
ResourceHandler resHandler) |
void |
registerDefaultBatchHandlers(org.opendaylight.controller.md.sal.binding.api.DataBroker broker) |
public static ResourceBatchingManager getInstance()
public void close()
close
in interface AutoCloseable
public void registerBatchableResource(String resourceType, BlockingQueue<ActionableResource> resQueue, ResourceHandler resHandler)
public void registerDefaultBatchHandlers(org.opendaylight.controller.md.sal.binding.api.DataBroker broker)
public <T extends org.opendaylight.yangtools.yang.binding.DataObject> com.google.common.util.concurrent.CheckedFuture<com.google.common.base.Optional<T>,org.opendaylight.controller.md.sal.common.api.data.ReadFailedException> read(String resourceType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> identifier)
resourceType
- resource type that was registered with batch manageridentifier
- identifier to be readpublic com.google.common.util.concurrent.ListenableFuture<Void> merge(ResourceBatchingManager.ShardResource shardResource, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier, org.opendaylight.yangtools.yang.binding.DataObject updatedData)
public void merge(String resourceType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier, org.opendaylight.yangtools.yang.binding.DataObject updatedData)
public com.google.common.util.concurrent.ListenableFuture<Void> delete(ResourceBatchingManager.ShardResource shardResource, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier)
public void delete(String resourceType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier)
public com.google.common.util.concurrent.ListenableFuture<Void> put(ResourceBatchingManager.ShardResource shardResource, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier, org.opendaylight.yangtools.yang.binding.DataObject updatedData)
public void put(String resourceType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> identifier, org.opendaylight.yangtools.yang.binding.DataObject updatedData)
public void deregisterBatchableResource(String resourceType)
Copyright © 2019 OpenDaylight. All rights reserved.