taskqueue

Documentation

Overview

Package taskqueue provides a utility for taskqueue

Index

• Constants
• Variables
• type PushQueue
  • func (queue *PushQueue) PushTask(ctx context.Context, urlPath string, form url.Values) error
  • func (queue *PushQueue) RequestValidator() web.Handler
  • func (queue *PushQueue) ToYAML() string
• type QueueMode

Constants

const LoggerKey = "gae.taskqueue"

Variables

var Add = taskqueue.Add

Add is a wapper for google.golang.org/appengine/taskqueue.Add

Types

type PushQueue

type PushQueue struct {
	Name                  string
	BucketSize            string
	MaxConcurrentRequests string
	Rate                  string
	RetryLimit            string
	AgeLimit              string
	MinBackoffSeconds     string
	MaxBackoffSeconds     string
	MaxDoubling           string
	Target                string
}

PushQueue is a struct to define push queue.

func (*PushQueue) PushTask

func (queue *PushQueue) PushTask(ctx context.Context, urlPath string, form url.Values) error

PushTask to push a task into the queue.

func (*PushQueue) RequestValidator

func (queue *PushQueue) RequestValidator() web.Handler

RequestValidator returns a web.Handler to validate the request targets the task or not. This is useful for handlers throttled via PushTask.

func (*PushQueue) ToYAML

func (queue *PushQueue) ToYAML() string

ToYAML generates the string for the queue

type QueueMode

type QueueMode string

QueueMode is a type alias for queue mode string

const (
	QueueModePuth QueueMode = "push"
	QueueModePull           = "pull"
)

Available constants for QueueMode.