Interface DispatchTaskStore

internal/core/exec/distributed.go:114–122

DispatchTaskStore manages the shared distributed dispatch queue.

// DispatchTaskStore manages the shared distributed dispatch queue.
type DispatchTaskStore interface {
	Enqueue(ctx context.Context, task *DispatchTask) error
	ClaimNext(ctx context.Context, claim DispatchTaskClaim) (*ClaimedDispatchTask, error)
	GetClaim(ctx context.Context, claimToken string) (*ClaimedDispatchTask, error)
	ReleaseClaim(ctx context.Context, claimToken string) error
	DeleteClaim(ctx context.Context, claimToken string) error
	CountOutstandingByQueue(ctx context.Context, queueName string, claimTimeout time.Duration) (int, error)
	HasOutstandingAttempt(ctx context.Context, attemptKey string, claimTimeout time.Duration) (bool, error)
}

// WorkerHeartbeatRecord is the shared presence record for a worker.
type WorkerHeartbeatRecord struct {