tasks

package
v0.0.0-...-5a26747 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2025 License: Apache-2.0 Imports: 7 Imported by: 3

Documentation

Overview

Package tasks contains task queue task definitions.

Index

Constants

This section is empty.

Variables

View Source 
var File_go_chromium_org_luci_gce_api_tasks_v1_tasks_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AuditProject 

type AuditProject struct {

	// The name of the project to audit
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The GCE zone to audit
	Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	// Page token to use with the query
	PageToken string `protobuf:"bytes,3,opt,name=pageToken,proto3" json:"pageToken,omitempty"`
	// contains filtered or unexported fields
}

A task to audit the project and instances alive within the project

func (*AuditProject) Descriptor deprecated 

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

Deprecated: Use AuditProject.ProtoReflect.Descriptor instead.

func (*AuditProject) GetPageToken 

func (x *AuditProject) GetPageToken() string

func (*AuditProject) GetProject 

func (x *AuditProject) GetProject() string

func (*AuditProject) GetZone 

func (x *AuditProject) GetZone() string

func (*AuditProject) ProtoMessage 

func (*AuditProject) ProtoMessage()

func (*AuditProject) ProtoReflect 

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

func (*AuditProject) Reset 

func (x *AuditProject) Reset()

func (*AuditProject) String 

func (x *AuditProject) String() string

type CountVMs 

type CountVMs struct {

	// The ID of the config whose VMs to count.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A task to count the VMs in a config.

func (*CountVMs) Descriptor deprecated 

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

Deprecated: Use CountVMs.ProtoReflect.Descriptor instead.

func (*CountVMs) GetId 

func (x *CountVMs) GetId() string

func (*CountVMs) ProtoMessage 

func (*CountVMs) ProtoMessage()

func (*CountVMs) ProtoReflect 

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

func (*CountVMs) Reset 

func (x *CountVMs) Reset()

func (*CountVMs) String 

func (x *CountVMs) String() string

type CreateInstance 

type CreateInstance struct {

	// The ID of the VM to create a GCE instance from.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A task to create a GCE instance from a VM.

func (*CreateInstance) Descriptor deprecated 

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

Deprecated: Use CreateInstance.ProtoReflect.Descriptor instead.

func (*CreateInstance) GetId 

func (x *CreateInstance) GetId() string

func (*CreateInstance) ProtoMessage 

func (*CreateInstance) ProtoMessage()

func (*CreateInstance) ProtoReflect 

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

func (*CreateInstance) Reset 

func (x *CreateInstance) Reset()

func (*CreateInstance) String 

func (x *CreateInstance) String() string

type CreateVM 

type CreateVM struct {

	// The ID of the VM to create.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The attributes of the VM.
	Attributes *v1.VM `protobuf:"bytes,2,opt,name=attributes,proto3" json:"attributes,omitempty"`
	// The ID of the config this VM belongs to.
	Config string `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// The timestamp when this task was created.
	Created *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
	// The index of the VM to create.
	Index int32 `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	// The lifetime of the VM in seconds.
	Lifetime int64 `protobuf:"varint,6,opt,name=lifetime,proto3" json:"lifetime,omitempty"`
	// The prefix to use when naming this VM.
	Prefix string `protobuf:"bytes,7,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// The config revision this VM is created from.
	Revision string `protobuf:"bytes,8,opt,name=revision,proto3" json:"revision,omitempty"`
	// The hostname of the Swarming server this VM connects to.
	Swarming string `protobuf:"bytes,9,opt,name=swarming,proto3" json:"swarming,omitempty"`
	// The timeout of the VM in seconds.
	Timeout int64 `protobuf:"varint,10,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// the lab DUT assigned to the VM.
	DUT string `protobuf:"bytes,11,opt,name=DUT,proto3" json:"DUT,omitempty"`
	// The timestamp when we expand the config and decide to create the vm.
	ConfigExpandTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=config_expand_time,json=configExpandTime,proto3" json:"config_expand_time,omitempty"`
	// ScalingType is how the pool size is scaled.
	ScalingType string `protobuf:"bytes,13,opt,name=scaling_type,json=scalingType,proto3" json:"scaling_type,omitempty"`
	// contains filtered or unexported fields
}

A task to create a particular VM.

func (*CreateVM) Descriptor deprecated 

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

Deprecated: Use CreateVM.ProtoReflect.Descriptor instead.

func (*CreateVM) GetAttributes 

func (x *CreateVM) GetAttributes() *v1.VM

func (*CreateVM) GetConfig 

func (x *CreateVM) GetConfig() string

func (*CreateVM) GetConfigExpandTime 

func (x *CreateVM) GetConfigExpandTime() *timestamppb.Timestamp

func (*CreateVM) GetCreated 

func (x *CreateVM) GetCreated() *timestamppb.Timestamp

func (*CreateVM) GetDUT 

func (x *CreateVM) GetDUT() string

func (*CreateVM) GetId 

func (x *CreateVM) GetId() string

func (*CreateVM) GetIndex 

func (x *CreateVM) GetIndex() int32

func (*CreateVM) GetLifetime 

func (x *CreateVM) GetLifetime() int64

func (*CreateVM) GetPrefix 

func (x *CreateVM) GetPrefix() string

func (*CreateVM) GetRevision 

func (x *CreateVM) GetRevision() string

func (*CreateVM) GetScalingType 

func (x *CreateVM) GetScalingType() string

func (*CreateVM) GetSwarming 

func (x *CreateVM) GetSwarming() string

func (*CreateVM) GetTimeout 

func (x *CreateVM) GetTimeout() int64

func (*CreateVM) ProtoMessage 

func (*CreateVM) ProtoMessage()

func (*CreateVM) ProtoReflect 

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

func (*CreateVM) Reset 

func (x *CreateVM) Reset()

func (*CreateVM) String 

func (x *CreateVM) String() string

type DeleteBot 

type DeleteBot struct {

	// The ID of the VM to delete a Swarming bot for.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The hostname of the Swarming bot to delete.
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

A task to delete a Swarming bot associated with a VM.

func (*DeleteBot) Descriptor deprecated 

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

Deprecated: Use DeleteBot.ProtoReflect.Descriptor instead.

func (*DeleteBot) GetHostname 

func (x *DeleteBot) GetHostname() string

func (*DeleteBot) GetId 

func (x *DeleteBot) GetId() string

func (*DeleteBot) ProtoMessage 

func (*DeleteBot) ProtoMessage()

func (*DeleteBot) ProtoReflect 

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

func (*DeleteBot) Reset 

func (x *DeleteBot) Reset()

func (*DeleteBot) String 

func (x *DeleteBot) String() string

type DeleteStaleSwarmingBot 

type DeleteStaleSwarmingBot struct {

	// The name of the bot to delete.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The first seen timestamp of the bot
	FirstSeenTs string `protobuf:"bytes,2,opt,name=firstSeenTs,proto3" json:"firstSeenTs,omitempty"`
	// contains filtered or unexported fields
}

A task to delete bot that is stale in swarming.

func (*DeleteStaleSwarmingBot) Descriptor deprecated 

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

Deprecated: Use DeleteStaleSwarmingBot.ProtoReflect.Descriptor instead.

func (*DeleteStaleSwarmingBot) GetFirstSeenTs 

func (x *DeleteStaleSwarmingBot) GetFirstSeenTs() string

func (*DeleteStaleSwarmingBot) GetId 

func (x *DeleteStaleSwarmingBot) GetId() string

func (*DeleteStaleSwarmingBot) ProtoMessage 

func (*DeleteStaleSwarmingBot) ProtoMessage()

func (*DeleteStaleSwarmingBot) ProtoReflect 

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

func (*DeleteStaleSwarmingBot) Reset 

func (x *DeleteStaleSwarmingBot) Reset()

func (*DeleteStaleSwarmingBot) String 

func (x *DeleteStaleSwarmingBot) String() string

type DeleteStaleSwarmingBots 

type DeleteStaleSwarmingBots struct {

	// The DeleteStaleSwarmingBot payload for the bot
	Bots []*DeleteStaleSwarmingBot `protobuf:"bytes,1,rep,name=bots,proto3" json:"bots,omitempty"`
	// contains filtered or unexported fields
}

A task to delete bots that are stale in swarming

func (*DeleteStaleSwarmingBots) Descriptor deprecated 

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

Deprecated: Use DeleteStaleSwarmingBots.ProtoReflect.Descriptor instead.

func (*DeleteStaleSwarmingBots) GetBots 

func (x *DeleteStaleSwarmingBots) GetBots() []*DeleteStaleSwarmingBot

func (*DeleteStaleSwarmingBots) ProtoMessage 

func (*DeleteStaleSwarmingBots) ProtoMessage()

func (*DeleteStaleSwarmingBots) ProtoReflect 

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

func (*DeleteStaleSwarmingBots) Reset 

func (x *DeleteStaleSwarmingBots) Reset()

func (*DeleteStaleSwarmingBots) String 

func (x *DeleteStaleSwarmingBots) String() string

type DestroyInstance 

type DestroyInstance struct {

	// The ID of the VM to destroy a GCE instance for.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The URL of the GCE instance to destroy.
	Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

A task to destroy a GCE instance created from a VM.

func (*DestroyInstance) Descriptor deprecated 

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

Deprecated: Use DestroyInstance.ProtoReflect.Descriptor instead.

func (*DestroyInstance) GetId 

func (x *DestroyInstance) GetId() string

func (*DestroyInstance) GetUrl 

func (x *DestroyInstance) GetUrl() string

func (*DestroyInstance) ProtoMessage 

func (*DestroyInstance) ProtoMessage()

func (*DestroyInstance) ProtoReflect 

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

func (*DestroyInstance) Reset 

func (x *DestroyInstance) Reset()

func (*DestroyInstance) String 

func (x *DestroyInstance) String() string

type DrainVM 

type DrainVM struct {

	// The name of the VM to drain
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A task to drain/delete the VMs and instances that are no longer needed

func (*DrainVM) Descriptor deprecated 

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

Deprecated: Use DrainVM.ProtoReflect.Descriptor instead.

func (*DrainVM) GetId 

func (x *DrainVM) GetId() string

func (*DrainVM) ProtoMessage 

func (*DrainVM) ProtoMessage()

func (*DrainVM) ProtoReflect 

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

func (*DrainVM) Reset 

func (x *DrainVM) Reset()

func (*DrainVM) String 

func (x *DrainVM) String() string

type ExpandConfig 

type ExpandConfig struct {

	// The ID of the config to expand.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The Unix time (number of seconds since 1970-01-01 UTC) when this task was
	// triggered.
	TriggeredUnixTime int64 `protobuf:"varint,2,opt,name=triggered_unix_time,json=triggeredUnixTime,proto3" json:"triggered_unix_time,omitempty"`
	// contains filtered or unexported fields
}

A task to expand a config.

func (*ExpandConfig) Descriptor deprecated 

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

Deprecated: Use ExpandConfig.ProtoReflect.Descriptor instead.

func (*ExpandConfig) GetId 

func (x *ExpandConfig) GetId() string

func (*ExpandConfig) GetTriggeredUnixTime 

func (x *ExpandConfig) GetTriggeredUnixTime() int64

func (*ExpandConfig) ProtoMessage 

func (*ExpandConfig) ProtoMessage()

func (*ExpandConfig) ProtoReflect 

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

func (*ExpandConfig) Reset 

func (x *ExpandConfig) Reset()

func (*ExpandConfig) String 

func (x *ExpandConfig) String() string

type InspectSwarming 

type InspectSwarming struct {

	// The name of the swarming service to inspect
	Swarming string `protobuf:"bytes,1,opt,name=swarming,proto3" json:"swarming,omitempty"`
	// The cursor for the swarming list query
	Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// contains filtered or unexported fields
}

A task to inspect all the bots in swarming

func (*InspectSwarming) Descriptor deprecated 

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

Deprecated: Use InspectSwarming.ProtoReflect.Descriptor instead.

func (*InspectSwarming) GetCursor 

func (x *InspectSwarming) GetCursor() string

func (*InspectSwarming) GetSwarming 

func (x *InspectSwarming) GetSwarming() string

func (*InspectSwarming) ProtoMessage 

func (*InspectSwarming) ProtoMessage()

func (*InspectSwarming) ProtoReflect 

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

func (*InspectSwarming) Reset 

func (x *InspectSwarming) Reset()

func (*InspectSwarming) String 

func (x *InspectSwarming) String() string

type ManageBot 

type ManageBot struct {

	// The ID of the VM to manage a Swarming bot for.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A task to manage a Swarming bot associated with a VM.

func (*ManageBot) Descriptor deprecated 

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

Deprecated: Use ManageBot.ProtoReflect.Descriptor instead.

func (*ManageBot) GetId 

func (x *ManageBot) GetId() string

func (*ManageBot) ProtoMessage 

func (*ManageBot) ProtoMessage()

func (*ManageBot) ProtoReflect 

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

func (*ManageBot) Reset 

func (x *ManageBot) Reset()

func (*ManageBot) String 

func (x *ManageBot) String() string

type ReportQuota 

type ReportQuota struct {

	// The ID of the project to report quota utilization for.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

A task to report GCE quota utilization.

func (*ReportQuota) Descriptor deprecated 

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

Deprecated: Use ReportQuota.ProtoReflect.Descriptor instead.

func (*ReportQuota) GetId 

func (x *ReportQuota) GetId() string

func (*ReportQuota) ProtoMessage 

func (*ReportQuota) ProtoMessage()

func (*ReportQuota) ProtoReflect 

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

func (*ReportQuota) Reset 

func (x *ReportQuota) Reset()

func (*ReportQuota) String 

func (x *ReportQuota) String() string

type Task 

type Task interface {
	GetId() string
}

Task is a task with an ID.

type TerminateBot 

type TerminateBot struct {

	// The ID of the VM to terminate a Swarming bot for.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The hostname of the Swarming bot to terminate.
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

A task to terminate a Swarming bot associated with a VM.

func (*TerminateBot) Descriptor deprecated 

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

Deprecated: Use TerminateBot.ProtoReflect.Descriptor instead.

func (*TerminateBot) GetHostname 

func (x *TerminateBot) GetHostname() string

func (*TerminateBot) GetId 

func (x *TerminateBot) GetId() string

func (*TerminateBot) ProtoMessage 

func (*TerminateBot) ProtoMessage()

func (*TerminateBot) ProtoReflect 

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

func (*TerminateBot) Reset 

func (x *TerminateBot) Reset()

func (*TerminateBot) String 

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