tasks

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 28, 2023 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TypeCronJobEsiMarketGroups = "cronjob:esi:market:groups"
)
View Source 
const (
	TypeCronJobEsiMarketHistory = "cronjob:esi:market:history"
)
View Source 
const (
	TypeCronJobEsiMarketOrders = "cronjob:esi:market:orders"
)
View Source 
const (
	TypeCronJobEsiMarketPrices = "cronjob:esi:market:prices"
)
View Source 
const (
	TypeCronJobEsiStatus = "cronjob:esi:status"
)
View Source 
const (
	TypeCronJobEsiUniverseAncestries = "cronjob:esi:universe:ancestries"
)
View Source 
const (
	TypeCronJobEsiUniverseAsteroidBelts = "cronjob:esi:universe:asteroidbelts"
)
View Source 
const (
	TypeCronJobEsiUniverseBloodlines = "cronjob:esi:universe:bloodlines"
)
View Source 
const (
	TypeCronJobEsiUniverseCategories = "cronjob:esi:universe:categories"
)
View Source 
const (
	TypeCronJobEsiUniverseConstellations = "cronjob:esi:universe:constellations"
)
View Source 
const (
	TypeCronJobEsiUniverseFactions = "cronjob:esi:universe:factions"
)
View Source 
const (
	TypeCronJobEsiUniverseGraphics = "cronjob:esi:universe:graphics"
)
View Source 
const (
	TypeCronJobEsiUniverseGroups = "cronjob:esi:universe:groups"
)
View Source 
const (
	TypeCronJobEsiUniverseMoons = "cronjob:esi:universe:moons"
)
View Source 
const (
	TypeCronJobEsiUniversePlanets = "cronjob:esi:universe:planets"
)
View Source 
const (
	TypeCronJobEsiUniverseRaces = "cronjob:esi:universe:races"
)
View Source 
const (
	TypeCronJobEsiUniverseRegions = "cronjob:esi:universe:regions"
)
View Source 
const (
	TypeCronJobEsiUniverseStargates = "cronjob:esi:universe:stargates"
)
View Source 
const (
	TypeCronJobEsiUniverseStars = "cronjob:esi:universe:stars"
)
View Source 
const (
	TypeCronJobEsiUniverseStations = "cronjob:esi:universe:stations"
)
View Source 
const (
	TypeCronJobEsiUniverseSystemJumps = "cronjob:esi:universe:systemjumps"
)
View Source 
const (
	TypeCronJobEsiUniverseSystemKills = "cronjob:esi:universe:systemkills"
)
View Source 
const (
	TypeCronJobEsiUniverseSystems = "cronjob:esi:universe:systems"
)
View Source 
const (
	TypeCronJobEsiUniverseTypes = "cronjob:esi:universe:types"
)

Variables

View Source 
var (
	BACKGROUND_QUEUE = GetQueueOpts("background", 1)
	STANDARD_QUEUE   = GetQueueOpts("standard", 2)
	CRITICAL_QUEUE   = GetQueueOpts("high", 3)
	REALTIME_QUEUE   = GetQueueOpts("realtime", 4)
)

Functions

func AddDB 

func AddDB(database *gorm.DB)

func AddQueueClient 

func AddQueueClient(client *asynq.Client)

func HandleCronJobMarketGroupsTask added in v1.2.0 

func HandleCronJobMarketGroupsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobMarketHistoryTask added in v1.2.0 

func HandleCronJobMarketHistoryTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobMarketOrdersTask added in v1.2.0 

func HandleCronJobMarketOrdersTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobMarketPricesTask added in v1.2.0 

func HandleCronJobMarketPricesTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobStatusTask 

func HandleCronJobStatusTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseAncestriesTask added in v1.1.0 

func HandleCronJobUniverseAncestriesTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseAsteroidBeltsTask 

func HandleCronJobUniverseAsteroidBeltsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseBloodlinesTask added in v1.1.0 

func HandleCronJobUniverseBloodlinesTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseCategoriesTask added in v1.1.0 

func HandleCronJobUniverseCategoriesTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseConstellationsTask 

func HandleCronJobUniverseConstellationsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseFactionsTask added in v1.1.0 

func HandleCronJobUniverseFactionsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseGraphicsTask added in v1.1.0 

func HandleCronJobUniverseGraphicsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseGroupsTask added in v1.1.0 

func HandleCronJobUniverseGroupsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseMoonsTask 

func HandleCronJobUniverseMoonsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniversePlanetsTask 

func HandleCronJobUniversePlanetsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseRacesTask added in v1.1.0 

func HandleCronJobUniverseRacesTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseRegionsTask 

func HandleCronJobUniverseRegionsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseStargatesTask 

func HandleCronJobUniverseStargatesTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseStarsTask 

func HandleCronJobUniverseStarsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseStationsTask 

func HandleCronJobUniverseStationsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseSystemJumpsTask added in v1.1.0 

func HandleCronJobUniverseSystemJumpsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseSystemKillsTask added in v1.1.0 

func HandleCronJobUniverseSystemKillsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseSystemsTask 

func HandleCronJobUniverseSystemsTask(ctx context.Context, t *asynq.Task) error

func HandleCronJobUniverseTypesTask 

func HandleCronJobUniverseTypesTask(ctx context.Context, t *asynq.Task) error

func NewCronJobMarketGroupsTask added in v1.2.0 

func NewCronJobMarketGroupsTask(groupID int32) (*asynq.Task, error)

func NewCronJobMarketHistoryTask added in v1.2.0 

func NewCronJobMarketHistoryTask(typeID int32, regionID int32) (*asynq.Task, error)

func NewCronJobMarketOrdersTask added in v1.2.0 

func NewCronJobMarketOrdersTask(typeID int32, regionID int32) (*asynq.Task, error)

func NewCronJobMarketPricesTask added in v1.2.0 

func NewCronJobMarketPricesTask() (*asynq.Task, error)

func NewCronJobStatusTask 

func NewCronJobStatusTask() (*asynq.Task, error)

func NewCronJobUniverseAncestriesTask added in v1.1.0 

func NewCronJobUniverseAncestriesTask() (*asynq.Task, error)

func NewCronJobUniverseAsteroidBeltsTask 

func NewCronJobUniverseAsteroidBeltsTask(typeID int32) (*asynq.Task, error)

func NewCronJobUniverseBloodlinesTask added in v1.1.0 

func NewCronJobUniverseBloodlinesTask() (*asynq.Task, error)

func NewCronJobUniverseCategoriesTask added in v1.1.0 

func NewCronJobUniverseCategoriesTask(categoryID int32) (*asynq.Task, error)

func NewCronJobUniverseFactionsTask added in v1.1.0 

func NewCronJobUniverseFactionsTask() (*asynq.Task, error)

func NewCronJobUniverseGraphicsTask added in v1.1.0 

func NewCronJobUniverseGraphicsTask(graphicID int32) (*asynq.Task, error)

func NewCronJobUniverseGroupsTask added in v1.1.0 

func NewCronJobUniverseGroupsTask(groupID int32) (*asynq.Task, error)

func NewCronJobUniverseMoonsTask 

func NewCronJobUniverseMoonsTask(typeID int32) (*asynq.Task, error)

func NewCronJobUniversePlanetsTask 

func NewCronJobUniversePlanetsTask(typeID int32) (*asynq.Task, error)

func NewCronJobUniverseRegionsTask 

func NewCronJobUniverseRegionsTask(typeID int32) (*asynq.Task, error)

func NewCronJobUniverseStargatesTask 

func NewCronJobUniverseStargatesTask(typeID int32) (*asynq.Task, error)

func NewCronJobUniverseStarsTask 

func NewCronJobUniverseStarsTask(typeID int32) (*asynq.Task, error)

func NewCronJobUniverseStationsTask 

func NewCronJobUniverseStationsTask(typeID int32) (*asynq.Task, error)

func NewCronJobUniverseSystemJumpsTask added in v1.1.0 

func NewCronJobUniverseSystemJumpsTask() (*asynq.Task, error)

func NewCronJobUniverseSystemKillsTask added in v1.1.0 

func NewCronJobUniverseSystemKillsTask() (*asynq.Task, error)

func NewCronJobUniverseSystemsTask 

func NewCronJobUniverseSystemsTask(id int32) (*asynq.Task, error)

func NewCronJobUniverseTypesTask 

func NewCronJobUniverseTypesTask(typeID int32) (*asynq.Task, error)

func NewCronJobUnvierseConstellationsTask 

func NewCronJobUnvierseConstellationsTask(id int32) (*asynq.Task, error)

func NewCronJubUniverseRacesTask added in v1.1.0 

func NewCronJubUniverseRacesTask() (*asynq.Task, error)

Types

type CronJobPayload added in v1.2.0 

type CronJobPayload struct {
	Timestamp time.Time
	TTL       int
}

type CronJobPayloadTypeWithRegion added in v1.2.0 

type CronJobPayloadTypeWithRegion struct {
	Timestamp time.Time
	TTL       int
	TypeID    int32
	RegionID  int32
}

type CronJobPayloadWithType added in v1.2.0 

type CronJobPayloadWithType struct {
	Timestamp time.Time
	TTL       int
	TypeID    int32
}

type CronJobPayloadWithType64 added in v1.2.0 

type CronJobPayloadWithType64 struct {
	Timestamp time.Time
	TTL       int
	TypeID    int64
}

type QueueOpts 

type QueueOpts struct {
	Name     string
	Priority int // 1 = low, 2 = normal, 3 = high
}

func GetQueueOpts 

func GetQueueOpts(name string, priority int) QueueOpts

func (QueueOpts) GetName 

func (q QueueOpts) GetName() string

func (QueueOpts) GetPriority 

func (q QueueOpts) GetPriority() int

func (QueueOpts) GetQueue 

func (q QueueOpts) GetQueue() asynq.Option

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.