celery

Sep 30, 2022

Changes in this version

type App

+ func (a *App) ApplyAsync(path, queue string, p *AsyncParam) error

+ type AsyncParam struct

+ Args []interface{}

+ Expires time.Time

+ Kwargs map[string]interface{}

Jul 7, 2022

Changes in this version

+ const ContextKeyTaskName

+ type Middleware func(next TaskF) TaskF

type Option

+ func WithMiddlewares(chain ...Middleware) Option

Jul 2, 2022

Changes in this version

+ const DefaultMaxWorkers

+ type App struct

+ func NewApp(options ...Option) *App

+ func (a *App) Delay(path, queue string, args ...interface{}) error

+ func (a *App) Register(path, queue string, task TaskF)

+ func (a *App) Run(ctx context.Context) error

+ type Broker interface

+ Observe func(queues []string)

+ Receive func() ([]byte, error)

+ Send func(msg []byte, queue string) error

+ type Config struct

+ type Option func(*Config)

+ func WithBroker(broker Broker) Option

+ func WithCustomTaskSerializer(serializer protocol.Serializer, mime, encoding string) Option

+ func WithLogger(logger log.Logger) Option

+ func WithMaxWorkers(n int) Option

+ func WithTaskProtocol(version int) Option

+ func WithTaskSerializer(mime string) Option

+ type TaskF func(context.Context, *TaskParam)

+ type TaskParam struct

+ func NewTaskParam(args []interface{}, kwargs map[string]interface{}) *TaskParam

+ func (p *TaskParam) Args() []interface{}

+ func (p *TaskParam) Get(name string) (v interface{}, ok bool)

+ func (p *TaskParam) Kwargs() map[string]interface{}

+ func (p *TaskParam) MustBool(name string) bool

+ func (p *TaskParam) MustFloat(name string) float64

+ func (p *TaskParam) MustInt(name string) int

+ func (p *TaskParam) MustString(name string) string

+ func (p *TaskParam) NameArgs(name ...string)