Documentation

Overview

Package tasks contains task queue task definitions.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A task to count the VMs in a config.

func (*CountVMs) Descriptor

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

func (*CountVMs) GetId

func (m *CountVMs) GetId() string

func (*CountVMs) ProtoMessage

func (*CountVMs) ProtoMessage()

func (*CountVMs) Reset

func (m *CountVMs) Reset()

func (*CountVMs) String

func (m *CountVMs) String() string

func (*CountVMs) XXX_DiscardUnknown

func (m *CountVMs) XXX_DiscardUnknown()

func (*CountVMs) XXX_Marshal

func (m *CountVMs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CountVMs) XXX_Merge

func (m *CountVMs) XXX_Merge(src proto.Message)

func (*CountVMs) XXX_Size

func (m *CountVMs) XXX_Size() int

func (*CountVMs) XXX_Unmarshal

func (m *CountVMs) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A task to create a GCE instance from a VM.

func (*CreateInstance) Descriptor

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

func (*CreateInstance) GetId

func (m *CreateInstance) GetId() string

func (*CreateInstance) ProtoMessage

func (*CreateInstance) ProtoMessage()

func (*CreateInstance) Reset

func (m *CreateInstance) Reset()

func (*CreateInstance) String

func (m *CreateInstance) String() string

func (*CreateInstance) XXX_DiscardUnknown

func (m *CreateInstance) XXX_DiscardUnknown()

func (*CreateInstance) XXX_Marshal

func (m *CreateInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateInstance) XXX_Merge

func (m *CreateInstance) XXX_Merge(src proto.Message)

func (*CreateInstance) XXX_Size

func (m *CreateInstance) XXX_Size() int

func (*CreateInstance) XXX_Unmarshal

func (m *CreateInstance) XXX_Unmarshal(b []byte) error

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 *timestamp.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A task to create a particular VM.

func (*CreateVM) Descriptor

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

func (*CreateVM) GetAttributes

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

func (*CreateVM) GetConfig

func (m *CreateVM) GetConfig() string

func (*CreateVM) GetCreated

func (m *CreateVM) GetCreated() *timestamp.Timestamp

func (*CreateVM) GetId

func (m *CreateVM) GetId() string

func (*CreateVM) GetIndex

func (m *CreateVM) GetIndex() int32

func (*CreateVM) GetLifetime

func (m *CreateVM) GetLifetime() int64

func (*CreateVM) GetPrefix

func (m *CreateVM) GetPrefix() string

func (*CreateVM) GetRevision

func (m *CreateVM) GetRevision() string

func (*CreateVM) GetSwarming

func (m *CreateVM) GetSwarming() string

func (*CreateVM) GetTimeout

func (m *CreateVM) GetTimeout() int64

func (*CreateVM) ProtoMessage

func (*CreateVM) ProtoMessage()

func (*CreateVM) Reset

func (m *CreateVM) Reset()

func (*CreateVM) String

func (m *CreateVM) String() string

func (*CreateVM) XXX_DiscardUnknown

func (m *CreateVM) XXX_DiscardUnknown()

func (*CreateVM) XXX_Marshal

func (m *CreateVM) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateVM) XXX_Merge

func (m *CreateVM) XXX_Merge(src proto.Message)

func (*CreateVM) XXX_Size

func (m *CreateVM) XXX_Size() int

func (*CreateVM) XXX_Unmarshal

func (m *CreateVM) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*DeleteBot) Descriptor

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

func (*DeleteBot) GetHostname

func (m *DeleteBot) GetHostname() string

func (*DeleteBot) GetId

func (m *DeleteBot) GetId() string

func (*DeleteBot) ProtoMessage

func (*DeleteBot) ProtoMessage()

func (*DeleteBot) Reset

func (m *DeleteBot) Reset()

func (*DeleteBot) String

func (m *DeleteBot) String() string

func (*DeleteBot) XXX_DiscardUnknown

func (m *DeleteBot) XXX_DiscardUnknown()

func (*DeleteBot) XXX_Marshal

func (m *DeleteBot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteBot) XXX_Merge

func (m *DeleteBot) XXX_Merge(src proto.Message)

func (*DeleteBot) XXX_Size

func (m *DeleteBot) XXX_Size() int

func (*DeleteBot) XXX_Unmarshal

func (m *DeleteBot) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*DestroyInstance) Descriptor

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

func (*DestroyInstance) GetId

func (m *DestroyInstance) GetId() string

func (*DestroyInstance) GetUrl

func (m *DestroyInstance) GetUrl() string

func (*DestroyInstance) ProtoMessage

func (*DestroyInstance) ProtoMessage()

func (*DestroyInstance) Reset

func (m *DestroyInstance) Reset()

func (*DestroyInstance) String

func (m *DestroyInstance) String() string

func (*DestroyInstance) XXX_DiscardUnknown

func (m *DestroyInstance) XXX_DiscardUnknown()

func (*DestroyInstance) XXX_Marshal

func (m *DestroyInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DestroyInstance) XXX_Merge

func (m *DestroyInstance) XXX_Merge(src proto.Message)

func (*DestroyInstance) XXX_Size

func (m *DestroyInstance) XXX_Size() int

func (*DestroyInstance) XXX_Unmarshal

func (m *DestroyInstance) XXX_Unmarshal(b []byte) error

type ExpandConfig

type ExpandConfig struct {
	// The ID of the config to expand.
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A task to expand a config.

func (*ExpandConfig) Descriptor

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

func (*ExpandConfig) GetId

func (m *ExpandConfig) GetId() string

func (*ExpandConfig) ProtoMessage

func (*ExpandConfig) ProtoMessage()

func (*ExpandConfig) Reset

func (m *ExpandConfig) Reset()

func (*ExpandConfig) String

func (m *ExpandConfig) String() string

func (*ExpandConfig) XXX_DiscardUnknown

func (m *ExpandConfig) XXX_DiscardUnknown()

func (*ExpandConfig) XXX_Marshal

func (m *ExpandConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExpandConfig) XXX_Merge

func (m *ExpandConfig) XXX_Merge(src proto.Message)

func (*ExpandConfig) XXX_Size

func (m *ExpandConfig) XXX_Size() int

func (*ExpandConfig) XXX_Unmarshal

func (m *ExpandConfig) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ManageBot) Descriptor

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

func (*ManageBot) GetId

func (m *ManageBot) GetId() string

func (*ManageBot) ProtoMessage

func (*ManageBot) ProtoMessage()

func (*ManageBot) Reset

func (m *ManageBot) Reset()

func (*ManageBot) String

func (m *ManageBot) String() string

func (*ManageBot) XXX_DiscardUnknown

func (m *ManageBot) XXX_DiscardUnknown()

func (*ManageBot) XXX_Marshal

func (m *ManageBot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ManageBot) XXX_Merge

func (m *ManageBot) XXX_Merge(src proto.Message)

func (*ManageBot) XXX_Size

func (m *ManageBot) XXX_Size() int

func (*ManageBot) XXX_Unmarshal

func (m *ManageBot) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A task to report GCE quota utilization.

func (*ReportQuota) Descriptor

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

func (*ReportQuota) GetId

func (m *ReportQuota) GetId() string

func (*ReportQuota) ProtoMessage

func (*ReportQuota) ProtoMessage()

func (*ReportQuota) Reset

func (m *ReportQuota) Reset()

func (*ReportQuota) String

func (m *ReportQuota) String() string

func (*ReportQuota) XXX_DiscardUnknown

func (m *ReportQuota) XXX_DiscardUnknown()

func (*ReportQuota) XXX_Marshal

func (m *ReportQuota) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportQuota) XXX_Merge

func (m *ReportQuota) XXX_Merge(src proto.Message)

func (*ReportQuota) XXX_Size

func (m *ReportQuota) XXX_Size() int

func (*ReportQuota) XXX_Unmarshal

func (m *ReportQuota) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*TerminateBot) Descriptor

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

func (*TerminateBot) GetHostname

func (m *TerminateBot) GetHostname() string

func (*TerminateBot) GetId

func (m *TerminateBot) GetId() string

func (*TerminateBot) ProtoMessage

func (*TerminateBot) ProtoMessage()

func (*TerminateBot) Reset

func (m *TerminateBot) Reset()

func (*TerminateBot) String

func (m *TerminateBot) String() string

func (*TerminateBot) XXX_DiscardUnknown

func (m *TerminateBot) XXX_DiscardUnknown()

func (*TerminateBot) XXX_Marshal

func (m *TerminateBot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TerminateBot) XXX_Merge

func (m *TerminateBot) XXX_Merge(src proto.Message)

func (*TerminateBot) XXX_Size

func (m *TerminateBot) XXX_Size() int

func (*TerminateBot) XXX_Unmarshal

func (m *TerminateBot) XXX_Unmarshal(b []byte) error