Package org.kie.kogito.persistence.rocksdb

Class RocksDBProcessInstances<T>

java.lang.Object
org.kie.kogito.persistence.rocksdb.RocksDBProcessInstances<T>
All Implemented Interfaces:
org.kie.kogito.process.MutableProcessInstances<T>, org.kie.kogito.process.ProcessInstances<T>
public class RocksDBProcessInstances<T> extends Object implements org.kie.kogito.process.MutableProcessInstances<T>

  • Constructor Summary

    Constructors
    Constructor
    Description
    RocksDBProcessInstances(org.kie.kogito.process.Process<T> process, org.rocksdb.RocksDB db)
     
    RocksDBProcessInstances(org.kie.kogito.process.Process<T> process, org.rocksdb.RocksDB db, org.kie.kogito.internal.process.runtime.HeadersPersistentConfig headersConfig)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    create(String id, org.kie.kogito.process.ProcessInstance<T> instance)
     
    boolean
    exists(String id)
     
    Optional<org.kie.kogito.process.ProcessInstance<T>>
    findById(String id, org.kie.kogito.process.ProcessInstanceReadMode mode)
     
    void
    remove(String id)
     
    Stream<org.kie.kogito.process.ProcessInstance<T>>
    stream(org.kie.kogito.process.ProcessInstanceReadMode mode)
     
    void
    update(String id, org.kie.kogito.process.ProcessInstance<T> instance)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.kie.kogito.process.MutableProcessInstances

    isActive, lock

    Methods inherited from interface org.kie.kogito.process.ProcessInstances

    findByBusinessKey, findByBusinessKey, findById, migrateAll, migrateProcessInstances, stream

  • Constructor Details

    • RocksDBProcessInstances

      public RocksDBProcessInstances(org.kie.kogito.process.Process<T> process, org.rocksdb.RocksDB db)

    • RocksDBProcessInstances

      public RocksDBProcessInstances(org.kie.kogito.process.Process<T> process, org.rocksdb.RocksDB db, org.kie.kogito.internal.process.runtime.HeadersPersistentConfig headersConfig)

  • Method Details

    • findById

      public Optional<org.kie.kogito.process.ProcessInstance<T>> findById(String id, org.kie.kogito.process.ProcessInstanceReadMode mode)
      Specified by:
      findById in interface org.kie.kogito.process.ProcessInstances<T>

    • stream

      public Stream<org.kie.kogito.process.ProcessInstance<T>> stream(org.kie.kogito.process.ProcessInstanceReadMode mode)
      Specified by:
      stream in interface org.kie.kogito.process.ProcessInstances<T>

    • exists

      public boolean exists(String id)
      Specified by:
      exists in interface org.kie.kogito.process.MutableProcessInstances<T>

    • create

      public void create(String id, org.kie.kogito.process.ProcessInstance<T> instance)
      Specified by:
      create in interface org.kie.kogito.process.MutableProcessInstances<T>

    • update

      public void update(String id, org.kie.kogito.process.ProcessInstance<T> instance)
      Specified by:
      update in interface org.kie.kogito.process.MutableProcessInstances<T>

    • remove

      public void remove(String id)
      Specified by:
      remove in interface org.kie.kogito.process.MutableProcessInstances<T>