bqpb

package
v0.0.0-...-d3da680 Latest Latest
Warning

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

Go to latest
Published: Dec 4, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package bqpb contains protobuf messages describing Swarming BigQuery tables.

Many messages here are similar, but not identical, to messages used by RPC APIs, for two reasons:

  1. Historical. These protos were designed with optimistic assumptions. They include a lot of features that were never implemented. It is now very hard to simplify them without breaking existing consumers.
  2. BQ protos need to use `float64` instead of google.protobuf.Duration and `string` with JSON instead of google.protobuf.Struct.

Index

Constants

This section is empty.

Variables

View Source
var (
	MarshalKind_name = map[int32]string{
		1: "JSON",
		2: "DURATION",
	}
	MarshalKind_value = map[string]int32{
		"JSON":     1,
		"DURATION": 2,
	}
)

Enum value maps for MarshalKind.

View Source
var (
	BotEventType_name = map[int32]string{
		0:  "BOT_EVENT_TYPE_UNSPECIFIED",
		1:  "BOT_NEW_SESSION",
		2:  "BOT_INTERNAL_FAILURE",
		3:  "BOT_HOOK_ERROR",
		4:  "BOT_HOOK_LOG",
		5:  "BOT_REBOOTING_HOST",
		6:  "BOT_SHUTDOWN",
		7:  "BOT_DELETED",
		8:  "BOT_MISSING",
		10: "INSTRUCT_IDLE",
		11: "INSTRUCT_START_TASK",
		12: "INSTRUCT_RESTART_BOT",
		13: "INSTRUCT_UPDATE_BOT_CODE",
		14: "INSTRUCT_TERMINATE_BOT",
		20: "TASK_COMPLETED",
		21: "TASK_INTERNAL_FAILURE",
		22: "TASK_KILLED",
	}
	BotEventType_value = map[string]int32{
		"BOT_EVENT_TYPE_UNSPECIFIED": 0,
		"BOT_NEW_SESSION":            1,
		"BOT_INTERNAL_FAILURE":       2,
		"BOT_HOOK_ERROR":             3,
		"BOT_HOOK_LOG":               4,
		"BOT_REBOOTING_HOST":         5,
		"BOT_SHUTDOWN":               6,
		"BOT_DELETED":                7,
		"BOT_MISSING":                8,
		"INSTRUCT_IDLE":              10,
		"INSTRUCT_START_TASK":        11,
		"INSTRUCT_RESTART_BOT":       12,
		"INSTRUCT_UPDATE_BOT_CODE":   13,
		"INSTRUCT_TERMINATE_BOT":     14,
		"TASK_COMPLETED":             20,
		"TASK_INTERNAL_FAILURE":      21,
		"TASK_KILLED":                22,
	}
)

Enum value maps for BotEventType.

View Source
var (
	BotStatusType_name = map[int32]string{
		0: "BOT_STATUS_UNSPECIFIED",
		1: "MISSING",
		2: "QUARANTINED_BY_SERVER",
		3: "QUARANTINED_BY_BOT",
		4: "OVERHEAD_MAINTENANCE_EXTERNAL",
		5: "OVERHEAD_BOT_INTERNAL",
		6: "HOST_REBOOTING",
		7: "BUSY",
		8: "RESERVED",
		9: "IDLE",
	}
	BotStatusType_value = map[string]int32{
		"BOT_STATUS_UNSPECIFIED":        0,
		"MISSING":                       1,
		"QUARANTINED_BY_SERVER":         2,
		"QUARANTINED_BY_BOT":            3,
		"OVERHEAD_MAINTENANCE_EXTERNAL": 4,
		"OVERHEAD_BOT_INTERNAL":         5,
		"HOST_REBOOTING":                6,
		"BUSY":                          7,
		"RESERVED":                      8,
		"IDLE":                          9,
	}
)

Enum value maps for BotStatusType.

View Source
var (
	TaskStateCategory_name = map[int32]string{
		0:  "TASK_STATE_CATEGORY_UNSPECIFIED",
		16: "CATEGORY_PENDING",
		32: "CATEGORY_RUNNING",
		48: "CATEGORY_TRANSIENT_DONE",
		64: "CATEGORY_EXECUTION_DONE",
		80: "CATEGORY_NEVER_RAN_DONE",
	}
	TaskStateCategory_value = map[string]int32{
		"TASK_STATE_CATEGORY_UNSPECIFIED": 0,
		"CATEGORY_PENDING":                16,
		"CATEGORY_RUNNING":                32,
		"CATEGORY_TRANSIENT_DONE":         48,
		"CATEGORY_EXECUTION_DONE":         64,
		"CATEGORY_NEVER_RAN_DONE":         80,
	}
)

Enum value maps for TaskStateCategory.

View Source
var (
	TaskState_name = map[int32]string{
		0:  "TASK_STATE_INVALID",
		16: "PENDING",
		17: "PENDING_DEDUPING",
		32: "RUNNING",
		33: "RUNNING_OVERHEAD_SETUP",
		34: "RUNNING_OVERHEAD_TEARDOWN",
		35: "TERMINATING",
		47: "COMPLETING",
		48: "RAN_INTERNAL_FAILURE",
		49: "DUT_FAILURE",
		50: "BOT_DISAPPEARED",
		51: "PREEMPTED",
		64: "COMPLETED",
		65: "TIMED_OUT",
		66: "TIMED_OUT_SILENCE",
		67: "KILLED",
		68: "MISSING_INPUTS",
		80: "DEDUPED",
		81: "EXPIRED",
		82: "CANCELED",
		83: "NO_RESOURCE",
		84: "LOAD_SHED",
		85: "RESOURCE_EXHAUSTED",
		86: "SKIPPED_INTERNAL_FAILURE",
		87: "CLIENT_ERROR",
	}
	TaskState_value = map[string]int32{
		"TASK_STATE_INVALID":        0,
		"PENDING":                   16,
		"PENDING_DEDUPING":          17,
		"RUNNING":                   32,
		"RUNNING_OVERHEAD_SETUP":    33,
		"RUNNING_OVERHEAD_TEARDOWN": 34,
		"TERMINATING":               35,
		"COMPLETING":                47,
		"RAN_INTERNAL_FAILURE":      48,
		"DUT_FAILURE":               49,
		"BOT_DISAPPEARED":           50,
		"PREEMPTED":                 51,
		"COMPLETED":                 64,
		"TIMED_OUT":                 65,
		"TIMED_OUT_SILENCE":         66,
		"KILLED":                    67,
		"MISSING_INPUTS":            68,
		"DEDUPED":                   80,
		"EXPIRED":                   81,
		"CANCELED":                  82,
		"NO_RESOURCE":               83,
		"LOAD_SHED":                 84,
		"RESOURCE_EXHAUSTED":        85,
		"SKIPPED_INTERNAL_FAILURE":  86,
		"CLIENT_ERROR":              87,
	}
)

Enum value maps for TaskState.

View Source
var (
	User_name = map[int32]string{
		0: "USER_UNSPECIFIED",
		1: "USER_SWARMING",
		2: "USER_TEMPORARY",
	}
	User_value = map[string]int32{
		"USER_UNSPECIFIED": 0,
		"USER_SWARMING":    1,
		"USER_TEMPORARY":   2,
	}
)

Enum value maps for User.

View Source
var (
	// If set, overrides how a field is marshalled to JSON.
	//
	// optional swarming.bq.MarshalKind marshal_to_json_as = 76700;
	E_MarshalToJsonAs = &file_go_chromium_org_luci_swarming_proto_bq_options_proto_extTypes[0]
)

Extension fields to descriptorpb.FieldOptions.

View Source
var File_go_chromium_org_luci_swarming_proto_bq_options_proto protoreflect.FileDescriptor
View Source
var File_go_chromium_org_luci_swarming_proto_bq_swarming_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Bot

type Bot struct {

	// Bot ID.
	//
	// It is unique across the Swarming fleet. It is generally based on the
	// hostname where the bot runs, but that's not a requirement
	//
	// This value is also included in dimensions for the key 'id'.
	BotId string `protobuf:"bytes,1,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	// The bot session name as reported by the bot when it was connecting.
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Pools that this bot belongs to.
	//
	// Normally a bot belongs to a single pool, but it can be in multiple pools
	// simultaneously. This is helpful when moving bots between pools.
	//
	// This value is also included in dimensions for the key 'pool'.
	Pools []string `protobuf:"bytes,3,rep,name=pools,proto3" json:"pools,omitempty"`
	// Current bot status. A bot status is a state in which the bot is for a
	// certain amount of time.
	Status BotStatusType `protobuf:"varint,4,opt,name=status,proto3,enum=swarming.bq.BotStatusType" json:"status,omitempty"`
	// Supplemental information to describe the bot status. Human readable.
	//
	// See BotStatusType for the meaning of this string for each status.
	StatusMsg string `protobuf:"bytes,5,opt,name=status_msg,json=statusMsg,proto3" json:"status_msg,omitempty"`
	// Current task being handled by the bot, if there is one.
	//
	// This is an ID of a concrete run attempt. Such IDs end with 1.
	CurrentTaskId string `protobuf:"bytes,6,opt,name=current_task_id,json=currentTaskId,proto3" json:"current_task_id,omitempty"`
	// Dimensions reported by the bot.
	//
	// Sorted.
	Dimensions []*StringListPair `protobuf:"bytes,7,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Extra information describing the bot or its host.
	//
	// This is NOT used for task selection.
	Info *BotInfo `protobuf:"bytes,8,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

Bot is a snapshot of the state of a Swarming bot.

func (*Bot) Descriptor deprecated

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

Deprecated: Use Bot.ProtoReflect.Descriptor instead.

func (*Bot) GetBotId

func (x *Bot) GetBotId() string

func (*Bot) GetCurrentTaskId

func (x *Bot) GetCurrentTaskId() string

func (*Bot) GetDimensions

func (x *Bot) GetDimensions() []*StringListPair

func (*Bot) GetInfo

func (x *Bot) GetInfo() *BotInfo

func (*Bot) GetPools

func (x *Bot) GetPools() []string

func (*Bot) GetSessionId

func (x *Bot) GetSessionId() string

func (*Bot) GetStatus

func (x *Bot) GetStatus() BotStatusType

func (*Bot) GetStatusMsg

func (x *Bot) GetStatusMsg() string

func (*Bot) ProtoMessage

func (*Bot) ProtoMessage()

func (*Bot) ProtoReflect

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

func (*Bot) Reset

func (x *Bot) Reset()

func (*Bot) String

func (x *Bot) String() string

type BotEvent

type BotEvent struct {

	// When this event happened.
	EventTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// Snapshot of the Bot at the moment the event happened.
	Bot *Bot `protobuf:"bytes,2,opt,name=bot,proto3" json:"bot,omitempty"`
	// What has happened to the bot.
	Event BotEventType `protobuf:"varint,3,opt,name=event,proto3,enum=swarming.bq.BotEventType" json:"event,omitempty"`
	// Human readable event message.
	//
	// See BotEventType for the meaning of this string for each status.
	EventMsg string `protobuf:"bytes,4,opt,name=event_msg,json=eventMsg,proto3" json:"event_msg,omitempty"`
	// contains filtered or unexported fields
}

BotEvent represents an event on a bot.

func (*BotEvent) Descriptor deprecated

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

Deprecated: Use BotEvent.ProtoReflect.Descriptor instead.

func (*BotEvent) GetBot

func (x *BotEvent) GetBot() *Bot

func (*BotEvent) GetEvent

func (x *BotEvent) GetEvent() BotEventType

func (*BotEvent) GetEventMsg

func (x *BotEvent) GetEventMsg() string

func (*BotEvent) GetEventTime

func (x *BotEvent) GetEventTime() *timestamppb.Timestamp

func (*BotEvent) ProtoMessage

func (*BotEvent) ProtoMessage()

func (*BotEvent) ProtoReflect

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

func (*BotEvent) Reset

func (x *BotEvent) Reset()

func (*BotEvent) String

func (x *BotEvent) String() string

type BotEventType

type BotEventType int32

BotEventType defines the reason why BotEvent was created.

const (
	// Invalid bot event type, do not use.
	BotEventType_BOT_EVENT_TYPE_UNSPECIFIED BotEventType = 0
	// Bot connected and started a new session.
	//
	// BotEvent.event_msg shall not be set.
	BotEventType_BOT_NEW_SESSION BotEventType = 1
	// Unused.
	BotEventType_BOT_INTERNAL_FAILURE BotEventType = 2
	// Bot had an hook error to report to the server. This shall send a report to
	// the administrator of the instance.
	//
	// BotEvent.event_msg shall contain the error message.
	BotEventType_BOT_HOOK_ERROR BotEventType = 3
	// Bot hook logged information. The bot hooks can log locally to the local log
	// file, which itself can be streamed out of band. For special notifications
	// that are worth notifying the administrator, this event can be used to raise
	// these. Due to the cost of doing an RPC just for this, this should be used
	// sparingly; vs local logging.
	//
	// BotEvent.event_msg shall contain the log entry.
	BotEventType_BOT_HOOK_LOG BotEventType = 4
	// Bot initiated a host reboot. An example is a bot hook requesting to reboot
	// the host after a task failure.
	//
	// BotEvent.event_msg shall contain the reason for rebooting the host, if any.
	BotEventType_BOT_REBOOTING_HOST BotEventType = 5
	// Bot is shutting down. It may be restarting for an update.
	//
	// BotEvent.event_msg shall contain the reason.
	BotEventType_BOT_SHUTDOWN BotEventType = 6
	// Unused.
	BotEventType_BOT_DELETED BotEventType = 7
	// Bot is missing. There have been no communication from the bot for longer
	// than deadline configured on server side.
	BotEventType_BOT_MISSING BotEventType = 8
	// The server instructs the bot to stay idle. This is when there is no task
	// pending for this bot. Will only be stored when there are other state
	// changes.
	//
	// BotEvent.event_msg shall not be set.
	BotEventType_INSTRUCT_IDLE BotEventType = 10
	// The server instructs the bot to start a task.
	//
	// BotEvent.event_msg shall not be set. BotEvent.bot.current_task_id shall
	// contain the task ID.
	BotEventType_INSTRUCT_START_TASK BotEventType = 11
	// The server instructs the bot to restart without self-updating. This is to
	// initiate a new bot session, with potentially new bot hooks.
	//
	// BotEvent.event_msg can be set to the rationale, if any.
	BotEventType_INSTRUCT_RESTART_BOT BotEventType = 12
	// The server instructs the bot to self-update.
	//
	// BotEvent.event_msg shall be set to the version to update to.
	// BotEvent.bot.info.version contains the bot's previous version.
	BotEventType_INSTRUCT_UPDATE_BOT_CODE BotEventType = 13
	// The server instructs the bot to stop its process.
	//
	// BotEvent.event_msg shall not be set. BotEvent.bot.current_task_id shall
	// contain the task ID.
	BotEventType_INSTRUCT_TERMINATE_BOT BotEventType = 14
	// Bot completed a task.
	//
	// BotEvent.event_msg shall not be set. BotEvent.bot.current_task_id shall
	// contain the task ID.
	BotEventType_TASK_COMPLETED BotEventType = 20
	// Bot had an internal failure (RAN_INTERNAL_FAILURE) to report to the server
	// while processing a task. This shall send a report to the administrator of
	// the instance and service author.
	//
	// This event shall not be filed in case of a MISSING_INPUTS.
	//
	// BotEvent.event_msg shall contain the error message.
	// BotEvent.bot.current_task_id shall contain the task ID.
	BotEventType_TASK_INTERNAL_FAILURE BotEventType = 21
	// Bot is forcibly killing the task.
	//
	// This can be induced by a server side request (KILLED, PREEMPTED) or by a
	// bot side decision (TIMED_OUT, TIMED_OUT_SILENCE).
	//
	// BotEvent.event_msg shall not be set. BotEvent.bot.current_task_id shall
	// contain the task ID.
	BotEventType_TASK_KILLED BotEventType = 22
)

func (BotEventType) Descriptor

func (BotEventType) Enum

func (x BotEventType) Enum() *BotEventType

func (BotEventType) EnumDescriptor deprecated

func (BotEventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use BotEventType.Descriptor instead.

func (BotEventType) Number

func (BotEventType) String

func (x BotEventType) String() string

func (BotEventType) Type

type BotInfo

type BotInfo struct {

	// Free form JSON data that includes interesting information about the bot
	// that doesn't fit in any of the fields below.
	//
	// Anything that is usable by multiple customers should eventually be moved to
	// a new field below.
	Supplemental string `protobuf:"bytes,1,opt,name=supplemental,proto3" json:"supplemental,omitempty"`
	// Bot's version. An opaque value.
	//
	// This value is Swarming instance and configuration dependent.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// External IP address as visible by the server.
	//
	// This could be a NAT'ing router external IP.
	//
	// Can be either IPv4 or IPv6.
	ExternalIp string `protobuf:"bytes,3,opt,name=external_ip,json=externalIp,proto3" json:"external_ip,omitempty"`
	// Authentication identity that the bot identified as. An opaque value.
	AuthenticatedAs string `protobuf:"bytes,4,opt,name=authenticated_as,json=authenticatedAs,proto3" json:"authenticated_as,omitempty"`
	// State of the content addressed cache on the bot.
	//
	// This is used for input files.
	CasStats *CASStats `protobuf:"bytes,5,opt,name=cas_stats,json=casStats,proto3" json:"cas_stats,omitempty"`
	// State of the named caches on the bot.
	//
	// Sorted.
	NamedCachesStats []*NamedCacheStats `protobuf:"bytes,6,rep,name=named_caches_stats,json=namedCachesStats,proto3" json:"named_caches_stats,omitempty"`
	// State of the CIPD packages cache on the bot.
	//
	// Sorted.
	CipdPackagesCacheStats []*CIPDPackageCacheStats `` /* 131-byte string literal not displayed */
	// Unused.
	Host *PhysicalEntity `protobuf:"bytes,8,opt,name=host,proto3" json:"host,omitempty"`
	// Unused.
	Devices []*PhysicalEntity `protobuf:"bytes,9,rep,name=devices,proto3" json:"devices,omitempty"`
	// This field is used in BOT_MISSING event to know the timestamp of the last
	// activity.
	LastSeenTs *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=last_seen_ts,json=lastSeenTs,proto3" json:"last_seen_ts,omitempty"`
	// The time when the bot became idle.
	IdleSinceTs *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=idle_since_ts,json=idleSinceTs,proto3" json:"idle_since_ts,omitempty"`
	// contains filtered or unexported fields
}

Extra information describing the bot or its host

This is NOT used for task selection.

func (*BotInfo) Descriptor deprecated

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

Deprecated: Use BotInfo.ProtoReflect.Descriptor instead.

func (*BotInfo) GetAuthenticatedAs

func (x *BotInfo) GetAuthenticatedAs() string

func (*BotInfo) GetCasStats

func (x *BotInfo) GetCasStats() *CASStats

func (*BotInfo) GetCipdPackagesCacheStats

func (x *BotInfo) GetCipdPackagesCacheStats() []*CIPDPackageCacheStats

func (*BotInfo) GetDevices

func (x *BotInfo) GetDevices() []*PhysicalEntity

func (*BotInfo) GetExternalIp

func (x *BotInfo) GetExternalIp() string

func (*BotInfo) GetHost

func (x *BotInfo) GetHost() *PhysicalEntity

func (*BotInfo) GetIdleSinceTs

func (x *BotInfo) GetIdleSinceTs() *timestamppb.Timestamp

func (*BotInfo) GetLastSeenTs

func (x *BotInfo) GetLastSeenTs() *timestamppb.Timestamp

func (*BotInfo) GetNamedCachesStats

func (x *BotInfo) GetNamedCachesStats() []*NamedCacheStats

func (*BotInfo) GetSupplemental

func (x *BotInfo) GetSupplemental() string

func (*BotInfo) GetVersion

func (x *BotInfo) GetVersion() string

func (*BotInfo) ProtoMessage

func (*BotInfo) ProtoMessage()

func (*BotInfo) ProtoReflect

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

func (*BotInfo) Reset

func (x *BotInfo) Reset()

func (*BotInfo) String

func (x *BotInfo) String() string

type BotStatusType

type BotStatusType int32

BotStatusType is one of the states the bot can be in.

A bot status implies being in this status for a certain amount of time, for example a hook running for N seconds, contrary to BotEventType which is about an event that doesn't have an inherent duration.

Some values are more important than others. For example if a bot is now MISSING but used to be QUARANTINED, the value is still MISSING.

const (
	// Invalid bot status, do not use.
	BotStatusType_BOT_STATUS_UNSPECIFIED BotStatusType = 0
	// The server detected that the bot is not pinging the server anymore. Unlike
	// other statuses, this value is set after a timeout.
	//
	// Bot.status_msg shall not be set.
	BotStatusType_MISSING BotStatusType = 1
	// Unused.
	BotStatusType_QUARANTINED_BY_SERVER BotStatusType = 2
	// Bot self-reported as unhealthy.
	//
	// What is currently called as 'quarantined' in the old API.
	//
	// Bot.status_msg shall include the bot provided rationale.
	BotStatusType_QUARANTINED_BY_BOT BotStatusType = 3
	// Bot self-reported as unable to run tasks due to externally induced
	// overhead.
	//
	// Examples include:
	//   - The temperature of the DUT (Device Under Test) is too high, and the bot
	//     is waiting for cool down
	//   - host is doing self-cleaning work out of the bot's control (puppet is
	//     running), etc.
	//
	// Bot.status_msg shall include the bot provided rationale.
	BotStatusType_OVERHEAD_MAINTENANCE_EXTERNAL BotStatusType = 4
	// Unused.
	BotStatusType_OVERHEAD_BOT_INTERNAL BotStatusType = 5
	// Unused.
	BotStatusType_HOST_REBOOTING BotStatusType = 6
	// Running a task.
	//
	// Bot.status_msg shall not be set.
	BotStatusType_BUSY BotStatusType = 7
	// Unused.
	BotStatusType_RESERVED BotStatusType = 8
	// Bot is healthy and waiting for tasks.
	//
	// Bot.status_msg shall not be set.
	BotStatusType_IDLE BotStatusType = 9
)

func (BotStatusType) Descriptor

func (BotStatusType) Enum

func (x BotStatusType) Enum() *BotStatusType

func (BotStatusType) EnumDescriptor deprecated

func (BotStatusType) EnumDescriptor() ([]byte, []int)

Deprecated: Use BotStatusType.Descriptor instead.

func (BotStatusType) Number

func (BotStatusType) String

func (x BotStatusType) String() string

func (BotStatusType) Type

type CASEntriesStats

type CASEntriesStats struct {

	// Number of entries in the cache.
	NumItems int64 `protobuf:"varint,1,opt,name=num_items,json=numItems,proto3" json:"num_items,omitempty"`
	// Total size of the cached items.
	TotalBytesItems int64 `protobuf:"varint,2,opt,name=total_bytes_items,json=totalBytesItems,proto3" json:"total_bytes_items,omitempty"`
	// Unused.
	Items []byte `protobuf:"bytes,6,opt,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

Statistics for differential CAS entries in the context of I/O for a task.

func (*CASEntriesStats) Descriptor deprecated

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

Deprecated: Use CASEntriesStats.ProtoReflect.Descriptor instead.

func (*CASEntriesStats) GetItems

func (x *CASEntriesStats) GetItems() []byte

func (*CASEntriesStats) GetNumItems

func (x *CASEntriesStats) GetNumItems() int64

func (*CASEntriesStats) GetTotalBytesItems

func (x *CASEntriesStats) GetTotalBytesItems() int64

func (*CASEntriesStats) ProtoMessage

func (*CASEntriesStats) ProtoMessage()

func (*CASEntriesStats) ProtoReflect

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

func (*CASEntriesStats) Reset

func (x *CASEntriesStats) Reset()

func (*CASEntriesStats) String

func (x *CASEntriesStats) String() string

type CASOverhead

type CASOverhead struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// CAS entries that were not present in the local or remote cache and had to
	// be sent across the network.
	Cold *CASEntriesStats `protobuf:"bytes,2,opt,name=cold,proto3" json:"cold,omitempty"`
	// CAS entries that were in the cache and thus didn't have to be transferred.
	Hot *CASEntriesStats `protobuf:"bytes,3,opt,name=hot,proto3" json:"hot,omitempty"`
	// contains filtered or unexported fields
}

Overhead information about CAS download or upload.

func (*CASOverhead) Descriptor deprecated

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

Deprecated: Use CASOverhead.ProtoReflect.Descriptor instead.

func (*CASOverhead) GetCold

func (x *CASOverhead) GetCold() *CASEntriesStats

func (*CASOverhead) GetDuration

func (x *CASOverhead) GetDuration() float64

func (*CASOverhead) GetHot

func (x *CASOverhead) GetHot() *CASEntriesStats

func (*CASOverhead) ProtoMessage

func (*CASOverhead) ProtoMessage()

func (*CASOverhead) ProtoReflect

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

func (*CASOverhead) Reset

func (x *CASOverhead) Reset()

func (*CASOverhead) String

func (x *CASOverhead) String() string

type CASStats

type CASStats struct {
	NumberItems int64                  `protobuf:"varint,1,opt,name=number_items,json=numberItems,proto3" json:"number_items,omitempty"`
	Size        int64                  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	OldestTime  *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=oldest_time,json=oldestTime,proto3" json:"oldest_time,omitempty"`
	// contains filtered or unexported fields
}

Bot local content addressed cache information.

func (*CASStats) Descriptor deprecated

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

Deprecated: Use CASStats.ProtoReflect.Descriptor instead.

func (*CASStats) GetNumberItems

func (x *CASStats) GetNumberItems() int64

func (*CASStats) GetOldestTime

func (x *CASStats) GetOldestTime() *timestamppb.Timestamp

func (*CASStats) GetSize

func (x *CASStats) GetSize() int64

func (*CASStats) ProtoMessage

func (*CASStats) ProtoMessage()

func (*CASStats) ProtoReflect

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

func (*CASStats) Reset

func (x *CASStats) Reset()

func (*CASStats) String

func (x *CASStats) String() string

type CASTree

type CASTree struct {
	Server    string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	Digest    string `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

Deprecated and unused.

func (*CASTree) Descriptor deprecated

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

Deprecated: Use CASTree.ProtoReflect.Descriptor instead.

func (*CASTree) GetDigest

func (x *CASTree) GetDigest() string

func (*CASTree) GetNamespace

func (x *CASTree) GetNamespace() string

func (*CASTree) GetServer

func (x *CASTree) GetServer() string

func (*CASTree) ProtoMessage

func (*CASTree) ProtoMessage()

func (*CASTree) ProtoReflect

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

func (*CASTree) Reset

func (x *CASTree) Reset()

func (*CASTree) String

func (x *CASTree) String() string

type CIPDOverhead

type CIPDOverhead struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

Overhead information about CIPD package installation.

func (*CIPDOverhead) Descriptor deprecated

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

Deprecated: Use CIPDOverhead.ProtoReflect.Descriptor instead.

func (*CIPDOverhead) GetDuration

func (x *CIPDOverhead) GetDuration() float64

func (*CIPDOverhead) ProtoMessage

func (*CIPDOverhead) ProtoMessage()

func (*CIPDOverhead) ProtoReflect

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

func (*CIPDOverhead) Reset

func (x *CIPDOverhead) Reset()

func (*CIPDOverhead) String

func (x *CIPDOverhead) String() string

type CIPDPackage

type CIPDPackage struct {

	// The template for the CIPD package name that will have its variables
	// evaluated, e.g. "infra/tools/authutil/${platform}".
	PackageName string `protobuf:"bytes,1,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
	// Package version for the requested package.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Path to directory relative to the task's root dir, where the package is to
	// be installed.
	//
	// If empty, the package will be installed at the root of the mapped
	// directory.
	DestPath string `protobuf:"bytes,3,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"`
	// contains filtered or unexported fields
}

Defines one CIPD package to install prior to running the task.

CIPD packages are versioned and ACL'ed packages that are meant for tools that are kept for a long time.

func (*CIPDPackage) Descriptor deprecated

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

Deprecated: Use CIPDPackage.ProtoReflect.Descriptor instead.

func (*CIPDPackage) GetDestPath

func (x *CIPDPackage) GetDestPath() string

func (*CIPDPackage) GetPackageName

func (x *CIPDPackage) GetPackageName() string

func (*CIPDPackage) GetVersion

func (x *CIPDPackage) GetVersion() string

func (*CIPDPackage) ProtoMessage

func (*CIPDPackage) ProtoMessage()

func (*CIPDPackage) ProtoReflect

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

func (*CIPDPackage) Reset

func (x *CIPDPackage) Reset()

func (*CIPDPackage) String

func (x *CIPDPackage) String() string

type CIPDPackageCacheStats

type CIPDPackageCacheStats struct {
	Name        string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version     string                 `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Size        int64                  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	LastUseTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_use_time,json=lastUseTime,proto3" json:"last_use_time,omitempty"`
	// contains filtered or unexported fields
}

Bot local CIPD package cache information.

func (*CIPDPackageCacheStats) Descriptor deprecated

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

Deprecated: Use CIPDPackageCacheStats.ProtoReflect.Descriptor instead.

func (*CIPDPackageCacheStats) GetLastUseTime

func (x *CIPDPackageCacheStats) GetLastUseTime() *timestamppb.Timestamp

func (*CIPDPackageCacheStats) GetName

func (x *CIPDPackageCacheStats) GetName() string

func (*CIPDPackageCacheStats) GetSize

func (x *CIPDPackageCacheStats) GetSize() int64

func (*CIPDPackageCacheStats) GetVersion

func (x *CIPDPackageCacheStats) GetVersion() string

func (*CIPDPackageCacheStats) ProtoMessage

func (*CIPDPackageCacheStats) ProtoMessage()

func (*CIPDPackageCacheStats) ProtoReflect

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

func (*CIPDPackageCacheStats) Reset

func (x *CIPDPackageCacheStats) Reset()

func (*CIPDPackageCacheStats) String

func (x *CIPDPackageCacheStats) String() string

type CIPDPins

type CIPDPins struct {

	// The CIPD server where the CIPD packages were fetched from. Must contain
	// "https://" or "http://" prefix.
	Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// The pinned package + version of the CIPD client that was actually used.
	ClientPackage *CIPDPackage `protobuf:"bytes,2,opt,name=client_package,json=clientPackage,proto3" json:"client_package,omitempty"`
	// List of CIPD packages that were installed in the task with fully resolved
	// package names and versions.
	Packages []*CIPDPackage `protobuf:"bytes,3,rep,name=packages,proto3" json:"packages,omitempty"`
	// contains filtered or unexported fields
}

Defines pinned CIPD packages that were installed during the task.

func (*CIPDPins) Descriptor deprecated

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

Deprecated: Use CIPDPins.ProtoReflect.Descriptor instead.

func (*CIPDPins) GetClientPackage

func (x *CIPDPins) GetClientPackage() *CIPDPackage

func (*CIPDPins) GetPackages

func (x *CIPDPins) GetPackages() []*CIPDPackage

func (*CIPDPins) GetServer

func (x *CIPDPins) GetServer() string

func (*CIPDPins) ProtoMessage

func (*CIPDPins) ProtoMessage()

func (*CIPDPins) ProtoReflect

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

func (*CIPDPins) Reset

func (x *CIPDPins) Reset()

func (*CIPDPins) String

func (x *CIPDPins) String() string

type CacheTrimOverhead

type CacheTrimOverhead struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

Overhead information about cache trimming.

func (*CacheTrimOverhead) Descriptor deprecated

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

Deprecated: Use CacheTrimOverhead.ProtoReflect.Descriptor instead.

func (*CacheTrimOverhead) GetDuration

func (x *CacheTrimOverhead) GetDuration() float64

func (*CacheTrimOverhead) ProtoMessage

func (*CacheTrimOverhead) ProtoMessage()

func (*CacheTrimOverhead) ProtoReflect

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

func (*CacheTrimOverhead) Reset

func (x *CacheTrimOverhead) Reset()

func (*CacheTrimOverhead) String

func (x *CacheTrimOverhead) String() string

type CleanupOverhead

type CleanupOverhead struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

Overhead information about cleanup step.

func (*CleanupOverhead) Descriptor deprecated

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

Deprecated: Use CleanupOverhead.ProtoReflect.Descriptor instead.

func (*CleanupOverhead) GetDuration

func (x *CleanupOverhead) GetDuration() float64

func (*CleanupOverhead) ProtoMessage

func (*CleanupOverhead) ProtoMessage()

func (*CleanupOverhead) ProtoReflect

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

func (*CleanupOverhead) Reset

func (x *CleanupOverhead) Reset()

func (*CleanupOverhead) String

func (x *CleanupOverhead) String() string

type MarshalKind

type MarshalKind int32

Possible kinds of "overrides" of default JSON marshalling.

const (
	// Interpret a string field as a JSON document and inline it.
	MarshalKind_JSON MarshalKind = 1
	// Interpret a double field as a duration and marshal it as "XXXs" string.
	MarshalKind_DURATION MarshalKind = 2
)

func (MarshalKind) Descriptor

func (MarshalKind) Enum

func (x MarshalKind) Enum() *MarshalKind

func (MarshalKind) EnumDescriptor deprecated

func (MarshalKind) EnumDescriptor() ([]byte, []int)

Deprecated: Use MarshalKind.Descriptor instead.

func (MarshalKind) Number

func (x MarshalKind) Number() protoreflect.EnumNumber

func (MarshalKind) String

func (x MarshalKind) String() string

func (MarshalKind) Type

func (*MarshalKind) UnmarshalJSON deprecated

func (x *MarshalKind) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type NamedCacheEntry

type NamedCacheEntry struct {

	// Unique name of the cache. Length is limited to 4096.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Path to directory relative to the task's root dir, where the named cache is
	// to be installed.
	//
	// A path cannot be shared among multiple caches or CIPD installations.
	// A task will fail if a file/dir with the same name already exists.
	DestPath string `protobuf:"bytes,2,opt,name=dest_path,json=destPath,proto3" json:"dest_path,omitempty"`
	// contains filtered or unexported fields
}

Describes a named cache that should be reused on the bot.

A NamedCacheEntry in a task specifies that the task wants a directory to be persisted on the bot across tasks.

If the cache was not present on the bot prior the task's execution, the directory is empty when the task starts. Any change done in the directory by the task is persisted on the bot after the task completes.

If another task runs on the same bot and requests the same named cache, even if mapped to a different path, it will get the updated content.

func (*NamedCacheEntry) Descriptor deprecated

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

Deprecated: Use NamedCacheEntry.ProtoReflect.Descriptor instead.

func (*NamedCacheEntry) GetDestPath

func (x *NamedCacheEntry) GetDestPath() string

func (*NamedCacheEntry) GetName

func (x *NamedCacheEntry) GetName() string

func (*NamedCacheEntry) ProtoMessage

func (*NamedCacheEntry) ProtoMessage()

func (*NamedCacheEntry) ProtoReflect

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

func (*NamedCacheEntry) Reset

func (x *NamedCacheEntry) Reset()

func (*NamedCacheEntry) String

func (x *NamedCacheEntry) String() string

type NamedCacheOverhead

type NamedCacheOverhead struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

Overhead information about Named Caches install or uninstall.

func (*NamedCacheOverhead) Descriptor deprecated

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

Deprecated: Use NamedCacheOverhead.ProtoReflect.Descriptor instead.

func (*NamedCacheOverhead) GetDuration

func (x *NamedCacheOverhead) GetDuration() float64

func (*NamedCacheOverhead) ProtoMessage

func (*NamedCacheOverhead) ProtoMessage()

func (*NamedCacheOverhead) ProtoReflect

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

func (*NamedCacheOverhead) Reset

func (x *NamedCacheOverhead) Reset()

func (*NamedCacheOverhead) String

func (x *NamedCacheOverhead) String() string

type NamedCacheStats

type NamedCacheStats struct {
	Name        string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Size        int64                  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	LastUseTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_use_time,json=lastUseTime,proto3" json:"last_use_time,omitempty"`
	// contains filtered or unexported fields
}

Bot local named cache information.

func (*NamedCacheStats) Descriptor deprecated

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

Deprecated: Use NamedCacheStats.ProtoReflect.Descriptor instead.

func (*NamedCacheStats) GetLastUseTime

func (x *NamedCacheStats) GetLastUseTime() *timestamppb.Timestamp

func (*NamedCacheStats) GetName

func (x *NamedCacheStats) GetName() string

func (*NamedCacheStats) GetSize

func (x *NamedCacheStats) GetSize() int64

func (*NamedCacheStats) ProtoMessage

func (*NamedCacheStats) ProtoMessage()

func (*NamedCacheStats) ProtoReflect

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

func (*NamedCacheStats) Reset

func (x *NamedCacheStats) Reset()

func (*NamedCacheStats) String

func (x *NamedCacheStats) String() string

type PhysicalEntity

type PhysicalEntity struct {

	// Name that represents this physical entity.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Free form JSON data that includes interesting information about the device
	// that doesn't fit in any of the fields below.
	//
	// Anything that is usable by multiple customers should eventually be moved to
	// a new field below.
	Supplemental string `protobuf:"bytes,2,opt,name=supplemental,proto3" json:"supplemental,omitempty"`
	// IP address as visible by the bot process (bot_main) itself.
	//
	// In the case of the host, it will be one of the IP addresses assigned to it.
	// In the case of the host where the bot is running inside docker, it will be
	// the IP address assigned to the docker container.
	// In the case of a device, it is the IP address of the device, if any.
	//
	// Can be either IPv4 or IPv6.
	Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

PhysicalEntity includes information about an host or device.

Unused.

func (*PhysicalEntity) Descriptor deprecated

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

Deprecated: Use PhysicalEntity.ProtoReflect.Descriptor instead.

func (*PhysicalEntity) GetIp

func (x *PhysicalEntity) GetIp() string

func (*PhysicalEntity) GetName

func (x *PhysicalEntity) GetName() string

func (*PhysicalEntity) GetSupplemental

func (x *PhysicalEntity) GetSupplemental() string

func (*PhysicalEntity) ProtoMessage

func (*PhysicalEntity) ProtoMessage()

func (*PhysicalEntity) ProtoReflect

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

func (*PhysicalEntity) Reset

func (x *PhysicalEntity) Reset()

func (*PhysicalEntity) String

func (x *PhysicalEntity) String() string

type PubSub

type PubSub struct {

	// Full topic name to post updates to, e.g. "projects/<id>/topics/<id>".
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Secret string to put into "auth_token" attribute of PubSub messages.
	//
	// Always empty in BQ exports.
	AuthToken string `protobuf:"bytes,2,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	// String to put into "userdata" attribute of PubSub messages.
	Userdata string `protobuf:"bytes,3,opt,name=userdata,proto3" json:"userdata,omitempty"`
	// contains filtered or unexported fields
}

PubSub is a Cloud Pub/Sub topic to send task updates to.

func (*PubSub) Descriptor deprecated

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

Deprecated: Use PubSub.ProtoReflect.Descriptor instead.

func (*PubSub) GetAuthToken

func (x *PubSub) GetAuthToken() string

func (*PubSub) GetTopic

func (x *PubSub) GetTopic() string

func (*PubSub) GetUserdata

func (x *PubSub) GetUserdata() string

func (*PubSub) ProtoMessage

func (*PubSub) ProtoMessage()

func (*PubSub) ProtoReflect

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

func (*PubSub) Reset

func (x *PubSub) Reset()

func (*PubSub) String

func (x *PubSub) String() string

type StringListPair

type StringListPair struct {
	Key    string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Represents a mapping of a string to a list of strings.

func (*StringListPair) Descriptor deprecated

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

Deprecated: Use StringListPair.ProtoReflect.Descriptor instead.

func (*StringListPair) GetKey

func (x *StringListPair) GetKey() string

func (*StringListPair) GetValues

func (x *StringListPair) GetValues() []string

func (*StringListPair) ProtoMessage

func (*StringListPair) ProtoMessage()

func (*StringListPair) ProtoReflect

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

func (*StringListPair) Reset

func (x *StringListPair) Reset()

func (*StringListPair) String

func (x *StringListPair) String() string

type StringPair

type StringPair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Represents a mapping of a string to a string.

func (*StringPair) Descriptor deprecated

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

Deprecated: Use StringPair.ProtoReflect.Descriptor instead.

func (*StringPair) GetKey

func (x *StringPair) GetKey() string

func (*StringPair) GetValue

func (x *StringPair) GetValue() string

func (*StringPair) ProtoMessage

func (*StringPair) ProtoMessage()

func (*StringPair) ProtoReflect

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

func (*StringPair) Reset

func (x *StringPair) Reset()

func (*StringPair) String

func (x *StringPair) String() string

type TaskOverheadStats deprecated

type TaskOverheadStats struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// CAS entries that were not present in the local or remote cache and had to
	// be sent across the network.
	Cold *CASEntriesStats `protobuf:"bytes,2,opt,name=cold,proto3" json:"cold,omitempty"`
	// CAS entries that were in the cache and thus didn't have to be transferred.
	Hot *CASEntriesStats `protobuf:"bytes,3,opt,name=hot,proto3" json:"hot,omitempty"`
	// contains filtered or unexported fields
}

Deprecated: Use TaskSetupOverhead or TaskTeardownOverhead instead.

func (*TaskOverheadStats) Descriptor deprecated

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

Deprecated: Use TaskOverheadStats.ProtoReflect.Descriptor instead.

func (*TaskOverheadStats) GetCold

func (x *TaskOverheadStats) GetCold() *CASEntriesStats

func (*TaskOverheadStats) GetDuration

func (x *TaskOverheadStats) GetDuration() float64

func (*TaskOverheadStats) GetHot

func (x *TaskOverheadStats) GetHot() *CASEntriesStats

func (*TaskOverheadStats) ProtoMessage

func (*TaskOverheadStats) ProtoMessage()

func (*TaskOverheadStats) ProtoReflect

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

func (*TaskOverheadStats) Reset

func (x *TaskOverheadStats) Reset()

func (*TaskOverheadStats) String

func (x *TaskOverheadStats) String() string

type TaskPerformance

type TaskPerformance struct {

	// Total cost of running this task in $USD. In the case of DEDUPED task, this
	// represents the amount saved.
	CostUsd float32 `protobuf:"fixed32,1,opt,name=cost_usd,json=costUsd,proto3" json:"cost_usd,omitempty"`
	// Total overhead caused by the bot in seconds.
	//
	// This is calculated by subtracting the duration of the actual task command
	// from the overall duration of the task (that includes fetching of inputs
	// reporting of results).
	TotalOverhead float64 `protobuf:"fixed64,5,opt,name=total_overhead,json=totalOverhead,proto3" json:"total_overhead,omitempty"`
	// Overhead in seconds that is not accounted for by the other overheads.
	OtherOverhead float64 `protobuf:"fixed64,2,opt,name=other_overhead,json=otherOverhead,proto3" json:"other_overhead,omitempty"`
	// Deprecated: use setup_overhead instead.
	// Task environment setup overhead. This is the task state
	// RUNNING_OVERHEAD_SETUP.
	Setup *TaskOverheadStats `protobuf:"bytes,3,opt,name=setup,proto3" json:"setup,omitempty"`
	// Deprecated: use teardown_overhead instead.
	// Task environment teardown overhead. This is the task state
	// RUNNING_OVERHEAD_TEARDOWN.
	Teardown *TaskOverheadStats `protobuf:"bytes,4,opt,name=teardown,proto3" json:"teardown,omitempty"`
	// Task environment setup overhead. This is the task state
	// RUNNING_OVERHEAD_SETUP.
	SetupOverhead *TaskSetupOverhead `protobuf:"bytes,6,opt,name=setup_overhead,json=setupOverhead,proto3" json:"setup_overhead,omitempty"`
	// Task environment teardown overhead. This is the task state
	// RUNNING_OVERHEAD_TEARDOWN.
	TeardownOverhead *TaskTeardownOverhead `protobuf:"bytes,7,opt,name=teardown_overhead,json=teardownOverhead,proto3" json:"teardown_overhead,omitempty"`
	// contains filtered or unexported fields
}

Information about the task's performance.

func (*TaskPerformance) Descriptor deprecated

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

Deprecated: Use TaskPerformance.ProtoReflect.Descriptor instead.

func (*TaskPerformance) GetCostUsd

func (x *TaskPerformance) GetCostUsd() float32

func (*TaskPerformance) GetOtherOverhead

func (x *TaskPerformance) GetOtherOverhead() float64

func (*TaskPerformance) GetSetup

func (x *TaskPerformance) GetSetup() *TaskOverheadStats

func (*TaskPerformance) GetSetupOverhead

func (x *TaskPerformance) GetSetupOverhead() *TaskSetupOverhead

func (*TaskPerformance) GetTeardown

func (x *TaskPerformance) GetTeardown() *TaskOverheadStats

func (*TaskPerformance) GetTeardownOverhead

func (x *TaskPerformance) GetTeardownOverhead() *TaskTeardownOverhead

func (*TaskPerformance) GetTotalOverhead

func (x *TaskPerformance) GetTotalOverhead() float64

func (*TaskPerformance) ProtoMessage

func (*TaskPerformance) ProtoMessage()

func (*TaskPerformance) ProtoReflect

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

func (*TaskPerformance) Reset

func (x *TaskPerformance) Reset()

func (*TaskPerformance) String

func (x *TaskPerformance) String() string

type TaskProperties

type TaskProperties struct {

	// Isolated inputs to map in the working directory.
	//
	// Deprecated: Isolate server is being migrated to RBE-CAS. `cas_input_root`
	// will be used to reference to the input root on RBE-CAS.
	//
	// Deprecated: the isolated file may optionally specify a command to run.
	// Otherwise, 'command' must be specified.
	CasInputs *CASTree `protobuf:"bytes,1,opt,name=cas_inputs,json=casInputs,proto3" json:"cas_inputs,omitempty"`
	// Digest of the input root on RBE-CAS.
	//
	// cas_input_root.digest MUST be digest of [build.bazel.remote.execution.v2.Directory].
	CasInputRoot *api_v2.CASReference `protobuf:"bytes,18,opt,name=cas_input_root,json=casInputRoot,proto3" json:"cas_input_root,omitempty"`
	// Set of CIPD packages to install prior to running the task.
	//
	// Sorted.
	CipdInputs []*CIPDPackage `protobuf:"bytes,2,rep,name=cipd_inputs,json=cipdInputs,proto3" json:"cipd_inputs,omitempty"`
	// Named caches to map into the working directory.
	//
	// Sorted.
	NamedCaches []*NamedCacheEntry `protobuf:"bytes,3,rep,name=named_caches,json=namedCaches,proto3" json:"named_caches,omitempty"`
	// The command line to run.
	Command []string `protobuf:"bytes,4,rep,name=command,proto3" json:"command,omitempty"`
	// Relative working directory to start the 'command' in, defaults to the root
	// mapped directory or what is provided in the isolated file, if any.
	RelativeCwd string `protobuf:"bytes,5,opt,name=relative_cwd,json=relativeCwd,proto3" json:"relative_cwd,omitempty"`
	// Extraneous arguments to append to the command specified in the isolated
	// file. Can only be used when an isolated file specifies a command.
	//
	// Deprecated.
	ExtraArgs []string `protobuf:"bytes,6,rep,name=extra_args,json=extraArgs,proto3" json:"extra_args,omitempty"`
	// Secret bytes to provide to the task. Write only, cannot be retrieved back.
	//
	// Always empty in BQ exports.
	SecretBytes []byte `protobuf:"bytes,7,opt,name=secret_bytes,json=secretBytes,proto3" json:"secret_bytes,omitempty"`
	// True if properties had secret bytes in them.
	HasSecretBytes bool `protobuf:"varint,8,opt,name=has_secret_bytes,json=hasSecretBytes,proto3" json:"has_secret_bytes,omitempty"`
	// Dimensions are what is used to determine which bot can run the task.
	//
	// The values are effectively an AND, a bot must match all dimensions to be
	// selected to run the task.
	//
	// Sorted.
	Dimensions []*StringListPair `protobuf:"bytes,9,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Environment variables to set when running the task.
	//
	// Sorted.
	Env []*StringPair `protobuf:"bytes,10,rep,name=env,proto3" json:"env,omitempty"`
	// Task root relative paths to prepend to a given environment variable.
	//
	// This allows one to safely modify variables like PATH, PYTHONPATH, or other
	// PATH-like environment variables. The order of operations is:
	//   - Turn slashes into native-platform slashes
	//   - Make the path absolute
	//   - Prepend it to the current value of the envvar using the os-native list
	//     separator (`;` on Windows, `:` on POSIX)
	//
	// Each key can have multiple paths to prepend. They will be prepended in
	// the order seen here.
	//
	// For example, if env_paths is:
	//
	//	[ (key="PATH", values=["foo", "bar"]),
	//	  (key="CUSTOMPATH", values=["custom"]), ]
	//
	// The task would see:
	//
	//	PATH=/path/to/swarming/rundir/foo:/path/to/swarming/rundir/bar:$PATH
	//	CUSTOMPATH=/path/to/swarming/rundir/custom
	//
	// Paths must always be specified here with forward-slashes, and must not
	// attempt to escape the task's root (i.e. must not contain `..`).
	//
	// This is applied AFTER evaluating `env`.
	//
	// Sorted by key.
	EnvPaths []*StringListPair `protobuf:"bytes,11,rep,name=env_paths,json=envPaths,proto3" json:"env_paths,omitempty"`
	// Unused.
	Containment *api_v2.Containment `protobuf:"bytes,12,opt,name=containment,proto3" json:"containment,omitempty"`
	// Maximum number of seconds the task can run before its process is forcibly
	// terminated and the task results in TIMED_OUT.
	ExecutionTimeout float64 `protobuf:"fixed64,13,opt,name=execution_timeout,json=executionTimeout,proto3" json:"execution_timeout,omitempty"`
	// Maximum number of seconds the task may be silent (no output to stdout nor
	// stderr) before it is considered hung and it forcibly terminated early and
	// the task results in TIMED_OUT_SILENCE.
	IoTimeout float64 `protobuf:"fixed64,14,opt,name=io_timeout,json=ioTimeout,proto3" json:"io_timeout,omitempty"`
	// Number of second to give the child process after a SIGTERM before sending a
	// SIGKILL.
	GracePeriod float64 `protobuf:"fixed64,15,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"`
	// True if it is OK to reuse results of a previously successfully completed
	// idempotent task with them same Properties.
	//
	// Should be set only for tasks that do not have side effects and produce same
	// outputs given the same inputs.
	//
	// Tasks that reuse results of existing tasks have state DEDUPED.
	Idempotent bool `protobuf:"varint,16,opt,name=idempotent,proto3" json:"idempotent,omitempty"`
	// Paths in the working directory to archive back and store as
	// TaskResult.outputs.
	//
	// Sorted.
	Outputs []string `protobuf:"bytes,17,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Unused.
	User User `protobuf:"varint,19,opt,name=user,proto3,enum=swarming.bq.User" json:"user,omitempty"`
	// contains filtered or unexported fields
}

Defines what to run.

A serialization of this message is hashed and this hash is what is used for task deduping.

func (*TaskProperties) Descriptor deprecated

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

Deprecated: Use TaskProperties.ProtoReflect.Descriptor instead.

func (*TaskProperties) GetCasInputRoot

func (x *TaskProperties) GetCasInputRoot() *api_v2.CASReference

func (*TaskProperties) GetCasInputs

func (x *TaskProperties) GetCasInputs() *CASTree

func (*TaskProperties) GetCipdInputs

func (x *TaskProperties) GetCipdInputs() []*CIPDPackage

func (*TaskProperties) GetCommand

func (x *TaskProperties) GetCommand() []string

func (*TaskProperties) GetContainment

func (x *TaskProperties) GetContainment() *api_v2.Containment

func (*TaskProperties) GetDimensions

func (x *TaskProperties) GetDimensions() []*StringListPair

func (*TaskProperties) GetEnv

func (x *TaskProperties) GetEnv() []*StringPair

func (*TaskProperties) GetEnvPaths

func (x *TaskProperties) GetEnvPaths() []*StringListPair

func (*TaskProperties) GetExecutionTimeout

func (x *TaskProperties) GetExecutionTimeout() float64

func (*TaskProperties) GetExtraArgs

func (x *TaskProperties) GetExtraArgs() []string

func (*TaskProperties) GetGracePeriod

func (x *TaskProperties) GetGracePeriod() float64

func (*TaskProperties) GetHasSecretBytes

func (x *TaskProperties) GetHasSecretBytes() bool

func (*TaskProperties) GetIdempotent

func (x *TaskProperties) GetIdempotent() bool

func (*TaskProperties) GetIoTimeout

func (x *TaskProperties) GetIoTimeout() float64

func (*TaskProperties) GetNamedCaches

func (x *TaskProperties) GetNamedCaches() []*NamedCacheEntry

func (*TaskProperties) GetOutputs

func (x *TaskProperties) GetOutputs() []string

func (*TaskProperties) GetRelativeCwd

func (x *TaskProperties) GetRelativeCwd() string

func (*TaskProperties) GetSecretBytes

func (x *TaskProperties) GetSecretBytes() []byte

func (*TaskProperties) GetUser

func (x *TaskProperties) GetUser() User

func (*TaskProperties) ProtoMessage

func (*TaskProperties) ProtoMessage()

func (*TaskProperties) ProtoReflect

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

func (*TaskProperties) Reset

func (x *TaskProperties) Reset()

func (*TaskProperties) String

func (x *TaskProperties) String() string

type TaskRequest

type TaskRequest struct {

	// List of TaskSlice, along with their scheduling parameters.
	//
	// Each TaskSlice defines where to run the task and what it does. They are
	// processed in order until the first successfully scheduled one. It is
	// guaranteed that at most one of these will be attempted.
	TaskSlices []*TaskSlice `protobuf:"bytes,1,rep,name=task_slices,json=taskSlices,proto3" json:"task_slices,omitempty"`
	// Task priority, the lower the more important.
	//
	// Valid values are between 1 and 255.
	Priority int32 `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	// Defines what OAuth2 credentials the task uses when calling other services.
	//
	// Possible values are:
	//   - 'none': do not use a task service account at all, this is the default.
	//   - 'bot': use bot's own account, works only if bots authenticate with
	//     OAuth2.
	//   - <some email>: use this specific service account if it is allowed in the
	//     pool (via 'allowed_service_account' pools.cfg setting) and configured
	//     in the token server's service_accounts.cfg.
	//
	// Note that the service account name is specified outside of task properties,
	// and thus it is possible to have two tasks with different service accounts,
	// but identical properties hash (so one can be deduped).
	ServiceAccount string `protobuf:"bytes,3,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// When the task was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Task name for display purpose.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// Tags are 'key:value' strings that describes what the task is about (it's
	// semantic meaning).
	//
	// It is fine to reuse the same 'key' multiple times. It is not fine to use a
	// key that is also used as a dimension.
	//
	// Tags are sorted.
	Tags []string `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
	// User for this task is run, if relevant. Not validated.
	User string `protobuf:"bytes,7,opt,name=user,proto3" json:"user,omitempty"`
	// Authenticated client that triggered this task.
	Authenticated string `protobuf:"bytes,13,opt,name=authenticated,proto3" json:"authenticated,omitempty"`
	// Task realm is used to control who can interact with the task e.g. get,
	// cancel etc, and which task service accounts can be used in the realm.
	Realm string `protobuf:"bytes,14,opt,name=realm,proto3" json:"realm,omitempty"`
	// ResultDB integration configuration for a task.
	Resultdb *api_v2.ResultDBCfg `protobuf:"bytes,15,opt,name=resultdb,proto3" json:"resultdb,omitempty"`
	// The task ID.
	//
	// This is an overall ID of the task (not a concrete run attempt). Such IDs
	// end with 0.
	TaskId string `protobuf:"bytes,8,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Parent Swarming task ID of the process requesting this task (if any).
	//
	// This is an overall ID of the task (not a concrete run attempt). Such IDs
	// end with 0.
	ParentTaskId string `protobuf:"bytes,9,opt,name=parent_task_id,json=parentTaskId,proto3" json:"parent_task_id,omitempty"`
	// Parent Swarming task run ID of the process requesting this task (if any).
	//
	// This is an ID of a concrete run attempt. Such IDs end with 1.
	ParentRunId string `protobuf:"bytes,11,opt,name=parent_run_id,json=parentRunId,proto3" json:"parent_run_id,omitempty"`
	// Root task id, independent of the depth of recursive tasks.
	//
	// This is an overall ID of the task (not a concrete run attempt). Such IDs
	// end with 0.
	RootTaskId string `protobuf:"bytes,16,opt,name=root_task_id,json=rootTaskId,proto3" json:"root_task_id,omitempty"`
	// Root task run id, independent of the depth of recursive tasks.
	//
	// This is an ID of a concrete run attempt. Such IDs end with 1.
	RootRunId string `protobuf:"bytes,17,opt,name=root_run_id,json=rootRunId,proto3" json:"root_run_id,omitempty"`
	// PubSub topic that receives notifications from this task.
	PubsubNotification *PubSub `protobuf:"bytes,10,opt,name=pubsub_notification,json=pubsubNotification,proto3" json:"pubsub_notification,omitempty"`
	// Maximum delay between bot pings before the bot is considered dead
	// while running a task in seconds.
	BotPingTolerance float64 `protobuf:"fixed64,12,opt,name=bot_ping_tolerance,json=botPingTolerance,proto3" json:"bot_ping_tolerance,omitempty"`
	// contains filtered or unexported fields
}

What has been submitted to Swarming for execution.

func (*TaskRequest) Descriptor deprecated

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

Deprecated: Use TaskRequest.ProtoReflect.Descriptor instead.

func (*TaskRequest) GetAuthenticated

func (x *TaskRequest) GetAuthenticated() string

func (*TaskRequest) GetBotPingTolerance

func (x *TaskRequest) GetBotPingTolerance() float64

func (*TaskRequest) GetCreateTime

func (x *TaskRequest) GetCreateTime() *timestamppb.Timestamp

func (*TaskRequest) GetName

func (x *TaskRequest) GetName() string

func (*TaskRequest) GetParentRunId

func (x *TaskRequest) GetParentRunId() string

func (*TaskRequest) GetParentTaskId

func (x *TaskRequest) GetParentTaskId() string

func (*TaskRequest) GetPriority

func (x *TaskRequest) GetPriority() int32

func (*TaskRequest) GetPubsubNotification

func (x *TaskRequest) GetPubsubNotification() *PubSub

func (*TaskRequest) GetRealm

func (x *TaskRequest) GetRealm() string

func (*TaskRequest) GetResultdb

func (x *TaskRequest) GetResultdb() *api_v2.ResultDBCfg

func (*TaskRequest) GetRootRunId

func (x *TaskRequest) GetRootRunId() string

func (*TaskRequest) GetRootTaskId

func (x *TaskRequest) GetRootTaskId() string

func (*TaskRequest) GetServiceAccount

func (x *TaskRequest) GetServiceAccount() string

func (*TaskRequest) GetTags

func (x *TaskRequest) GetTags() []string

func (*TaskRequest) GetTaskId

func (x *TaskRequest) GetTaskId() string

func (*TaskRequest) GetTaskSlices

func (x *TaskRequest) GetTaskSlices() []*TaskSlice

func (*TaskRequest) GetUser

func (x *TaskRequest) GetUser() string

func (*TaskRequest) ProtoMessage

func (*TaskRequest) ProtoMessage()

func (*TaskRequest) ProtoReflect

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

func (*TaskRequest) Reset

func (x *TaskRequest) Reset()

func (*TaskRequest) String

func (x *TaskRequest) String() string

type TaskResult

type TaskResult struct {

	// The task request that concluded with this result.
	Request *TaskRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	// Time the task was requested.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Time the task started being run by a bot, before RUNNING_OVERHEAD_SETUP.
	//
	// Doing "start_time - create_time" gives the task pending time.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Time when the task was abandoned instead of normal completion.
	//
	// This happens for example when a task was KILLED, this then represents the
	// time a client requested the task to be killed, which is before end_time.
	// Same for TIMED_OUT state, this then represents the time when the bot
	// decided to abort the task.
	AbandonTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=abandon_time,json=abandonTime,proto3" json:"abandon_time,omitempty"`
	// Time the task completed and teared down, after RUNNING_OVERHEAD_TEARDOWN.
	//
	// Doing "end_time - start_time" will not lead to the exact task duration,
	// since this time frame includes overheads.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Duration of the task in seconds. This excludes overheads.
	Duration float64 `protobuf:"fixed64,6,opt,name=duration,proto3" json:"duration,omitempty"`
	// Current state of the task (e.g. PENDING, RUNNING, COMPLETED, EXPIRED, etc).
	State TaskState `protobuf:"varint,7,opt,name=state,proto3,enum=swarming.bq.TaskState" json:"state,omitempty"`
	// The category of the current task state. This is primarily useful to
	// simplify BigQuery queries. This can be used to determine if a task is done
	// or if still considered for execution.
	StateCategory TaskStateCategory `` /* 136-byte string literal not displayed */
	// The task try number.
	//
	// It is 0 for a deduped task, since nothing ran. It is 0 if the task is still
	// PENDING.
	//
	// It is normally 1 for a task that started running and runs a normal flow.
	TryNumber int32 `protobuf:"varint,9,opt,name=try_number,json=tryNumber,proto3" json:"try_number,omitempty"`
	// Index in the TaskRequest.task_slices (TaskSlice instance) that this result
	// represents.
	//
	// The TaskSlice contains a TaskProperties, which defines what is run.
	CurrentTaskSlice int32 `protobuf:"varint,10,opt,name=current_task_slice,json=currentTaskSlice,proto3" json:"current_task_slice,omitempty"`
	// Snapshot of the bot that was assigned to this task at the start of the
	// task. This includes bot local cache information.
	Bot *Bot `protobuf:"bytes,11,opt,name=bot,proto3" json:"bot,omitempty"`
	// Server versions that touched this task.
	//
	// A different version of the server may get the request and hand it to the
	// bot. This is primarily useful to detect if a new server version introduced
	// a bug and for canarying purpose.
	ServerVersions []string `protobuf:"bytes,12,rep,name=server_versions,json=serverVersions,proto3" json:"server_versions,omitempty"`
	// List of children task IDs that this task triggered, if any.
	//
	// This is populate only in the case this Swarming task triggers more Swarming
	// tasks. Each of these task will have 'run_id' set as their 'TaskRequest.parent_task_id'.
	ChildrenTaskIds []string `protobuf:"bytes,13,rep,name=children_task_ids,json=childrenTaskIds,proto3" json:"children_task_ids,omitempty"`
	// Task ID which results was reused for state DEDUPED.
	//
	// This is the run_id (ending with '1', '2' or more).
	DedupedFrom string `protobuf:"bytes,14,opt,name=deduped_from,json=dedupedFrom,proto3" json:"deduped_from,omitempty"`
	// Summary task ID (ending with '0') when creating a new task.
	TaskId string `protobuf:"bytes,15,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Actual executed task id that this task represents.
	//
	// This value is only set if it ran, that is, the task went through one of the
	// state in CATEGORY_RUNNING.
	RunId string `protobuf:"bytes,16,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Listing of the actual pinned CIPDPackages that the task used.
	//
	// These can vary from the input packages if the inputs included non-identity
	// versions (e.g. a ref like "latest"). This can be available once task setup
	// is completed.
	CipdPins *CIPDPins `protobuf:"bytes,17,opt,name=cipd_pins,json=cipdPins,proto3" json:"cipd_pins,omitempty"`
	// Statistics about overhead for an isolated task. This is populated as the
	// task goes through setup, execution and teardown.
	Performance *TaskPerformance `protobuf:"bytes,18,opt,name=performance,proto3" json:"performance,omitempty"`
	// Process exit code if relevant. May be forcibly set to -1 in exceptional
	// cases.
	ExitCode int64 `protobuf:"zigzag64,19,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// Isolated outputs, if any.
	//
	// Deprecated: `cas_output_root` will be used.
	Outputs *CASTree `protobuf:"bytes,20,opt,name=outputs,proto3" json:"outputs,omitempty"`
	// RBE-CAS output, if any.
	CasOutputRoot *api_v2.CASReference `protobuf:"bytes,21,opt,name=cas_output_root,json=casOutputRoot,proto3" json:"cas_output_root,omitempty"`
	// ResultDB related properties for this task.
	ResultdbInfo *api_v2.ResultDBInfo `protobuf:"bytes,22,opt,name=resultdb_info,json=resultdbInfo,proto3" json:"resultdb_info,omitempty"`
	// contains filtered or unexported fields
}

TaskResult is the result of a TaskRequest as it is processed by Swarming.

The TaskResult represents one attempt (run on a bot) and/or the final result (summary). When the task never ran (for example EXPIRED), there's one summary but no run.

func (*TaskResult) Descriptor deprecated

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

Deprecated: Use TaskResult.ProtoReflect.Descriptor instead.

func (*TaskResult) GetAbandonTime

func (x *TaskResult) GetAbandonTime() *timestamppb.Timestamp

func (*TaskResult) GetBot

func (x *TaskResult) GetBot() *Bot

func (*TaskResult) GetCasOutputRoot

func (x *TaskResult) GetCasOutputRoot() *api_v2.CASReference

func (*TaskResult) GetChildrenTaskIds

func (x *TaskResult) GetChildrenTaskIds() []string

func (*TaskResult) GetCipdPins

func (x *TaskResult) GetCipdPins() *CIPDPins

func (*TaskResult) GetCreateTime

func (x *TaskResult) GetCreateTime() *timestamppb.Timestamp

func (*TaskResult) GetCurrentTaskSlice

func (x *TaskResult) GetCurrentTaskSlice() int32

func (*TaskResult) GetDedupedFrom

func (x *TaskResult) GetDedupedFrom() string

func (*TaskResult) GetDuration

func (x *TaskResult) GetDuration() float64

func (*TaskResult) GetEndTime

func (x *TaskResult) GetEndTime() *timestamppb.Timestamp

func (*TaskResult) GetExitCode

func (x *TaskResult) GetExitCode() int64

func (*TaskResult) GetOutputs

func (x *TaskResult) GetOutputs() *CASTree

func (*TaskResult) GetPerformance

func (x *TaskResult) GetPerformance() *TaskPerformance

func (*TaskResult) GetRequest

func (x *TaskResult) GetRequest() *TaskRequest

func (*TaskResult) GetResultdbInfo

func (x *TaskResult) GetResultdbInfo() *api_v2.ResultDBInfo

func (*TaskResult) GetRunId

func (x *TaskResult) GetRunId() string

func (*TaskResult) GetServerVersions

func (x *TaskResult) GetServerVersions() []string

func (*TaskResult) GetStartTime

func (x *TaskResult) GetStartTime() *timestamppb.Timestamp

func (*TaskResult) GetState

func (x *TaskResult) GetState() TaskState

func (*TaskResult) GetStateCategory

func (x *TaskResult) GetStateCategory() TaskStateCategory

func (*TaskResult) GetTaskId

func (x *TaskResult) GetTaskId() string

func (*TaskResult) GetTryNumber

func (x *TaskResult) GetTryNumber() int32

func (*TaskResult) ProtoMessage

func (*TaskResult) ProtoMessage()

func (*TaskResult) ProtoReflect

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

func (*TaskResult) Reset

func (x *TaskResult) Reset()

func (*TaskResult) String

func (x *TaskResult) String() string

type TaskSetupOverhead

type TaskSetupOverhead struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// Cache trimming overhead.
	CacheTrim *CacheTrimOverhead `protobuf:"bytes,2,opt,name=cache_trim,json=cacheTrim,proto3" json:"cache_trim,omitempty"`
	// CIPD package installation overhead.
	Cipd *CIPDOverhead `protobuf:"bytes,3,opt,name=cipd,proto3" json:"cipd,omitempty"`
	// Named cache install overhead.
	NamedCache *NamedCacheOverhead `protobuf:"bytes,4,opt,name=named_cache,json=namedCache,proto3" json:"named_cache,omitempty"`
	// CAS download overhead.
	Cas *CASOverhead `protobuf:"bytes,5,opt,name=cas,proto3" json:"cas,omitempty"`
	// contains filtered or unexported fields
}

Overhead information about setup.

func (*TaskSetupOverhead) Descriptor deprecated

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

Deprecated: Use TaskSetupOverhead.ProtoReflect.Descriptor instead.

func (*TaskSetupOverhead) GetCacheTrim

func (x *TaskSetupOverhead) GetCacheTrim() *CacheTrimOverhead

func (*TaskSetupOverhead) GetCas

func (x *TaskSetupOverhead) GetCas() *CASOverhead

func (*TaskSetupOverhead) GetCipd

func (x *TaskSetupOverhead) GetCipd() *CIPDOverhead

func (*TaskSetupOverhead) GetDuration

func (x *TaskSetupOverhead) GetDuration() float64

func (*TaskSetupOverhead) GetNamedCache

func (x *TaskSetupOverhead) GetNamedCache() *NamedCacheOverhead

func (*TaskSetupOverhead) ProtoMessage

func (*TaskSetupOverhead) ProtoMessage()

func (*TaskSetupOverhead) ProtoReflect

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

func (*TaskSetupOverhead) Reset

func (x *TaskSetupOverhead) Reset()

func (*TaskSetupOverhead) String

func (x *TaskSetupOverhead) String() string

type TaskSlice

type TaskSlice struct {

	// The property of the task to try to run.
	//
	// In particular properties.dimensions are used to find bots that can run this
	// slice.
	Properties *TaskProperties `protobuf:"bytes,1,opt,name=properties,proto3" json:"properties,omitempty"`
	// If this task slice is not picked up by a bot after waiting this number of
	// seconds, the next one will be processed. If this is the last slice, the
	// task will fail with EXPIRED error.
	Expiration float64 `protobuf:"fixed64,2,opt,name=expiration,proto3" json:"expiration,omitempty"`
	// This flag controls what to do if there are no bots online with requested
	// dimensions when this slice is submitted.
	//
	// A bot is consider online if it is present (sends pings to Swarming) and not
	// quarantined. It may be busy running some other task though.
	//
	// If wait_for_capacity is false and there are no bots online that match
	// requested dimensions, the slice is skipped immediately with NO_RESOURCE
	// error (the next slice is processed instead).
	//
	// If wait_for_capacity is true, the slice will be put into the pending queue
	// and will stay there either until a matching bot appears and picks it up,
	// or the slice reaches its expiration timeout.
	WaitForCapacity bool `protobuf:"varint,3,opt,name=wait_for_capacity,json=waitForCapacity,proto3" json:"wait_for_capacity,omitempty"`
	// Digest of a serialized form of TaskProperties.
	//
	// This is used for DEDUPED and PENDING_DEDUPING when idempotent is true.
	// Consider this value as opaque string, only use to check equality.
	//
	// It is set even if idempotent is false.
	PropertiesHash string `protobuf:"bytes,4,opt,name=properties_hash,json=propertiesHash,proto3" json:"properties_hash,omitempty"`
	// contains filtered or unexported fields
}

Defines where to run the task and what it does.

A single TaskRequest can have multiple TaskSlices. They are processed in order until the first successfully scheduled one.

func (*TaskSlice) Descriptor deprecated

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

Deprecated: Use TaskSlice.ProtoReflect.Descriptor instead.

func (*TaskSlice) GetExpiration

func (x *TaskSlice) GetExpiration() float64

func (*TaskSlice) GetProperties

func (x *TaskSlice) GetProperties() *TaskProperties

func (*TaskSlice) GetPropertiesHash

func (x *TaskSlice) GetPropertiesHash() string

func (*TaskSlice) GetWaitForCapacity

func (x *TaskSlice) GetWaitForCapacity() bool

func (*TaskSlice) ProtoMessage

func (*TaskSlice) ProtoMessage()

func (*TaskSlice) ProtoReflect

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

func (*TaskSlice) Reset

func (x *TaskSlice) Reset()

func (*TaskSlice) String

func (x *TaskSlice) String() string

type TaskState

type TaskState int32

TaskState represents the different possible states for a Task.

Each state is in one of the bitmask in TaskStateCategory.

const (
	// Invalid task state.
	TaskState_TASK_STATE_INVALID TaskState = 0
	// The task is currently pending.
	//
	// This means that no bot reaped the task yet. It will stay in this state
	// until either a bot reaps the task, or the expiration elapsed or all bots
	// become MISSING, leading to a NO_RESOURCE. The task pending expiration is
	// specified as TaskSlice.expiration, one per task slice.
	//
	// The task may go through multiple pending TaskSlice as they expire or are
	// skipped due to NO_RESOURCE (see definition below). In this situation the
	// task state still stays in PENDING state as long as there's a chance for a
	// bot to reap the task.
	TaskState_PENDING TaskState = 16
	// Unused.
	TaskState_PENDING_DEDUPING TaskState = 17
	// The task is currently running.
	//
	// For new tasks, this is only the actual tasks runtime. For old tasks, this
	// includes RUNNING_OVERHEAD_START and RUNNING_OVERHEAD_END.
	TaskState_RUNNING TaskState = 32
	// Unused.
	TaskState_RUNNING_OVERHEAD_SETUP TaskState = 33
	// Unused.
	TaskState_RUNNING_OVERHEAD_TEARDOWN TaskState = 34
	// Unused.
	TaskState_TERMINATING TaskState = 35
	// Unused.
	TaskState_COMPLETING TaskState = 47
	// The task ran but the bot had an internal failure, unrelated to the task
	// itself. It can be due to disk or network I/O issues.
	TaskState_RAN_INTERNAL_FAILURE TaskState = 48
	// Unused.
	TaskState_DUT_FAILURE TaskState = 49
	// Unused.
	TaskState_BOT_DISAPPEARED TaskState = 50
	// Unused.
	TaskState_PREEMPTED TaskState = 51
	// The task ran and completed normally. The task process exit code may be 0 or
	// another value.
	//
	// This value is also used when the task is deduped against a previous task.
	TaskState_COMPLETED TaskState = 64
	// The task ran for longer than the allowed time in
	// TaskProperties.execution_timeout.
	//
	// This means the bot forcefully killed the task process as described in the
	// graceful termination dance in the documentation.
	TaskState_TIMED_OUT TaskState = 65
	// Unused.
	TaskState_TIMED_OUT_SILENCE TaskState = 66
	// The task ran but was manually killed via the 'cancel' API.
	//
	// This means the bot forcefully killed the task process as described in the
	// graceful termination dance in the documentation.
	TaskState_KILLED TaskState = 67
	// Unused.
	TaskState_MISSING_INPUTS TaskState = 68
	// The task didn't have to run, because a previous task had results. It is
	// functionally equivalent to COMPLETED, except that previous results were
	// returned as-is.
	TaskState_DEDUPED TaskState = 80
	// The task is not pending anymore; it never ran due to lack of capacity.
	//
	// This means that other higher priority tasks ran instead and that not enough
	// bots were available to run this task for TaskSlice.expiration.
	TaskState_EXPIRED TaskState = 81
	// The task never ran, and was manually cancelled via the 'cancel' API before
	// it was reaped.
	TaskState_CANCELED TaskState = 82
	// The task was never set to PENDING and was immediately refused, as the
	// server determined that there is no bot capacity to run this task. This
	// happens because no bot exposes a superset of the requested task dimensions.
	//
	// There can be a situation where a task goes from PENDING to NO_RESOURCE if
	// capacity (bots) is removed.
	//
	// Set TaskSlice.wait_for_capacity to True to force the server to keep the
	// task slice pending even in this case. Generally speaking, the task will
	// eventually switch to EXPIRED, as there's no bot to run it. That said, there
	// are situations where it is known that in some not-too-distant future a wild
	// bot will appear that will be able to run this task.
	TaskState_NO_RESOURCE TaskState = 83
	// Unused.
	TaskState_LOAD_SHED TaskState = 84
	// Unused.
	TaskState_RESOURCE_EXHAUSTED TaskState = 85
	// Unused.
	TaskState_SKIPPED_INTERNAL_FAILURE TaskState = 86
	// The task encountered an error caused by the client. This means that
	// rerunning the task with the same parameters will not change the result
	TaskState_CLIENT_ERROR TaskState = 87
)

func (TaskState) Descriptor

func (TaskState) Descriptor() protoreflect.EnumDescriptor

func (TaskState) Enum

func (x TaskState) Enum() *TaskState

func (TaskState) EnumDescriptor deprecated

func (TaskState) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskState.Descriptor instead.

func (TaskState) Number

func (x TaskState) Number() protoreflect.EnumNumber

func (TaskState) String

func (x TaskState) String() string

func (TaskState) Type

type TaskStateCategory

type TaskStateCategory int32

TaskStateCategory represents different categories of task state.

const (
	// Invalid value.
	TaskStateCategory_TASK_STATE_CATEGORY_UNSPECIFIED TaskStateCategory = 0
	// The task is enqueued and pending bot availability.
	TaskStateCategory_CATEGORY_PENDING TaskStateCategory = 16
	// The task is running.
	TaskStateCategory_CATEGORY_RUNNING TaskStateCategory = 32
	// Transient done states are uncertain states; something ran but the result
	// was inconclusive.
	TaskStateCategory_CATEGORY_TRANSIENT_DONE TaskStateCategory = 48
	// The task ran, and it is done.
	TaskStateCategory_CATEGORY_EXECUTION_DONE TaskStateCategory = 64
	// The task did not run, and won't.
	TaskStateCategory_CATEGORY_NEVER_RAN_DONE TaskStateCategory = 80
)

func (TaskStateCategory) Descriptor

func (TaskStateCategory) Enum

func (TaskStateCategory) EnumDescriptor deprecated

func (TaskStateCategory) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskStateCategory.Descriptor instead.

func (TaskStateCategory) Number

func (TaskStateCategory) String

func (x TaskStateCategory) String() string

func (TaskStateCategory) Type

type TaskTeardownOverhead

type TaskTeardownOverhead struct {

	// Duration of this overhead in seconds.
	Duration float64 `protobuf:"fixed64,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// CAS upload overhead.
	Cas *CASOverhead `protobuf:"bytes,2,opt,name=cas,proto3" json:"cas,omitempty"`
	// Named cache uninstall overhead.
	NamedCache *NamedCacheOverhead `protobuf:"bytes,3,opt,name=named_cache,json=namedCache,proto3" json:"named_cache,omitempty"`
	// Directory cleanup overhead.
	Cleanup *CleanupOverhead `protobuf:"bytes,4,opt,name=cleanup,proto3" json:"cleanup,omitempty"`
	// contains filtered or unexported fields
}

Overhead information about teardown.

func (*TaskTeardownOverhead) Descriptor deprecated

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

Deprecated: Use TaskTeardownOverhead.ProtoReflect.Descriptor instead.

func (*TaskTeardownOverhead) GetCas

func (x *TaskTeardownOverhead) GetCas() *CASOverhead

func (*TaskTeardownOverhead) GetCleanup

func (x *TaskTeardownOverhead) GetCleanup() *CleanupOverhead

func (*TaskTeardownOverhead) GetDuration

func (x *TaskTeardownOverhead) GetDuration() float64

func (*TaskTeardownOverhead) GetNamedCache

func (x *TaskTeardownOverhead) GetNamedCache() *NamedCacheOverhead

func (*TaskTeardownOverhead) ProtoMessage

func (*TaskTeardownOverhead) ProtoMessage()

func (*TaskTeardownOverhead) ProtoReflect

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

func (*TaskTeardownOverhead) Reset

func (x *TaskTeardownOverhead) Reset()

func (*TaskTeardownOverhead) String

func (x *TaskTeardownOverhead) String() string

type User

type User int32

Unused.

const (
	User_USER_UNSPECIFIED User = 0
	User_USER_SWARMING    User = 1
	User_USER_TEMPORARY   User = 2
)

func (User) Descriptor

func (User) Descriptor() protoreflect.EnumDescriptor

func (User) Enum

func (x User) Enum() *User

func (User) EnumDescriptor deprecated

func (User) EnumDescriptor() ([]byte, []int)

Deprecated: Use User.Descriptor instead.

func (User) Number

func (x User) Number() protoreflect.EnumNumber

func (User) String

func (x User) String() string

func (User) Type

func (User) Type() protoreflect.EnumType

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL