appengine

May 20, 2020

Changes in this version

+ const AppEngineFailFast

+ const AppEngineQueueName

+ const AppEngineTaskETA

+ const AppEngineTaskExecutionCount

+ const AppEngineTaskName

+ const AppEngineTaskPreviousResponse

+ const AppEngineTaskRetryCount

+ const AppEngineTaskRetryReason

+ var ErrNotFoundHeader = errors.New("not found cloudtasks header")

+ type GetTask struct

+ Headers map[string]string

+ RelativeUri string

+ Routing *Routing

+ type Header struct

+ FailFast bool

+ QueueName string

+ TaskETA time.Time

+ TaskExecutionCount int64

+ TaskName string

+ TaskPreviousResponse string

+ TaskRetryCount int64

+ TaskRetryReason string

+ func GetHeader(r *http.Request) (*Header, error)

+ type JsonPostTask struct

+ Body interface{}

+ RelativeUri string

+ Routing *Routing

+ type Queue struct

+ Name string

+ ProjectID string

+ Region string

+ func (q *Queue) Parent() string

+ type Routing struct

+ Service string

+ Version string

+ type Service struct

+ func NewService(ctx context.Context, taskClient *cloudtasks.Client) (*Service, error)

+ func (s *Service) CreateGetTask(ctx context.Context, queue *Queue, task *GetTask) (string, error)

+ func (s *Service) CreateJsonPostTask(ctx context.Context, queue *Queue, task *JsonPostTask) (string, error)

+ func (s *Service) CreateTask(ctx context.Context, queue *Queue, task *Task) (string, error)

+ type Task struct

+ Body []byte

+ Headers map[string]string

+ Method string

+ RelativeUri string

+ Routing *Routing