Package io.serverlessworkflow.impl.persistence

Class AbstractAllStrategyCorrelationInfo

java.lang.Object
io.serverlessworkflow.impl.persistence.AbstractAllStrategyCorrelationInfo
All Implemented Interfaces:
io.serverlessworkflow.impl.scheduler.AllStrategyCorrelationInfo, AutoCloseable
Direct Known Subclasses:
OperationAllStrategyCorrelationInfo, StoreAllStrategyCorrelationInfo
public abstract class AbstractAllStrategyCorrelationInfo extends Object implements io.serverlessworkflow.impl.scheduler.AllStrategyCorrelationInfo

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final io.serverlessworkflow.impl.WorkflowDefinition
    definition
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    AbstractAllStrategyCorrelationInfo(io.serverlessworkflow.impl.WorkflowDefinition definition, PersistenceExecutor executor)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addMetadata(io.serverlessworkflow.impl.WorkflowInstance instance, Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent> events)
     
    void
    correlate(io.serverlessworkflow.impl.events.EventRegistrationBuilder reg, io.cloudevents.CloudEvent event)
     
    protected abstract Collection<Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent>>
    doTransaction(Function<CorrelationOperations,Collection<Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent>>> function)
     
    protected String
    generateIdFromReg(io.serverlessworkflow.impl.events.EventRegistrationBuilder reg)
     
    void
    init(Collection<io.serverlessworkflow.impl.events.EventRegistrationBuilder> regs, Consumer<Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent>> starter)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.serverlessworkflow.impl.scheduler.AllStrategyCorrelationInfo

    close

  • Field Details

    • definition

      protected final io.serverlessworkflow.impl.WorkflowDefinition definition

  • Constructor Details

    • AbstractAllStrategyCorrelationInfo

      public AbstractAllStrategyCorrelationInfo(io.serverlessworkflow.impl.WorkflowDefinition definition, PersistenceExecutor executor)

  • Method Details

    • correlate

      public void correlate(io.serverlessworkflow.impl.events.EventRegistrationBuilder reg, io.cloudevents.CloudEvent event)
      Specified by:
      correlate in interface io.serverlessworkflow.impl.scheduler.AllStrategyCorrelationInfo

    • init

      public void init(Collection<io.serverlessworkflow.impl.events.EventRegistrationBuilder> regs, Consumer<Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent>> starter)
      Specified by:
      init in interface io.serverlessworkflow.impl.scheduler.AllStrategyCorrelationInfo

    • addMetadata

      public void addMetadata(io.serverlessworkflow.impl.WorkflowInstance instance, Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent> events)
      Specified by:
      addMetadata in interface io.serverlessworkflow.impl.scheduler.AllStrategyCorrelationInfo

    • doTransaction

      protected abstract Collection<Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent>> doTransaction(Function<CorrelationOperations,Collection<Map<io.serverlessworkflow.impl.events.EventRegistrationBuilder,io.cloudevents.CloudEvent>>> function)

    • generateIdFromReg

      protected String generateIdFromReg(io.serverlessworkflow.impl.events.EventRegistrationBuilder reg)