worker

type Job struct {
	// Random UUID for logging and tracing. It is generated randomly by Enqueue function when blank.
	ID uuid.UUID

	// Job type or "queue".
	Type JobType

	// Associated account.
	AccountID int64

	// Associated identity
	Identity identity.Principal

	// For logging purposes
	TraceContext propagation.MapCarrier

	// For logging purposes
	EdgeID string

	// Job arguments.
	Args any
}

type JobEnqueuer interface {
	// Enqueue delivers a job to one of the backend workers.
	Enqueue(context.Context, *Job) error
}

type JobHandler func(ctx context.Context, job *Job)

type JobType string

type JobWorker interface {
	// RegisterHandler registers an event listener for a particular type with an associated handler.
	RegisterHandler(JobType, JobHandler, any)

	// DequeueLoop starts one or more goroutines to dispatch incoming jobs.
	DequeueLoop(ctx context.Context)

	// Stop let's background workers to finish all jobs and terminates them. It blocks until workers are done.
	Stop(ctx context.Context)

	// Stats returns statistics. Not all implementations supports stats, some may return zero values.
	Stats(ctx context.Context) (Stats, error)
}

type MemoryWorker struct {
	// contains filtered or unexported fields
}

type RedisWorker struct {
	// contains filtered or unexported fields
}

type Stats struct {
	// Number of jobs currently in the queue. This is a global value - all clients see the same value.
	EnqueuedJobs uint64

	// Number of jobs currently being processed. Local value - each client has its own number.
	InFlight int64
}