package events

import (
	"time"

	"github.com/hibiken/asynq"
)

const FlushGateway = "gateway:flush"

func NewFlushGateway(ttl time.Duration) *asynq.Task {
	return asynq.NewTask(FlushGateway, nil, asynq.MaxRetry(0), asynq.Unique(ttl))
}