PersistenceInstanceOperations (Serverless Workflow :: Impl :: Persistence:: API 7.29.0.Final API)

All Superinterfaces:: CorrelationOperations

All Known Subinterfaces:: PersistenceInstanceTransaction

public interface PersistenceInstanceOperations extends CorrelationOperations

Method Summary

Modifier and Type

Method

Description

void

clearStatus(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

Optional<PersistenceWorkflowInfo>

readWorkflowInfo(io.serverlessworkflow.impl.WorkflowDefinition definition, String instanceId)

void

removeProcessInstance(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

Stream<PersistenceWorkflowInfo>

scanAll(String applicationId, io.serverlessworkflow.impl.WorkflowDefinition definition)

void

writeCompletedTask(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.TaskContextData taskContext)

void

writeInstanceData(io.serverlessworkflow.impl.WorkflowContextData workflowContext)

void

writeRetryTask(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.TaskContextData taskContext)

void

writeStatus(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.WorkflowStatus suspended)

Methods inherited from interface io.serverlessworkflow.impl.persistence.CorrelationOperations
clearProcessed, markAsProcessed, removeCloudEvents, retrieveEvents, storeEvent

Method Details
- writeInstanceData
  
  void writeInstanceData(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
- writeRetryTask
  
  void writeRetryTask(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.TaskContextData taskContext)
- writeCompletedTask
  
  void writeCompletedTask(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.TaskContextData taskContext)
- writeStatus
  
  void writeStatus(io.serverlessworkflow.impl.WorkflowContextData workflowContext, io.serverlessworkflow.impl.WorkflowStatus suspended)
- removeProcessInstance
  
  void removeProcessInstance(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
- clearStatus
  
  void clearStatus(io.serverlessworkflow.impl.WorkflowContextData workflowContext)
- scanAll
  
  Stream<PersistenceWorkflowInfo> scanAll(String applicationId, io.serverlessworkflow.impl.WorkflowDefinition definition)
- readWorkflowInfo
  
  Optional<PersistenceWorkflowInfo> readWorkflowInfo(io.serverlessworkflow.impl.WorkflowDefinition definition, String instanceId)