taskdefs

package
v0.0.0-...-d3da680 Latest Latest
Warning

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

Go to latest
Published: Dec 4, 2024 License: Apache-2.0 Imports: 6 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 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"`
	// Timestamp of when the task was sent to TaskBackend.
	// This is useful to find out when the task creation should expire.
	// Only used for builder with the max_concurrent_builds feature enabled.
	DequeueTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=DequeueTime,proto3" json:"DequeueTime,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) GetDequeueTime

func (x *CreateBackendBuildTask) GetDequeueTime() *timestamppb.Timestamp

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 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 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 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 PopPendingBuildTask

type PopPendingBuildTask struct {

	// ID of the build just being ended.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// ID of the builder to trigger pending builds.
	BuilderId *proto.BuilderID `protobuf:"bytes,2,opt,name=builder_id,json=builderId,proto3" json:"builder_id,omitempty"`
	// contains filtered or unexported fields
}

PopPendingBuildTask pops builds from the builder's pending_build queue and send them to task backend.

func (*PopPendingBuildTask) Descriptor deprecated

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

Deprecated: Use PopPendingBuildTask.ProtoReflect.Descriptor instead.

func (*PopPendingBuildTask) GetBuildId

func (x *PopPendingBuildTask) GetBuildId() int64

func (*PopPendingBuildTask) GetBuilderId

func (x *PopPendingBuildTask) GetBuilderId() *proto.BuilderID

func (*PopPendingBuildTask) ProtoMessage

func (*PopPendingBuildTask) ProtoMessage()

func (*PopPendingBuildTask) ProtoReflect

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

func (*PopPendingBuildTask) Reset

func (x *PopPendingBuildTask) Reset()

func (*PopPendingBuildTask) String

func (x *PopPendingBuildTask) String() string

type PushPendingBuildTask

type PushPendingBuildTask struct {

	// ID of the build just being created.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// ID of the builder the build belongs to.
	BuilderId *proto.BuilderID `protobuf:"bytes,2,opt,name=builder_id,json=builderId,proto3" json:"builder_id,omitempty"`
	// contains filtered or unexported fields
}

PushPendingBuildTask checks if the build should be pushed to the builder's pending_build queue or if the build should be immediately triggered.

func (*PushPendingBuildTask) Descriptor deprecated

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

Deprecated: Use PushPendingBuildTask.ProtoReflect.Descriptor instead.

func (*PushPendingBuildTask) GetBuildId

func (x *PushPendingBuildTask) GetBuildId() int64

func (*PushPendingBuildTask) GetBuilderId

func (x *PushPendingBuildTask) GetBuilderId() *proto.BuilderID

func (*PushPendingBuildTask) ProtoMessage

func (*PushPendingBuildTask) ProtoMessage()

func (*PushPendingBuildTask) ProtoReflect

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

func (*PushPendingBuildTask) Reset

func (x *PushPendingBuildTask) Reset()

func (*PushPendingBuildTask) String

func (x *PushPendingBuildTask) 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