tasks

Documentation

Overview

Package tasks contains task queue implementations.

Index

• func CancelSwarmingTask(ctx context.Context, task *taskdefs.CancelSwarmingTask) error
• func CreateSwarmingTask(ctx context.Context, task *taskdefs.CreateSwarmingTask) error
• func ExportBigQuery(ctx context.Context, task *taskdefs.ExportBigQuery) error
• func FinalizeResultDB(ctx context.Context, task *taskdefs.FinalizeResultDB) error
• func NotifyPubSub(ctx context.Context, task *taskdefs.NotifyPubSub) error

Functions

func CancelSwarmingTask

func CancelSwarmingTask(ctx context.Context, task *taskdefs.CancelSwarmingTask) error

CancelSwarmingTask enqueues a task queue task to cancel the given Swarming task.

func CreateSwarmingTask

func CreateSwarmingTask(ctx context.Context, task *taskdefs.CreateSwarmingTask) error

CreateSwarmingTask enqueues a task queue task to create a Swarming task from the given build.

func ExportBigQuery

func ExportBigQuery(ctx context.Context, task *taskdefs.ExportBigQuery) error

ExportBigQuery enqueues a task queue task to export the given build to BigQuery.

func FinalizeResultDB

func FinalizeResultDB(ctx context.Context, task *taskdefs.FinalizeResultDB) error

FinalizeResultDB enqueues a task queue task to finalize the invocation for the given build in ResultDB.

func NotifyPubSub

func NotifyPubSub(ctx context.Context, task *taskdefs.NotifyPubSub) error

NotifyPubSub enqueues a task queue task to notify Pub/Sub about the given build.