gae

Documentation

Index

• Variables
• func CreateDelayTask(queueName, subPath string, f *delay.Function, args ...interface{}) (*taskqueue.Task, error)

Variables

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 = errors.WithMessage(err, failedToAddTaskToQueue)

	}
	return
}

AddTaskToQueue - adds tasks to a queue TODO: Document why whe need this

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

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

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