Versions in this module Expand all Collapse all v0 v0.0.1 May 2, 2023 Changes in this version + func NewDelayExecutor(shardId string, storage shard.Storage, engine *shard.FlowEngine, ...) *delayExecutor + func NewRetryExecutor(shardId string, stoarge shard.Storage, engine *shard.FlowEngine, ...) *retryExecutor + func NewSystemActionExecutor(shardId string, storage shard.Storage, engine *shard.FlowEngine, batchSize int, ...) *systemActionExecutor + func NewTimeoutExecutor(shardId string, storage shard.Storage, engine *shard.FlowEngine, ...) *timeoutExecutor + func NewUserActionExecutor(shardId string, storage shard.Storage, ...) *userActionExecutor
Go to main page