Documentation ¶
Index ¶
- Variables
- func CreateDelayTask(queueName, subPath string, f *delay.Function, args ...interface{}) (*taskqueue.Task, error)
- func EnqueueWork(ctx context.Context, queueName, subPath string, delay time.Duration, ...) (err error)
- func EnqueueWorkMulti(ctx context.Context, queueName, subPath string, delay time.Duration, ...) (err error)
- func MustRegisterDelayedFunc(key string, i interface{}) delaying.Function
- func NewHttpAppHostGAE() strongoapp.HttpAppHost
Constants ¶
This section is empty.
Variables ¶
View Source
var AddTaskToQueue = func(c context.Context, t *taskqueue.Task, queueName string) (task *taskqueue.Task, err error) { if queueName == "" { return nil, errors.New(failedToAddTaskToQueuePrefix + "queueName is empty") } if queueName == "default" { return nil, errors.New(failedToAddTaskToQueuePrefix + "queueName is 'default'") } if task, err = taskqueue.Add(c, t, queueName); err != nil { err = fmt.Errorf("%s: %w", failedToAddTaskToQueue, err) } return }
AddTaskToQueue - adds tasks to a queue TODO: Document why whe need this
View Source
var CallDelayFunc = func(c context.Context, queueName, subPath string, f *delay.Function, args ...interface{}) error { return CallDelayFuncWithDelay(c, 0, queueName, subPath, f, args...) }
CallDelayFunc - TODO: Document why whe need this Obsolete - use EnqueueWork instead
View Source
var CallDelayFuncWithDelay = func(c context.Context, delay time.Duration, queueName, subPath string, f *delay.Function, args ...interface{}) error { if task, err := CreateDelayTask(queueName, subPath, f, args...); err != nil { return err } else { task.Delay = delay _, err = AddTaskToQueue(c, task, queueName) return err } }
CallDelayFuncWithDelay - TODO: Document why whe need this Obsolete - use EnqueueWork instead
Functions ¶
func CreateDelayTask ¶
func CreateDelayTask(queueName, subPath string, f *delay.Function, args ...interface{}) (*taskqueue.Task, error)
CreateDelayTask creates a delay task TODO: Document why whe need this
func EnqueueWork ¶ added in v0.1.3
func EnqueueWork(ctx context.Context, queueName, subPath string, delay time.Duration, f *delay.Function, args ...interface{}) (err error)
EnqueueWork - is obsolete Obsolete
func EnqueueWorkMulti ¶ added in v0.1.6
func EnqueueWorkMulti(ctx context.Context, queueName, subPath string, delay time.Duration, f *delay.Function, args ...[]interface{}) (err error)
EnqueueWorkMulti - is obsolete Obsolete
func MustRegisterDelayedFunc ¶ added in v0.1.8
func NewHttpAppHostGAE ¶
func NewHttpAppHostGAE() strongoapp.HttpAppHost
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.