Package org.opendaylight.netvirt.elan.l2gw.ha

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>