SchedulableBatchExecutor

org.sigilaris.core.application.scheduling.SchedulableBatchExecutor

Executes a schedulable batch plan sequentially, verifying footprint conformance after each item.

Attributes

Source
BatchPlanning.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def executeSequentially[A, E](initial: StoreState, plan: SchedulableBatchPlan[A])(execute: (StoreState, A) => Either[E, TxExecution[_, _]]): Either[SchedulableExecutionFailure[A, E], SchedulableBatchExecution[A]]

Executes all items in a schedulable batch plan sequentially, verifying conformance after each.

Executes all items in a schedulable batch plan sequentially, verifying conformance after each.

Type parameters

A

the item type

E

the execution error type

Value parameters

execute

the function that executes a single item against a store state

initial

the initial store state

plan

the schedulable batch plan to execute

Attributes

Returns

either an execution failure or the batch execution result

Source
BatchPlanning.scala