fetcher

Documentation

Index

• func ConcreteExecution(ctx context.Context, retryer persistence.Retryer, request ExecutionRequest) (entity.Entity, error)
• func ConcreteExecutionIterator(ctx context.Context, retryer persistence.Retryer, pageSize int) pagination.Iterator
• func CurrentExecution(ctx context.Context, retryer persistence.Retryer, request ExecutionRequest) (entity.Entity, error)
• func CurrentExecutionIterator(ctx context.Context, retryer persistence.Retryer, pageSize int) pagination.Iterator
• func TimerIterator(ctx context.Context, retryer persistence.Retryer, minTimestamp time.Time, ...) pagination.Iterator
• type ExecutionRequest

Functions

func ConcreteExecution

func ConcreteExecution(
	ctx context.Context,
	retryer persistence.Retryer,
	request ExecutionRequest,
) (entity.Entity, error)

ConcreteExecution returns a single ConcreteExecution from persistence

func ConcreteExecutionIterator

func ConcreteExecutionIterator(
	ctx context.Context,
	retryer persistence.Retryer,
	pageSize int,
) pagination.Iterator

ConcreteExecutionIterator is used to retrieve Concrete executions.

func CurrentExecution

func CurrentExecution(
	ctx context.Context,
	retryer persistence.Retryer,
	request ExecutionRequest,
) (entity.Entity, error)

CurrentExecution returns a single execution

func CurrentExecutionIterator

func CurrentExecutionIterator(
	ctx context.Context,
	retryer persistence.Retryer,
	pageSize int,
) pagination.Iterator

CurrentExecutionIterator is used to retrieve Concrete executions.

func TimerIterator

func TimerIterator(
	ctx context.Context,
	retryer persistence.Retryer,
	minTimestamp time.Time,
	maxTimestamp time.Time,
	pageSize int,
) pagination.Iterator

TimerIterator is used to retrieve Concrete executions.

Types

type ExecutionRequest

type ExecutionRequest struct {
	DomainID   string
	WorkflowID string
	RunID      string
	DomainName string
}

ExecutionRequest is used to fetch execution from persistence