luci: go.chromium.org/luci/dm/api/distributor/swarming/v1 Index | Files

package swarmingV1

import "go.chromium.org/luci/dm/api/distributor/swarming/v1"

Index

Package Files

cipd.go cipd.pb.go config.pb.go gen.go isolate_ref.pb.go normalize.go params.pb.go result.pb.go

Constants

const DefaultSwarmingPriority = 100

DefaultSwarmingPriority is the priority used if Parameters.scheduling.priority == 0.

type CipdPackage Uses

type CipdPackage struct {
    Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
    Version              string   `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*CipdPackage) Descriptor Uses

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

func (*CipdPackage) GetName Uses

func (m *CipdPackage) GetName() string

func (*CipdPackage) GetVersion Uses

func (m *CipdPackage) GetVersion() string

func (*CipdPackage) Normalize Uses

func (p *CipdPackage) Normalize() error

Normalize normalizes and checks for input violations.

func (*CipdPackage) ProtoMessage Uses

func (*CipdPackage) ProtoMessage()

func (*CipdPackage) Reset Uses

func (m *CipdPackage) Reset()

func (*CipdPackage) String Uses

func (m *CipdPackage) String() string

func (*CipdPackage) ToCipdPackage Uses

func (c *CipdPackage) ToCipdPackage() *swarm.SwarmingRpcsCipdPackage

ToCipdPackage converts this to a swarming api SwarmingRpcsCipdPackage.

func (*CipdPackage) XXX_DiscardUnknown Uses

func (m *CipdPackage) XXX_DiscardUnknown()

func (*CipdPackage) XXX_Marshal Uses

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

func (*CipdPackage) XXX_Merge Uses

func (dst *CipdPackage) XXX_Merge(src proto.Message)

func (*CipdPackage) XXX_Size Uses

func (m *CipdPackage) XXX_Size() int

func (*CipdPackage) XXX_Unmarshal Uses

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

type CipdSpec Uses

type CipdSpec struct {
    // Server to use for cipd packages. Required (though it may be specified
    // by the quest's designated distributor config). This must be
    // scheme://<hostname>, e.g. "https://example.appspot.com". The only
    // supported schemes are http and https.
    Server string `protobuf:"bytes,1,opt,name=server" json:"server,omitempty"`
    // Specifies the CIPD package to use for the job to obtain the actual CIPD
    // client binary. You usually want to omit this.
    Client *CipdPackage `protobuf:"bytes,2,opt,name=client" json:"client,omitempty"`
    // A mapping from path-to-install to a list of cipd packages to install at
    // that location. To install packages in the root of the job, use the path
    // ''.
    ByPath               map[string]*CipdSpec_CipdPackages `protobuf:"bytes,3,rep,name=by_path,json=byPath" json:"by_path,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
    XXX_unrecognized     []byte                            `json:"-"`
    XXX_sizecache        int32                             `json:"-"`
}

func (*CipdSpec) Descriptor Uses

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

func (*CipdSpec) GetByPath Uses

func (m *CipdSpec) GetByPath() map[string]*CipdSpec_CipdPackages

func (*CipdSpec) GetClient Uses

func (m *CipdSpec) GetClient() *CipdPackage

func (*CipdSpec) GetServer Uses

func (m *CipdSpec) GetServer() string

func (*CipdSpec) Normalize Uses

func (c *CipdSpec) Normalize() error

Normalize normalizes and checks for input violations.

func (*CipdSpec) ProtoMessage Uses

func (*CipdSpec) ProtoMessage()

func (*CipdSpec) Reset Uses

func (m *CipdSpec) Reset()

func (*CipdSpec) String Uses

func (m *CipdSpec) String() string

func (*CipdSpec) ToCipdInput Uses

func (c *CipdSpec) ToCipdInput() *swarm.SwarmingRpcsCipdInput

ToCipdInput converts this to a swarming api SwarmingRpcsCipdInput.

func (*CipdSpec) XXX_DiscardUnknown Uses

func (m *CipdSpec) XXX_DiscardUnknown()

func (*CipdSpec) XXX_Marshal Uses

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

func (*CipdSpec) XXX_Merge Uses

func (dst *CipdSpec) XXX_Merge(src proto.Message)

func (*CipdSpec) XXX_Size Uses

func (m *CipdSpec) XXX_Size() int

func (*CipdSpec) XXX_Unmarshal Uses

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

type CipdSpec_CipdPackages Uses

type CipdSpec_CipdPackages struct {
    Pkg                  []*CipdPackage `protobuf:"bytes,1,rep,name=pkg" json:"pkg,omitempty"`
    XXX_NoUnkeyedLiteral struct{}       `json:"-"`
    XXX_unrecognized     []byte         `json:"-"`
    XXX_sizecache        int32          `json:"-"`
}

func (*CipdSpec_CipdPackages) Descriptor Uses

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

func (*CipdSpec_CipdPackages) GetPkg Uses

func (m *CipdSpec_CipdPackages) GetPkg() []*CipdPackage

func (*CipdSpec_CipdPackages) ProtoMessage Uses

func (*CipdSpec_CipdPackages) ProtoMessage()

func (*CipdSpec_CipdPackages) Reset Uses

func (m *CipdSpec_CipdPackages) Reset()

func (*CipdSpec_CipdPackages) String Uses

func (m *CipdSpec_CipdPackages) String() string

func (*CipdSpec_CipdPackages) XXX_DiscardUnknown Uses

func (m *CipdSpec_CipdPackages) XXX_DiscardUnknown()

func (*CipdSpec_CipdPackages) XXX_Marshal Uses

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

func (*CipdSpec_CipdPackages) XXX_Merge Uses

func (dst *CipdSpec_CipdPackages) XXX_Merge(src proto.Message)

func (*CipdSpec_CipdPackages) XXX_Size Uses

func (m *CipdSpec_CipdPackages) XXX_Size() int

func (*CipdSpec_CipdPackages) XXX_Unmarshal Uses

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

type Config Uses

type Config struct {
    Swarming             *Config_Swarming `protobuf:"bytes,1,opt,name=swarming" json:"swarming,omitempty"`
    Isolate              *Config_Isolate  `protobuf:"bytes,2,opt,name=isolate" json:"isolate,omitempty"`
    XXX_NoUnkeyedLiteral struct{}         `json:"-"`
    XXX_unrecognized     []byte           `json:"-"`
    XXX_sizecache        int32            `json:"-"`
}

func (*Config) Descriptor Uses

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

func (*Config) GetIsolate Uses

func (m *Config) GetIsolate() *Config_Isolate

func (*Config) GetSwarming Uses

func (m *Config) GetSwarming() *Config_Swarming

func (*Config) Normalize Uses

func (c *Config) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Config) ProtoMessage Uses

func (*Config) ProtoMessage()

func (*Config) Reset Uses

func (m *Config) Reset()

func (*Config) String Uses

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown Uses

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal Uses

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

func (*Config) XXX_Merge Uses

func (dst *Config) XXX_Merge(src proto.Message)

func (*Config) XXX_Size Uses

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal Uses

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

type Config_Isolate Uses

type Config_Isolate struct {
    // The host of the isolate service, e.g. isolateserver.appspot.com.
    Url string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
    // The default assumed expiration period for execution results.
    Expiration           *duration.Duration `protobuf:"bytes,2,opt,name=expiration" json:"expiration,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

func (*Config_Isolate) Descriptor Uses

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

func (*Config_Isolate) GetExpiration Uses

func (m *Config_Isolate) GetExpiration() *duration.Duration

func (*Config_Isolate) GetUrl Uses

func (m *Config_Isolate) GetUrl() string

func (*Config_Isolate) Normalize Uses

func (i *Config_Isolate) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Config_Isolate) ProtoMessage Uses

func (*Config_Isolate) ProtoMessage()

func (*Config_Isolate) Reset Uses

func (m *Config_Isolate) Reset()

func (*Config_Isolate) String Uses

func (m *Config_Isolate) String() string

func (*Config_Isolate) XXX_DiscardUnknown Uses

func (m *Config_Isolate) XXX_DiscardUnknown()

func (*Config_Isolate) XXX_Marshal Uses

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

func (*Config_Isolate) XXX_Merge Uses

func (dst *Config_Isolate) XXX_Merge(src proto.Message)

func (*Config_Isolate) XXX_Size Uses

func (m *Config_Isolate) XXX_Size() int

func (*Config_Isolate) XXX_Unmarshal Uses

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

type Config_Swarming Uses

type Config_Swarming struct {
    Url                  string   `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Config_Swarming) Descriptor Uses

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

func (*Config_Swarming) GetUrl Uses

func (m *Config_Swarming) GetUrl() string

func (*Config_Swarming) Normalize Uses

func (s *Config_Swarming) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Config_Swarming) ProtoMessage Uses

func (*Config_Swarming) ProtoMessage()

func (*Config_Swarming) Reset Uses

func (m *Config_Swarming) Reset()

func (*Config_Swarming) String Uses

func (m *Config_Swarming) String() string

func (*Config_Swarming) XXX_DiscardUnknown Uses

func (m *Config_Swarming) XXX_DiscardUnknown()

func (*Config_Swarming) XXX_Marshal Uses

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

func (*Config_Swarming) XXX_Merge Uses

func (dst *Config_Swarming) XXX_Merge(src proto.Message)

func (*Config_Swarming) XXX_Size Uses

func (m *Config_Swarming) XXX_Size() int

func (*Config_Swarming) XXX_Unmarshal Uses

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

type IsolatedRef Uses

type IsolatedRef struct {
    Id                   string   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
    Server               string   `protobuf:"bytes,2,opt,name=server" json:"server,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*IsolatedRef) Descriptor Uses

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

func (*IsolatedRef) GetId Uses

func (m *IsolatedRef) GetId() string

func (*IsolatedRef) GetServer Uses

func (m *IsolatedRef) GetServer() string

func (*IsolatedRef) ProtoMessage Uses

func (*IsolatedRef) ProtoMessage()

func (*IsolatedRef) Reset Uses

func (m *IsolatedRef) Reset()

func (*IsolatedRef) String Uses

func (m *IsolatedRef) String() string

func (*IsolatedRef) XXX_DiscardUnknown Uses

func (m *IsolatedRef) XXX_DiscardUnknown()

func (*IsolatedRef) XXX_Marshal Uses

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

func (*IsolatedRef) XXX_Merge Uses

func (dst *IsolatedRef) XXX_Merge(src proto.Message)

func (*IsolatedRef) XXX_Size Uses

func (m *IsolatedRef) XXX_Size() int

func (*IsolatedRef) XXX_Unmarshal Uses

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

type Parameters Uses

type Parameters struct {
    Scheduling           *Parameters_Scheduling `protobuf:"bytes,1,opt,name=scheduling" json:"scheduling,omitempty"`
    Meta                 *Parameters_Meta       `protobuf:"bytes,2,opt,name=meta" json:"meta,omitempty"`
    Job                  *Parameters_Job        `protobuf:"bytes,3,opt,name=job" json:"job,omitempty"`
    XXX_NoUnkeyedLiteral struct{}               `json:"-"`
    XXX_unrecognized     []byte                 `json:"-"`
    XXX_sizecache        int32                  `json:"-"`
}

Parameters represents the set of swarming parameters that the Swarming v1 distributor can interpret for use with a Swarming v1 compatible service.

func (*Parameters) Descriptor Uses

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

func (*Parameters) GetJob Uses

func (m *Parameters) GetJob() *Parameters_Job

func (*Parameters) GetMeta Uses

func (m *Parameters) GetMeta() *Parameters_Meta

func (*Parameters) GetScheduling Uses

func (m *Parameters) GetScheduling() *Parameters_Scheduling

func (*Parameters) Normalize Uses

func (p *Parameters) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Parameters) ProtoMessage Uses

func (*Parameters) ProtoMessage()

func (*Parameters) Reset Uses

func (m *Parameters) Reset()

func (*Parameters) String Uses

func (m *Parameters) String() string

func (*Parameters) XXX_DiscardUnknown Uses

func (m *Parameters) XXX_DiscardUnknown()

func (*Parameters) XXX_Marshal Uses

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

func (*Parameters) XXX_Merge Uses

func (dst *Parameters) XXX_Merge(src proto.Message)

func (*Parameters) XXX_Size Uses

func (m *Parameters) XXX_Size() int

func (*Parameters) XXX_Unmarshal Uses

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

type Parameters_Job Uses

type Parameters_Job struct {
    Inputs *Parameters_Job_Inputs `protobuf:"bytes,1,opt,name=inputs" json:"inputs,omitempty"`
    // This is the "argv" to run with this job. This includes substitution
    // paramters defined by swarming's run_isolated.py script:
    //   https://github.com/luci/luci-py/blob/master/client/run_isolated.py
    //
    // Additionally, DM provides the following substitutions:
    //   ${DM.PREVIOUS.EXECUTION.STATE:PATH} - the path to a JSONPB encoding of
    //     the swarming_v1.Result from the previous Execution of this Attempt.
    //   ${DM.QUEST.DATA.DESC:PATH} - the path to the
    //     dm.Quest.Data.Desc JSONPB for the quest that this execution is part
    //     of.
    //   ${DM.HOST} - the hostname to use to access DM's pRPC API.
    //
    // DM also provides a JSONPB encoded dm.Execution.Auth via the LUCI_CONTEXT
    // swarming.secret_bytes value. See:
    //   https://github.com/luci/luci-py/blob/master/client/LUCI_CONTEXT.md
    //
    // Command MUST be specified; specifying a command in any of the isolated
    // inputs WILL NOT DO ANYTHING.
    Command []string `protobuf:"bytes,2,rep,name=command" json:"command,omitempty"`
    // Environment variables for the executions.
    Env                  map[string]string `protobuf:"bytes,3,rep,name=env" json:"env,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*Parameters_Job) Descriptor Uses

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

func (*Parameters_Job) GetCommand Uses

func (m *Parameters_Job) GetCommand() []string

func (*Parameters_Job) GetEnv Uses

func (m *Parameters_Job) GetEnv() map[string]string

func (*Parameters_Job) GetInputs Uses

func (m *Parameters_Job) GetInputs() *Parameters_Job_Inputs

func (*Parameters_Job) Normalize Uses

func (j *Parameters_Job) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Parameters_Job) ProtoMessage Uses

func (*Parameters_Job) ProtoMessage()

func (*Parameters_Job) Reset Uses

func (m *Parameters_Job) Reset()

func (*Parameters_Job) String Uses

func (m *Parameters_Job) String() string

func (*Parameters_Job) XXX_DiscardUnknown Uses

func (m *Parameters_Job) XXX_DiscardUnknown()

func (*Parameters_Job) XXX_Marshal Uses

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

func (*Parameters_Job) XXX_Merge Uses

func (dst *Parameters_Job) XXX_Merge(src proto.Message)

func (*Parameters_Job) XXX_Size Uses

func (m *Parameters_Job) XXX_Size() int

func (*Parameters_Job) XXX_Unmarshal Uses

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

type Parameters_Job_Inputs Uses

type Parameters_Job_Inputs struct {
    // 0 or more isolated IDs that will be 'included' together into the final
    // job .isolated sent to swarming.
    //
    // The "server" value must either be omitted, or equal the isolate server
    // defined by this distributor's config (the `isolate.host` field,
    // prepended with "https://").
    Isolated []*IsolatedRef `protobuf:"bytes,1,rep,name=isolated" json:"isolated,omitempty"`
    // CIPD packages to use for the job. These specs may contain templated
    // parameters for package names or non-instance_ids for the package
    // versions. The first successful execution for each attempt will
    // resolve+snapshot all package names and versions. These package names
    // and versions will be used for all subsequent executions of that
    // attempt.
    Cipd                 *CipdSpec `protobuf:"bytes,2,opt,name=cipd" json:"cipd,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*Parameters_Job_Inputs) Descriptor Uses

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

func (*Parameters_Job_Inputs) GetCipd Uses

func (m *Parameters_Job_Inputs) GetCipd() *CipdSpec

func (*Parameters_Job_Inputs) GetIsolated Uses

func (m *Parameters_Job_Inputs) GetIsolated() []*IsolatedRef

func (*Parameters_Job_Inputs) Normalize Uses

func (i *Parameters_Job_Inputs) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Parameters_Job_Inputs) ProtoMessage Uses

func (*Parameters_Job_Inputs) ProtoMessage()

func (*Parameters_Job_Inputs) Reset Uses

func (m *Parameters_Job_Inputs) Reset()

func (*Parameters_Job_Inputs) String Uses

func (m *Parameters_Job_Inputs) String() string

func (*Parameters_Job_Inputs) XXX_DiscardUnknown Uses

func (m *Parameters_Job_Inputs) XXX_DiscardUnknown()

func (*Parameters_Job_Inputs) XXX_Marshal Uses

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

func (*Parameters_Job_Inputs) XXX_Merge Uses

func (dst *Parameters_Job_Inputs) XXX_Merge(src proto.Message)

func (*Parameters_Job_Inputs) XXX_Size Uses

func (m *Parameters_Job_Inputs) XXX_Size() int

func (*Parameters_Job_Inputs) XXX_Unmarshal Uses

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

type Parameters_Meta Uses

type Parameters_Meta struct {
    // The 'human readable' name prefix for Executions of this quest. DM will
    // automatically prepend this to the execution ID. So if this was "cool
    // job", the swarming task name would be
    //   "cool job / <quest_ID>|<attempt>|<execution>"
    NamePrefix           string   `protobuf:"bytes,1,opt,name=name_prefix,json=namePrefix" json:"name_prefix,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Parameters_Meta) Descriptor Uses

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

func (*Parameters_Meta) GetNamePrefix Uses

func (m *Parameters_Meta) GetNamePrefix() string

func (*Parameters_Meta) Normalize Uses

func (m *Parameters_Meta) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Parameters_Meta) ProtoMessage Uses

func (*Parameters_Meta) ProtoMessage()

func (*Parameters_Meta) Reset Uses

func (m *Parameters_Meta) Reset()

func (*Parameters_Meta) String Uses

func (m *Parameters_Meta) String() string

func (*Parameters_Meta) XXX_DiscardUnknown Uses

func (m *Parameters_Meta) XXX_DiscardUnknown()

func (*Parameters_Meta) XXX_Marshal Uses

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

func (*Parameters_Meta) XXX_Merge Uses

func (dst *Parameters_Meta) XXX_Merge(src proto.Message)

func (*Parameters_Meta) XXX_Size Uses

func (m *Parameters_Meta) XXX_Size() int

func (*Parameters_Meta) XXX_Unmarshal Uses

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

type Parameters_Scheduling Uses

type Parameters_Scheduling struct {
    // Priority adjusts the scheduling preference for Executions. The higher the
    // priority number, the longer it will take to schedule, and vice versa (ala
    // `nice`).
    //
    // A value of 0 (default) corresponds to a default priority (currently 100).
    // Other values correspond directly to the swarming task Priority.
    //
    // THIS MEANS THAT PRIORITY 0 IS NOT PERMITTED HERE! If you want 0, use
    // 1 instead.
    //
    // This must be <= 255.
    Priority uint32 `protobuf:"varint,1,opt,name=priority" json:"priority,omitempty"`
    // These specifiy the profile of the machine to use for Execuions of this
    // quest. These can indicate OS, number of cores, amount of ram, GPU type,
    // pool, etc. See the swarming service instance for available dimensions.
    Dimensions map[string]string `protobuf:"bytes,2,rep,name=dimensions" json:"dimensions,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    // These dimensions will be snapshotted from the first execution of each
    // attempt, and will be subsequently re-used for all following executions of
    // that attempt.
    //
    // The most-specific value for these dimensions will be taken for tasks
    // where a given dimension has multiple values.
    SnapshotDimensions []string `protobuf:"bytes,3,rep,name=snapshot_dimensions,json=snapshotDimensions" json:"snapshot_dimensions,omitempty"`
    // This indicates the maximum amount of time that an Execution may run
    // without emitting IO on stdout/err. 0 means 'no timeout'.
    IoTimeout            *duration.Duration `protobuf:"bytes,4,opt,name=io_timeout,json=ioTimeout" json:"io_timeout,omitempty"`
    XXX_NoUnkeyedLiteral struct{}           `json:"-"`
    XXX_unrecognized     []byte             `json:"-"`
    XXX_sizecache        int32              `json:"-"`
}

These parameters affect how the Executions for this Quest are scheduled.

func (*Parameters_Scheduling) Descriptor Uses

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

func (*Parameters_Scheduling) GetDimensions Uses

func (m *Parameters_Scheduling) GetDimensions() map[string]string

func (*Parameters_Scheduling) GetIoTimeout Uses

func (m *Parameters_Scheduling) GetIoTimeout() *duration.Duration

func (*Parameters_Scheduling) GetPriority Uses

func (m *Parameters_Scheduling) GetPriority() uint32

func (*Parameters_Scheduling) GetSnapshotDimensions Uses

func (m *Parameters_Scheduling) GetSnapshotDimensions() []string

func (*Parameters_Scheduling) Normalize Uses

func (s *Parameters_Scheduling) Normalize() (err error)

Normalize normalizes and checks for input violations.

func (*Parameters_Scheduling) ProtoMessage Uses

func (*Parameters_Scheduling) ProtoMessage()

func (*Parameters_Scheduling) Reset Uses

func (m *Parameters_Scheduling) Reset()

func (*Parameters_Scheduling) String Uses

func (m *Parameters_Scheduling) String() string

func (*Parameters_Scheduling) XXX_DiscardUnknown Uses

func (m *Parameters_Scheduling) XXX_DiscardUnknown()

func (*Parameters_Scheduling) XXX_Marshal Uses

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

func (*Parameters_Scheduling) XXX_Merge Uses

func (dst *Parameters_Scheduling) XXX_Merge(src proto.Message)

func (*Parameters_Scheduling) XXX_Size Uses

func (m *Parameters_Scheduling) XXX_Size() int

func (*Parameters_Scheduling) XXX_Unmarshal Uses

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

type Result Uses

type Result struct {
    ExitCode int64 `protobuf:"varint,1,opt,name=exit_code,json=exitCode" json:"exit_code,omitempty"`
    // The isolated hash of the output directory
    IsolatedOutdir *IsolatedRef `protobuf:"bytes,2,opt,name=isolated_outdir,json=isolatedOutdir" json:"isolated_outdir,omitempty"`
    // The pinned cipd packages that this task actually used.
    CipdPins *CipdSpec `protobuf:"bytes,3,opt,name=cipd_pins,json=cipdPins" json:"cipd_pins,omitempty"`
    // The captured snapshot dimensions that the bot actually had.
    SnapshotDimensions   map[string]string `protobuf:"bytes,4,rep,name=snapshot_dimensions,json=snapshotDimensions" json:"snapshot_dimensions,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

This is the swarming-specific result for Executions run via swarming.

func (*Result) Descriptor Uses

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

func (*Result) GetCipdPins Uses

func (m *Result) GetCipdPins() *CipdSpec

func (*Result) GetExitCode Uses

func (m *Result) GetExitCode() int64

func (*Result) GetIsolatedOutdir Uses

func (m *Result) GetIsolatedOutdir() *IsolatedRef

func (*Result) GetSnapshotDimensions Uses

func (m *Result) GetSnapshotDimensions() map[string]string

func (*Result) ProtoMessage Uses

func (*Result) ProtoMessage()

func (*Result) Reset Uses

func (m *Result) Reset()

func (*Result) String Uses

func (m *Result) String() string

func (*Result) XXX_DiscardUnknown Uses

func (m *Result) XXX_DiscardUnknown()

func (*Result) XXX_Marshal Uses

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

func (*Result) XXX_Merge Uses

func (dst *Result) XXX_Merge(src proto.Message)

func (*Result) XXX_Size Uses

func (m *Result) XXX_Size() int

func (*Result) XXX_Unmarshal Uses

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

Package swarmingV1 imports 11 packages (graph) and is imported by 4 packages. Updated 2018-08-20. Refresh now. Tools for package owners.