queue

Documentation

Index

• Constants
• func GetTask(taskName string) *taskq.Task
• type Config
• type Queue
  • func New(cfg *Config) (*Queue, error)
  • func (q *Queue) Add(msg *taskq.Message) error
  • func (q *Queue) Close() error
  • func (q *Queue) Start(ctx context.Context) error

Constants

const (
	LoadVersionsAndUpdateServerData = "loadVersionsAndUpdateServerData"
	LoadServersAndUpdateData        = "loadServersAndUpdateData"
	UpdateServerData                = "updateServerData"
	Vacuum                          = "vacuum"
	VacuumServerData                = "vacuumServerData"
	UpdateEnnoblements              = "updateEnnoblements"
	UpdateServerEnnoblements        = "updateServerEnnoblements"
	UpdateHistory                   = "updateHistory"
	UpdateServerHistory             = "updateServerHistory"
	UpdateStats                     = "updateStats"
	UpdateServerStats               = "updateServerStats"
	DeleteNonExistentVillages       = "deleteNonExistentVillages"
	ServerDeleteNonExistentVillages = "serverDeleteNonExistentVillages"
)

Functions

func GetTask

func GetTask(taskName string) *taskq.Task

Types

type Config

type Config struct {
	Redis       redis.UniversalClient
	WorkerLimit int
	DB          *pg.DB
}

type Queue

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

func New

func New(cfg *Config) (*Queue, error)

func (*Queue) Add

func (q *Queue) Add(msg *taskq.Message) error

func (*Queue) Close

func (q *Queue) Close() error

func (*Queue) Start

func (q *Queue) Start(ctx context.Context) error