delayqueue

type Handler[T any] func(ctx context.Context, job *Job[T]) error

type Job[T any] struct {
	ID       string
	Queue    string
	Payload  T
	Attempts int
}

type Option[T any] func(*RedisDelayQueue[T])

type RedisDelayQueue[T any] struct {
	// contains filtered or unexported fields
}

type TaskSummaryPayload struct {
	TaskID    string `json:"task_id"`
	CreatedAt int64  `json:"created_at"`
}

type TaskSummaryQueue struct {
	*RedisDelayQueue[*TaskSummaryPayload]
}

type VMExpireQueue struct {
	*RedisDelayQueue[*domain.VmExpireInfo]
}

type VMNotifyQueue struct {
	*RedisDelayQueue[*domain.VmIdleInfo]
}

type VMRecycleQueue struct {
	*RedisDelayQueue[*domain.VmIdleInfo]
}

type VMSleepQueue struct {
	*RedisDelayQueue[*domain.VmIdleInfo]
}