executor

Documentation

Index

• 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

Functions

func NewDelayExecutor

func NewDelayExecutor(shardId string, storage shard.Storage, engine *shard.FlowEngine, wg *sync.WaitGroup) *delayExecutor

func NewRetryExecutor

func NewRetryExecutor(shardId string, stoarge shard.Storage, engine *shard.FlowEngine, wg *sync.WaitGroup) *retryExecutor

func NewSystemActionExecutor

func NewSystemActionExecutor(shardId string, storage shard.Storage, engine *shard.FlowEngine, batchSize int, wg *sync.WaitGroup) *systemActionExecutor

func NewTimeoutExecutor

func NewTimeoutExecutor(shardId string, storage shard.Storage, engine *shard.FlowEngine, wg *sync.WaitGroup) *timeoutExecutor

func NewUserActionExecutor

func NewUserActionExecutor(shardId string, storage shard.Storage, metadataService metadata.MetadataService, externalQueue shard.ExternalQueue, batchSize int, wg *sync.WaitGroup) *userActionExecutor