taskdefs

package
v0.0.0-...-df660c4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 5 Imported by: 2

Documentation

Overview

Package taskdefs contains task queue task definitions.

Index

Constants

This section is empty.

Variables

View Source
var File_go_chromium_org_luci_buildbucket_appengine_tasks_defs_tasks_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CancelBackendTask

type CancelBackendTask struct {

	// LUCI project the task belongs to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// Target for the backend.
	Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// Task ID.
	TaskId string `protobuf:"bytes,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

A cloud task to cancel a backend task

func (*CancelBackendTask) Descriptor deprecated

func (*CancelBackendTask) Descriptor() ([]byte, []int)

Deprecated: Use CancelBackendTask.ProtoReflect.Descriptor instead.

func (*CancelBackendTask) GetProject

func (x *CancelBackendTask) GetProject() string

func (*CancelBackendTask) GetTarget

func (x *CancelBackendTask) GetTarget() string

func (*CancelBackendTask) GetTaskId

func (x *CancelBackendTask) GetTaskId() string

func (*CancelBackendTask) ProtoMessage

func (*CancelBackendTask) ProtoMessage()

func (*CancelBackendTask) ProtoReflect

func (x *CancelBackendTask) ProtoReflect() protoreflect.Message

func (*CancelBackendTask) Reset

func (x *CancelBackendTask) Reset()

func (*CancelBackendTask) String

func (x *CancelBackendTask) String() string

type CancelBuildTask

type CancelBuildTask struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

A task to cancel a build.

Besides canceling the build, the task also enqueues CancelBuildTask tasks for each of the build's children that cannot outlive it.

func (*CancelBuildTask) Descriptor deprecated

func (*CancelBuildTask) Descriptor() ([]byte, []int)

Deprecated: Use CancelBuildTask.ProtoReflect.Descriptor instead.

func (*CancelBuildTask) GetBuildId

func (x *CancelBuildTask) GetBuildId() int64

func (*CancelBuildTask) ProtoMessage

func (*CancelBuildTask) ProtoMessage()

func (*CancelBuildTask) ProtoReflect

func (x *CancelBuildTask) ProtoReflect() protoreflect.Message

func (*CancelBuildTask) Reset

func (x *CancelBuildTask) Reset()

func (*CancelBuildTask) String

func (x *CancelBuildTask) String() string

type CancelSwarmingTask

type CancelSwarmingTask struct {

	// Hostname (e.g. "chromium-swarm.appspot.com") where the task should be
	// cancelled.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Swarming task ID to cancel.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// LUCI realm the task belongs to.
	Realm string `protobuf:"bytes,3,opt,name=realm,proto3" json:"realm,omitempty"`
	// contains filtered or unexported fields
}

A task to cancel a Swarming task in Python.

func (*CancelSwarmingTask) Descriptor deprecated

func (*CancelSwarmingTask) Descriptor() ([]byte, []int)

Deprecated: Use CancelSwarmingTask.ProtoReflect.Descriptor instead.

func (*CancelSwarmingTask) GetHostname

func (x *CancelSwarmingTask) GetHostname() string

func (*CancelSwarmingTask) GetRealm

func (x *CancelSwarmingTask) GetRealm() string

func (*CancelSwarmingTask) GetTaskId

func (x *CancelSwarmingTask) GetTaskId() string

func (*CancelSwarmingTask) ProtoMessage

func (*CancelSwarmingTask) ProtoMessage()

func (*CancelSwarmingTask) ProtoReflect

func (x *CancelSwarmingTask) ProtoReflect() protoreflect.Message

func (*CancelSwarmingTask) Reset

func (x *CancelSwarmingTask) Reset()

func (*CancelSwarmingTask) String

func (x *CancelSwarmingTask) String() string

type CancelSwarmingTaskGo

type CancelSwarmingTaskGo struct {

	// Hostname (e.g. "chromium-swarm.appspot.com") where the task should be
	// cancelled.
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Swarming task ID to cancel.
	TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// LUCI realm the task belongs to.
	Realm string `protobuf:"bytes,3,opt,name=realm,proto3" json:"realm,omitempty"`
	// contains filtered or unexported fields
}

A task to cancel a Swarming task in Go.

func (*CancelSwarmingTaskGo) Descriptor deprecated

func (*CancelSwarmingTaskGo) Descriptor() ([]byte, []int)

Deprecated: Use CancelSwarmingTaskGo.ProtoReflect.Descriptor instead.

func (*CancelSwarmingTaskGo) GetHostname

func (x *CancelSwarmingTaskGo) GetHostname() string

func (*CancelSwarmingTaskGo) GetRealm

func (x *CancelSwarmingTaskGo) GetRealm() string

func (*CancelSwarmingTaskGo) GetTaskId

func (x *CancelSwarmingTaskGo) GetTaskId() string

func (*CancelSwarmingTaskGo) ProtoMessage

func (*CancelSwarmingTaskGo) ProtoMessage()

func (*CancelSwarmingTaskGo) ProtoReflect

func (x *CancelSwarmingTaskGo) ProtoReflect() protoreflect.Message

func (*CancelSwarmingTaskGo) Reset

func (x *CancelSwarmingTaskGo) Reset()

func (*CancelSwarmingTaskGo) String

func (x *CancelSwarmingTaskGo) String() string

type CheckBuildLiveness

type CheckBuildLiveness struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// The maximum amount of seconds for not hearing any build heartbeats before
	// failing the build.
	HeartbeatTimeout uint32 `protobuf:"varint,2,opt,name=heartbeat_timeout,json=heartbeatTimeout,proto3" json:"heartbeat_timeout,omitempty"`
	// contains filtered or unexported fields
}

CheckBuildLiveness is a task to check if any build updates are received for the given build during the give time period.

func (*CheckBuildLiveness) Descriptor deprecated

func (*CheckBuildLiveness) Descriptor() ([]byte, []int)

Deprecated: Use CheckBuildLiveness.ProtoReflect.Descriptor instead.

func (*CheckBuildLiveness) GetBuildId

func (x *CheckBuildLiveness) GetBuildId() int64

func (*CheckBuildLiveness) GetHeartbeatTimeout

func (x *CheckBuildLiveness) GetHeartbeatTimeout() uint32

func (*CheckBuildLiveness) ProtoMessage

func (*CheckBuildLiveness) ProtoMessage()

func (*CheckBuildLiveness) ProtoReflect

func (x *CheckBuildLiveness) ProtoReflect() protoreflect.Message

func (*CheckBuildLiveness) Reset

func (x *CheckBuildLiveness) Reset()

func (*CheckBuildLiveness) String

func (x *CheckBuildLiveness) String() string

type CreateBackendBuildTask

type CreateBackendBuildTask struct {
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// The request ID to be sent to TaskBackend RunTask for idempotency.
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

A task to create a backend task

func (*CreateBackendBuildTask) Descriptor deprecated

func (*CreateBackendBuildTask) Descriptor() ([]byte, []int)

Deprecated: Use CreateBackendBuildTask.ProtoReflect.Descriptor instead.

func (*CreateBackendBuildTask) GetBuildId

func (x *CreateBackendBuildTask) GetBuildId() int64

func (*CreateBackendBuildTask) GetRequestId

func (x *CreateBackendBuildTask) GetRequestId() string

func (*CreateBackendBuildTask) ProtoMessage

func (*CreateBackendBuildTask) ProtoMessage()

func (*CreateBackendBuildTask) ProtoReflect

func (x *CreateBackendBuildTask) ProtoReflect() protoreflect.Message

func (*CreateBackendBuildTask) Reset

func (x *CreateBackendBuildTask) Reset()

func (*CreateBackendBuildTask) String

func (x *CreateBackendBuildTask) String() string

type CreateSwarmingBuildTask

type CreateSwarmingBuildTask struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

A task to create a Swarming task.

func (*CreateSwarmingBuildTask) Descriptor deprecated

func (*CreateSwarmingBuildTask) Descriptor() ([]byte, []int)

Deprecated: Use CreateSwarmingBuildTask.ProtoReflect.Descriptor instead.

func (*CreateSwarmingBuildTask) GetBuildId

func (x *CreateSwarmingBuildTask) GetBuildId() int64

func (*CreateSwarmingBuildTask) ProtoMessage

func (*CreateSwarmingBuildTask) ProtoMessage()

func (*CreateSwarmingBuildTask) ProtoReflect

func (x *CreateSwarmingBuildTask) ProtoReflect() protoreflect.Message

func (*CreateSwarmingBuildTask) Reset

func (x *CreateSwarmingBuildTask) Reset()

func (*CreateSwarmingBuildTask) String

func (x *CreateSwarmingBuildTask) String() string

type CreateSwarmingTask

type CreateSwarmingTask struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

A task to create a Swarming task. TODO(crbug.com/1328646): Delete it after swarming-build-create migration is done.

func (*CreateSwarmingTask) Descriptor deprecated

func (*CreateSwarmingTask) Descriptor() ([]byte, []int)

Deprecated: Use CreateSwarmingTask.ProtoReflect.Descriptor instead.

func (*CreateSwarmingTask) GetBuildId

func (x *CreateSwarmingTask) GetBuildId() int64

func (*CreateSwarmingTask) ProtoMessage

func (*CreateSwarmingTask) ProtoMessage()

func (*CreateSwarmingTask) ProtoReflect

func (x *CreateSwarmingTask) ProtoReflect() protoreflect.Message

func (*CreateSwarmingTask) Reset

func (x *CreateSwarmingTask) Reset()

func (*CreateSwarmingTask) String

func (x *CreateSwarmingTask) String() string

type ExportBigQuery

type ExportBigQuery struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

A task to export a build to BigQuery. TODO(crbug.com/1356766): remove it after bq-exporter runs in Go.

func (*ExportBigQuery) Descriptor deprecated

func (*ExportBigQuery) Descriptor() ([]byte, []int)

Deprecated: Use ExportBigQuery.ProtoReflect.Descriptor instead.

func (*ExportBigQuery) GetBuildId

func (x *ExportBigQuery) GetBuildId() int64

func (*ExportBigQuery) ProtoMessage

func (*ExportBigQuery) ProtoMessage()

func (*ExportBigQuery) ProtoReflect

func (x *ExportBigQuery) ProtoReflect() protoreflect.Message

func (*ExportBigQuery) Reset

func (x *ExportBigQuery) Reset()

func (*ExportBigQuery) String

func (x *ExportBigQuery) String() string

type ExportBigQueryGo

type ExportBigQueryGo struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

A task to export a build to BigQuery.

func (*ExportBigQueryGo) Descriptor deprecated

func (*ExportBigQueryGo) Descriptor() ([]byte, []int)

Deprecated: Use ExportBigQueryGo.ProtoReflect.Descriptor instead.

func (*ExportBigQueryGo) GetBuildId

func (x *ExportBigQueryGo) GetBuildId() int64

func (*ExportBigQueryGo) ProtoMessage

func (*ExportBigQueryGo) ProtoMessage()

func (*ExportBigQueryGo) ProtoReflect

func (x *ExportBigQueryGo) ProtoReflect() protoreflect.Message

func (*ExportBigQueryGo) Reset

func (x *ExportBigQueryGo) Reset()

func (*ExportBigQueryGo) String

func (x *ExportBigQueryGo) String() string

type FinalizeResultDB

type FinalizeResultDB struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

A task to finalize an invocation in ResultDB.

func (*FinalizeResultDB) Descriptor deprecated

func (*FinalizeResultDB) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeResultDB.ProtoReflect.Descriptor instead.

func (*FinalizeResultDB) GetBuildId

func (x *FinalizeResultDB) GetBuildId() int64

func (*FinalizeResultDB) ProtoMessage

func (*FinalizeResultDB) ProtoMessage()

func (*FinalizeResultDB) ProtoReflect

func (x *FinalizeResultDB) ProtoReflect() protoreflect.Message

func (*FinalizeResultDB) Reset

func (x *FinalizeResultDB) Reset()

func (*FinalizeResultDB) String

func (x *FinalizeResultDB) String() string

type FinalizeResultDBGo

type FinalizeResultDBGo struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// contains filtered or unexported fields
}

A task to finalize an invocation in ResultDB.

func (*FinalizeResultDBGo) Descriptor deprecated

func (*FinalizeResultDBGo) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeResultDBGo.ProtoReflect.Descriptor instead.

func (*FinalizeResultDBGo) GetBuildId

func (x *FinalizeResultDBGo) GetBuildId() int64

func (*FinalizeResultDBGo) ProtoMessage

func (*FinalizeResultDBGo) ProtoMessage()

func (*FinalizeResultDBGo) ProtoReflect

func (x *FinalizeResultDBGo) ProtoReflect() protoreflect.Message

func (*FinalizeResultDBGo) Reset

func (x *FinalizeResultDBGo) Reset()

func (*FinalizeResultDBGo) String

func (x *FinalizeResultDBGo) String() string

type NotifyPubSub

type NotifyPubSub struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Whether to use the global or build-specific callback Pub/Sub topic.
	Callback bool `protobuf:"varint,2,opt,name=callback,proto3" json:"callback,omitempty"`
	// contains filtered or unexported fields
}

A task to send a build notification on `builds` Pub/Sub.

func (*NotifyPubSub) Descriptor deprecated

func (*NotifyPubSub) Descriptor() ([]byte, []int)

Deprecated: Use NotifyPubSub.ProtoReflect.Descriptor instead.

func (*NotifyPubSub) GetBuildId

func (x *NotifyPubSub) GetBuildId() int64

func (*NotifyPubSub) GetCallback

func (x *NotifyPubSub) GetCallback() bool

func (*NotifyPubSub) ProtoMessage

func (*NotifyPubSub) ProtoMessage()

func (*NotifyPubSub) ProtoReflect

func (x *NotifyPubSub) ProtoReflect() protoreflect.Message

func (*NotifyPubSub) Reset

func (x *NotifyPubSub) Reset()

func (*NotifyPubSub) String

func (x *NotifyPubSub) String() string

type NotifyPubSubGo

type NotifyPubSubGo struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// An external topic which a build notification should be sent to.
	// If nil or empty, will send to the internal `builds_v2` topic.
	Topic *proto.BuildbucketCfg_Topic `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// Whether to use the global or build-specific callback Pub/Sub topic.
	Callback bool `protobuf:"varint,3,opt,name=callback,proto3" json:"callback,omitempty"`
	// contains filtered or unexported fields
}

A task to send a build notification when a build status changes.

func (*NotifyPubSubGo) Descriptor deprecated

func (*NotifyPubSubGo) Descriptor() ([]byte, []int)

Deprecated: Use NotifyPubSubGo.ProtoReflect.Descriptor instead.

func (*NotifyPubSubGo) GetBuildId

func (x *NotifyPubSubGo) GetBuildId() int64

func (*NotifyPubSubGo) GetCallback

func (x *NotifyPubSubGo) GetCallback() bool

func (*NotifyPubSubGo) GetTopic

func (x *NotifyPubSubGo) GetTopic() *proto.BuildbucketCfg_Topic

func (*NotifyPubSubGo) ProtoMessage

func (*NotifyPubSubGo) ProtoMessage()

func (*NotifyPubSubGo) ProtoReflect

func (x *NotifyPubSubGo) ProtoReflect() protoreflect.Message

func (*NotifyPubSubGo) Reset

func (x *NotifyPubSubGo) Reset()

func (*NotifyPubSubGo) String

func (x *NotifyPubSubGo) String() string

type NotifyPubSubGoProxy

type NotifyPubSubGoProxy struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// The project that the build belongs to.
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

NotifyPubSubGoProxy tasks dispatch NotifyPubSubGo tasks to send builds_v2 notifications.

func (*NotifyPubSubGoProxy) Descriptor deprecated

func (*NotifyPubSubGoProxy) Descriptor() ([]byte, []int)

Deprecated: Use NotifyPubSubGoProxy.ProtoReflect.Descriptor instead.

func (*NotifyPubSubGoProxy) GetBuildId

func (x *NotifyPubSubGoProxy) GetBuildId() int64

func (*NotifyPubSubGoProxy) GetProject

func (x *NotifyPubSubGoProxy) GetProject() string

func (*NotifyPubSubGoProxy) ProtoMessage

func (*NotifyPubSubGoProxy) ProtoMessage()

func (*NotifyPubSubGoProxy) ProtoReflect

func (x *NotifyPubSubGoProxy) ProtoReflect() protoreflect.Message

func (*NotifyPubSubGoProxy) Reset

func (x *NotifyPubSubGoProxy) Reset()

func (*NotifyPubSubGoProxy) String

func (x *NotifyPubSubGoProxy) String() string

type SyncBuildsWithBackendTasks

type SyncBuildsWithBackendTasks struct {

	// Target of the backend.
	Backend string `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	// LUCI project .
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

SyncBuildsWithBackendTasks finds builds that have exceeded their next sync time, then updates the builds. The builds should belong to the same project and run on the same backend.

func (*SyncBuildsWithBackendTasks) Descriptor deprecated

func (*SyncBuildsWithBackendTasks) Descriptor() ([]byte, []int)

Deprecated: Use SyncBuildsWithBackendTasks.ProtoReflect.Descriptor instead.

func (*SyncBuildsWithBackendTasks) GetBackend

func (x *SyncBuildsWithBackendTasks) GetBackend() string

func (*SyncBuildsWithBackendTasks) GetProject

func (x *SyncBuildsWithBackendTasks) GetProject() string

func (*SyncBuildsWithBackendTasks) ProtoMessage

func (*SyncBuildsWithBackendTasks) ProtoMessage()

func (*SyncBuildsWithBackendTasks) ProtoReflect

func (*SyncBuildsWithBackendTasks) Reset

func (x *SyncBuildsWithBackendTasks) Reset()

func (*SyncBuildsWithBackendTasks) String

func (x *SyncBuildsWithBackendTasks) String() string

type SyncSwarmingBuildTask

type SyncSwarmingBuildTask struct {

	// ID of a build in the datastore. See model.Build.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Generation indicates how many times this build has been put back into the
	// swarming sync queue.
	Generation int64 `protobuf:"varint,2,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

A task to create a Swarming task.

func (*SyncSwarmingBuildTask) Descriptor deprecated

func (*SyncSwarmingBuildTask) Descriptor() ([]byte, []int)

Deprecated: Use SyncSwarmingBuildTask.ProtoReflect.Descriptor instead.

func (*SyncSwarmingBuildTask) GetBuildId

func (x *SyncSwarmingBuildTask) GetBuildId() int64

func (*SyncSwarmingBuildTask) GetGeneration

func (x *SyncSwarmingBuildTask) GetGeneration() int64

func (*SyncSwarmingBuildTask) ProtoMessage

func (*SyncSwarmingBuildTask) ProtoMessage()

func (*SyncSwarmingBuildTask) ProtoReflect

func (x *SyncSwarmingBuildTask) ProtoReflect() protoreflect.Message

func (*SyncSwarmingBuildTask) Reset

func (x *SyncSwarmingBuildTask) Reset()

func (*SyncSwarmingBuildTask) String

func (x *SyncSwarmingBuildTask) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL