worker

Mar 16, 2019

Changes in this version

type Context

+ func (c *Context) SetAssetsBaseURL(assetsBaseURL string)

+ func (c Context) TenantAssetsURL(path string, a ...interface{}) string

Dec 2, 2018

Changes in this version

type Task

+ OriginSessionID string

Aug 23, 2018

Changes in this version

type Context

+ func (c *Context) SetLogoURL(logoURL string)

+ func (c Context) LogoURL() string

Jun 30, 2018

Changes in this version

type Context

+ func (c *Context) Database() *dbx.Database

May 29, 2018

Changes in this version

type BackgroundWorker

+ func (w *BackgroundWorker) Shutdown(ctx context.Context) error

type Worker

+ Shutdown func(ctx context.Context) error

Apr 28, 2018

Changes in this version

type Context

+ func (c *Context) Failure(err error) error

Feb 28, 2018

Changes in this version

+ type BackgroundWorker struct

+ func New() *BackgroundWorker

+ func (w *BackgroundWorker) Enqueue(task Task)

+ func (w *BackgroundWorker) Length() int

+ func (w *BackgroundWorker) Logger() log.Logger

+ func (w *BackgroundWorker) Run(id string)

+ func (w *BackgroundWorker) Use(middleware MiddlewareFunc)

+ type Context struct

+ func NewContext(workerID, taskName string, logger log.Logger) *Context

+ func (c *Context) BaseURL() string

+ func (c *Context) Logger() log.Logger

+ func (c *Context) Services() *app.Services

+ func (c *Context) SetBaseURL(baseURL string)

+ func (c *Context) SetServices(services *app.Services)

+ func (c *Context) SetTenant(tenant *models.Tenant)

+ func (c *Context) SetUser(user *models.User)

+ func (c *Context) TaskName() string

+ func (c *Context) Tenant() *models.Tenant

+ func (c *Context) User() *models.User

+ func (c *Context) WorkerID() string

+ type Job func(c *Context) error

+ type MiddlewareFunc func(Job) Job

+ type Task struct

+ Job Job

+ Name string

+ type Worker interface

+ Enqueue func(task Task)

+ Length func() int

+ Logger func() log.Logger

+ Run func(id string)

+ Use func(middleware MiddlewareFunc)