Class BatchedTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>

  • All Implemented Interfaces:
    org.opendaylight.mdsal.binding.api.Transaction, org.opendaylight.mdsal.binding.util.TypedReadTransaction<D>, org.opendaylight.mdsal.binding.util.TypedReadWriteTransaction<D>, org.opendaylight.mdsal.binding.util.TypedWriteTransaction<D>, org.opendaylight.yangtools.concepts.Identifiable<java.lang.Object>

    public class BatchedTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
    extends java.lang.Object
    implements org.opendaylight.mdsal.binding.util.TypedReadWriteTransaction<D>
    • Constructor Summary

      Constructors 
      Constructor Description
      BatchedTransaction​(java.lang.Class<D> logicalDatastoreType)  
    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static boolean addCallbackIfInProgress​(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, java.lang.Runnable runnable)  
      void delete​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> instanceIdentifier)  
      <T extends @NonNull org.opendaylight.yangtools.yang.binding.DataObject>
      com.google.common.util.concurrent.FluentFuture<org.opendaylight.mdsal.binding.api.query.QueryResult<T>>
      execute​(org.opendaylight.mdsal.binding.api.query.QueryExpression<T> query)  
      com.google.common.util.concurrent.FluentFuture<java.lang.Boolean> exists​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> path)  
      com.google.common.util.concurrent.ListenableFuture<java.lang.Void> getFt​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)  
      java.lang.Object getIdentifier()  
      com.google.common.util.concurrent.ListenableFuture<java.lang.Void> getResult()  
      org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId getSrcNodeId()  
      static boolean isInProgress​(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)  
      static <D extends org.opendaylight.mdsal.binding.util.Datastore>
      void
      markUpdateInProgress​(java.lang.Class<D> type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft)  
      static <D extends org.opendaylight.mdsal.binding.util.Datastore>
      void
      markUpdateInProgress​(java.lang.Class<D> type, org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier, com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft, java.lang.String desc)  
      <T extends org.opendaylight.yangtools.yang.binding.DataObject>
      void
      merge​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier, T dataObj)  
      <T extends org.opendaylight.yangtools.yang.binding.DataObject>
      void
      mergeParentStructureMerge​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path, T data)  
      <T extends org.opendaylight.yangtools.yang.binding.DataObject>
      void
      mergeParentStructurePut​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path, T data)  
      <T extends org.opendaylight.yangtools.yang.binding.DataObject>
      void
      put​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier, T dataObj)  
      <T extends org.opendaylight.yangtools.yang.binding.DataObject>
      com.google.common.util.concurrent.FluentFuture<java.util.Optional<T>>
      read​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier)  
      void setSrcNodeId​(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId srcNodeId)  
      com.google.common.util.concurrent.ListenableFuture<java.lang.Void> submit()  
      boolean updateMetric()  
      void updateMetric​(java.lang.Boolean update)  
      void waitForCompletion()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • BatchedTransaction

        public BatchedTransaction​(java.lang.Class<D> logicalDatastoreType)
    • Method Detail

      • getResult

        public com.google.common.util.concurrent.ListenableFuture<java.lang.Void> getResult()
      • read

        public <T extends org.opendaylight.yangtools.yang.binding.DataObject> com.google.common.util.concurrent.FluentFuture<java.util.Optional<T>> read​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier)
        Specified by:
        read in interface org.opendaylight.mdsal.binding.util.TypedReadTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • exists

        public com.google.common.util.concurrent.FluentFuture<java.lang.Boolean> exists​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> path)
        Specified by:
        exists in interface org.opendaylight.mdsal.binding.util.TypedReadTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • markUpdateInProgress

        public static <D extends org.opendaylight.mdsal.binding.util.Datastore> void markUpdateInProgress​(java.lang.Class<D> type,
                                                                                                          org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier,
                                                                                                          com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft)
      • markUpdateInProgress

        public static <D extends org.opendaylight.mdsal.binding.util.Datastore> void markUpdateInProgress​(java.lang.Class<D> type,
                                                                                                          org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier,
                                                                                                          com.google.common.util.concurrent.ListenableFuture<java.lang.Void> ft,
                                                                                                          java.lang.String desc)
      • isInProgress

        public static boolean isInProgress​(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType,
                                           org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)
      • addCallbackIfInProgress

        public static boolean addCallbackIfInProgress​(org.opendaylight.mdsal.common.api.LogicalDatastoreType logicalDatastoreType,
                                                      org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier,
                                                      java.lang.Runnable runnable)
      • waitForCompletion

        public void waitForCompletion()
      • put

        public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void put​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier,
                                                                                       T dataObj)
        Specified by:
        put in interface org.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • mergeParentStructurePut

        public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void mergeParentStructurePut​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path,
                                                                                                           T data)
        Specified by:
        mergeParentStructurePut in interface org.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • merge

        public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void merge​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> instanceIdentifier,
                                                                                         T dataObj)
        Specified by:
        merge in interface org.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • mergeParentStructureMerge

        public <T extends org.opendaylight.yangtools.yang.binding.DataObject> void mergeParentStructureMerge​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<T> path,
                                                                                                             T data)
        Specified by:
        mergeParentStructureMerge in interface org.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • getFt

        public com.google.common.util.concurrent.ListenableFuture<java.lang.Void> getFt​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier instanceIdentifier)
      • delete

        public void delete​(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<?> instanceIdentifier)
        Specified by:
        delete in interface org.opendaylight.mdsal.binding.util.TypedWriteTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • submit

        public com.google.common.util.concurrent.ListenableFuture<java.lang.Void> submit()
      • getIdentifier

        public java.lang.Object getIdentifier()
        Specified by:
        getIdentifier in interface org.opendaylight.yangtools.concepts.Identifiable<D extends org.opendaylight.mdsal.binding.util.Datastore>
      • setSrcNodeId

        public void setSrcNodeId​(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId srcNodeId)
      • getSrcNodeId

        public org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId getSrcNodeId()
      • updateMetric

        public boolean updateMetric()
      • updateMetric

        public void updateMetric​(java.lang.Boolean update)
      • execute

        public <T extends @NonNull org.opendaylight.yangtools.yang.binding.DataObject> com.google.common.util.concurrent.FluentFuture<org.opendaylight.mdsal.binding.api.query.QueryResult<T>> execute​(org.opendaylight.mdsal.binding.api.query.QueryExpression<T> query)
        Specified by:
        execute in interface org.opendaylight.mdsal.binding.util.TypedReadTransaction<D extends org.opendaylight.mdsal.binding.util.Datastore>