bqpb

package
v0.0.0-...-86f0ed1 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 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) Descriptor() protoreflect.EnumDescriptor

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 (x BotEventType) Number() protoreflect.EnumNumber

func (BotEventType) String 

func (x BotEventType) String() string

func (BotEventType) Type 

func (BotEventType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 (x BotStatusType) Number() protoreflect.EnumNumber

func (BotStatusType) String 

func (x BotStatusType) String() string

func (BotStatusType) Type 

func (BotStatusType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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) Type() protoreflect.EnumType

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 

func (TaskState) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

func (TaskStateCategory) Enum 

func (x TaskStateCategory) Enum() *TaskStateCategory

func (TaskStateCategory) EnumDescriptor deprecated 

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

Deprecated: Use TaskStateCategory.Descriptor instead.

func (TaskStateCategory) Number 

func (x TaskStateCategory) Number() protoreflect.EnumNumber

func (TaskStateCategory) String 

func (x TaskStateCategory) String() string

func (TaskStateCategory) Type 

func (TaskStateCategory) Type() protoreflect.EnumType

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.