tasks

package
v0.0.0-...-35d8de9 Latest Latest
Warning

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

 Go to latest Published: Oct 1, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

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

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.