taskqueue

Feb 27, 2024

Changes in this version

type TaskQueue

+ IsReady func() bool

Feb 2, 2024

Changes in this version

+ func TenantEventConsumerQueue(t string) (fanoutQueue, error)

+ type Queue interface

+ AutoDeleted func() bool

+ Durable func() bool

+ Exclusive func() bool

+ FanoutExchangeKey func() string

+ Name func() string

type Task

+ func (t *Task) TenantID() string

type TaskQueue

+ RegisterTenant func(ctx context.Context, tenantId string) error

Jan 29, 2024

Changes in this version

type QueueType

+ const WORKFLOW_PROCESSING_QUEUE

Jan 22, 2024

Changes in this version

+ type QueueType string

+ const DISPATCHER_POOL_QUEUE

+ const EVENT_PROCESSING_QUEUE

+ const JOB_PROCESSING_QUEUE

+ const SCHEDULING_QUEUE

+ func QueueTypeFromDispatcherID(d string) QueueType

+ func QueueTypeFromTickerID(t string) QueueType

+ type Task struct

+ ID string

+ Metadata map[string]interface{}

+ Payload map[string]interface{}

+ Queue QueueType

+ Retries int

+ RetryDelay int

+ type TaskQueue interface

+ AddTask func(ctx context.Context, queue QueueType, task *Task) error

+ Subscribe func(ctx context.Context, queueType QueueType) (<-chan *Task, error)