re_exec

Documentation

Index

• Constants
• func NewMemoryQueue[T any](dic *di.Container, ctx context.Context, queueLimit int, retryInterval string, ...) common.Queue[T]
• type ReExecFunc

Constants

const (
	DefaultMaxQueueLimit = 10000
	DefaultRetryInterval = "10m"
)

Functions

func NewMemoryQueue

func NewMemoryQueue[T any](dic *di.Container, ctx context.Context, queueLimit int, retryInterval string, fun ReExecFunc[T]) common.Queue[T]

NewMemoryQueue is a factory method that returns an initialized ReExecQueue.

Types

type ReExecFunc

type ReExecFunc[T any] func(context.Context, *di.Container, T) bool