taskdefs

package
v0.0.0-...-797cded Latest Latest
Warning

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

 Go to latest Published: Nov 25, 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 (x *SyncBuildsWithBackendTasks) ProtoReflect() protoreflect.Message

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.