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