apipb

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: 13 Imported by: 29

Documentation

Overview

Package apipb contains swarming.v2 protos

Index

Constants

View Source 
const (
	Bots_GetBot_FullMethodName           = "/swarming.v2.Bots/GetBot"
	Bots_DeleteBot_FullMethodName        = "/swarming.v2.Bots/DeleteBot"
	Bots_ListBotEvents_FullMethodName    = "/swarming.v2.Bots/ListBotEvents"
	Bots_TerminateBot_FullMethodName     = "/swarming.v2.Bots/TerminateBot"
	Bots_ListBotTasks_FullMethodName     = "/swarming.v2.Bots/ListBotTasks"
	Bots_ListBots_FullMethodName         = "/swarming.v2.Bots/ListBots"
	Bots_CountBots_FullMethodName        = "/swarming.v2.Bots/CountBots"
	Bots_GetBotDimensions_FullMethodName = "/swarming.v2.Bots/GetBotDimensions"
)
View Source 
const (
	Tasks_GetResult_FullMethodName        = "/swarming.v2.Tasks/GetResult"
	Tasks_BatchGetResult_FullMethodName   = "/swarming.v2.Tasks/BatchGetResult"
	Tasks_GetRequest_FullMethodName       = "/swarming.v2.Tasks/GetRequest"
	Tasks_CancelTask_FullMethodName       = "/swarming.v2.Tasks/CancelTask"
	Tasks_GetStdout_FullMethodName        = "/swarming.v2.Tasks/GetStdout"
	Tasks_NewTask_FullMethodName          = "/swarming.v2.Tasks/NewTask"
	Tasks_ListTasks_FullMethodName        = "/swarming.v2.Tasks/ListTasks"
	Tasks_ListTaskStates_FullMethodName   = "/swarming.v2.Tasks/ListTaskStates"
	Tasks_ListTaskRequests_FullMethodName = "/swarming.v2.Tasks/ListTaskRequests"
	Tasks_CancelTasks_FullMethodName      = "/swarming.v2.Tasks/CancelTasks"
	Tasks_CountTasks_FullMethodName       = "/swarming.v2.Tasks/CountTasks"
)
View Source 
const (
	Swarming_GetDetails_FullMethodName     = "/swarming.v2.Swarming/GetDetails"
	Swarming_GetToken_FullMethodName       = "/swarming.v2.Swarming/GetToken"
	Swarming_GetPermissions_FullMethodName = "/swarming.v2.Swarming/GetPermissions"
)

Variables

View Source 
var (
	StateQuery_name = map[int32]string{
		0:  "QUERY_PENDING",
		1:  "QUERY_RUNNING",
		2:  "QUERY_PENDING_RUNNING",
		3:  "QUERY_COMPLETED",
		4:  "QUERY_COMPLETED_SUCCESS",
		5:  "QUERY_COMPLETED_FAILURE",
		6:  "QUERY_EXPIRED",
		7:  "QUERY_TIMED_OUT",
		8:  "QUERY_BOT_DIED",
		9:  "QUERY_CANCELED",
		10: "QUERY_ALL",
		11: "QUERY_DEDUPED",
		12: "QUERY_KILLED",
		13: "QUERY_NO_RESOURCE",
		14: "QUERY_CLIENT_ERROR",
	}
	StateQuery_value = map[string]int32{
		"QUERY_PENDING":           0,
		"QUERY_RUNNING":           1,
		"QUERY_PENDING_RUNNING":   2,
		"QUERY_COMPLETED":         3,
		"QUERY_COMPLETED_SUCCESS": 4,
		"QUERY_COMPLETED_FAILURE": 5,
		"QUERY_EXPIRED":           6,
		"QUERY_TIMED_OUT":         7,
		"QUERY_BOT_DIED":          8,
		"QUERY_CANCELED":          9,
		"QUERY_ALL":               10,
		"QUERY_DEDUPED":           11,
		"QUERY_KILLED":            12,
		"QUERY_NO_RESOURCE":       13,
		"QUERY_CLIENT_ERROR":      14,
	}
)

Enum value maps for StateQuery.

View Source 
var (
	SortQuery_name = map[int32]string{
		0: "QUERY_CREATED_TS",
		2: "QUERY_COMPLETED_TS",
		3: "QUERY_ABANDONED_TS",
		4: "QUERY_STARTED_TS",
	}
	SortQuery_value = map[string]int32{
		"QUERY_CREATED_TS":   0,
		"QUERY_COMPLETED_TS": 2,
		"QUERY_ABANDONED_TS": 3,
		"QUERY_STARTED_TS":   4,
	}
)

Enum value maps for SortQuery.

View Source 
var (
	NullableBool_name = map[int32]string{
		0: "NULL",
		1: "FALSE",
		2: "TRUE",
	}
	NullableBool_value = map[string]int32{
		"NULL":  0,
		"FALSE": 1,
		"TRUE":  2,
	}
)

Enum value maps for NullableBool.

View Source 
var (
	TaskState_name = map[int32]string{
		0:   "INVALID",
		16:  "RUNNING",
		32:  "PENDING",
		48:  "EXPIRED",
		64:  "TIMED_OUT",
		80:  "BOT_DIED",
		96:  "CANCELED",
		112: "COMPLETED",
		128: "KILLED",
		256: "NO_RESOURCE",
		512: "CLIENT_ERROR",
	}
	TaskState_value = map[string]int32{
		"INVALID":      0,
		"RUNNING":      16,
		"PENDING":      32,
		"EXPIRED":      48,
		"TIMED_OUT":    64,
		"BOT_DIED":     80,
		"CANCELED":     96,
		"COMPLETED":    112,
		"KILLED":       128,
		"NO_RESOURCE":  256,
		"CLIENT_ERROR": 512,
	}
)

Enum value maps for TaskState.

View Source 
var (
	Containment_ContainmentType_name = map[int32]string{
		0: "NOT_SPECIFIED",
		1: "NONE",
		2: "AUTO",
		3: "JOB_OBJECT",
	}
	Containment_ContainmentType_value = map[string]int32{
		"NOT_SPECIFIED": 0,
		"NONE":          1,
		"AUTO":          2,
		"JOB_OBJECT":    3,
	}
)

Enum value maps for Containment_ContainmentType.

View Source 
var (
	NewTaskRequest_PoolTaskTemplateField_name = map[int32]string{
		0: "AUTO",
		1: "CANARY_PREFER",
		2: "CANARY_NEVER",
		3: "SKIP",
	}
	NewTaskRequest_PoolTaskTemplateField_value = map[string]int32{
		"AUTO":          0,
		"CANARY_PREFER": 1,
		"CANARY_NEVER":  2,
		"SKIP":          3,
	}
)

Enum value maps for NewTaskRequest_PoolTaskTemplateField.

View Source 
var Bots_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "swarming.v2.Bots",
	HandlerType: (*BotsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetBot",
			Handler:    _Bots_GetBot_Handler,
		},
		{
			MethodName: "DeleteBot",
			Handler:    _Bots_DeleteBot_Handler,
		},
		{
			MethodName: "ListBotEvents",
			Handler:    _Bots_ListBotEvents_Handler,
		},
		{
			MethodName: "TerminateBot",
			Handler:    _Bots_TerminateBot_Handler,
		},
		{
			MethodName: "ListBotTasks",
			Handler:    _Bots_ListBotTasks_Handler,
		},
		{
			MethodName: "ListBots",
			Handler:    _Bots_ListBots_Handler,
		},
		{
			MethodName: "CountBots",
			Handler:    _Bots_CountBots_Handler,
		},
		{
			MethodName: "GetBotDimensions",
			Handler:    _Bots_GetBotDimensions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go.chromium.org/luci/swarming/proto/api_v2/swarming.proto",
}

Bots_ServiceDesc is the grpc.ServiceDesc for Bots service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_go_chromium_org_luci_swarming_proto_api_v2_swarming_proto protoreflect.FileDescriptor
View Source 
var Swarming_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "swarming.v2.Swarming",
	HandlerType: (*SwarmingServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDetails",
			Handler:    _Swarming_GetDetails_Handler,
		},
		{
			MethodName: "GetToken",
			Handler:    _Swarming_GetToken_Handler,
		},
		{
			MethodName: "GetPermissions",
			Handler:    _Swarming_GetPermissions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go.chromium.org/luci/swarming/proto/api_v2/swarming.proto",
}

Swarming_ServiceDesc is the grpc.ServiceDesc for Swarming service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Tasks_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "swarming.v2.Tasks",
	HandlerType: (*TasksServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetResult",
			Handler:    _Tasks_GetResult_Handler,
		},
		{
			MethodName: "BatchGetResult",
			Handler:    _Tasks_BatchGetResult_Handler,
		},
		{
			MethodName: "GetRequest",
			Handler:    _Tasks_GetRequest_Handler,
		},
		{
			MethodName: "CancelTask",
			Handler:    _Tasks_CancelTask_Handler,
		},
		{
			MethodName: "GetStdout",
			Handler:    _Tasks_GetStdout_Handler,
		},
		{
			MethodName: "NewTask",
			Handler:    _Tasks_NewTask_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _Tasks_ListTasks_Handler,
		},
		{
			MethodName: "ListTaskStates",
			Handler:    _Tasks_ListTaskStates_Handler,
		},
		{
			MethodName: "ListTaskRequests",
			Handler:    _Tasks_ListTaskRequests_Handler,
		},
		{
			MethodName: "CancelTasks",
			Handler:    _Tasks_CancelTasks_Handler,
		},
		{
			MethodName: "CountTasks",
			Handler:    _Tasks_CountTasks_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "go.chromium.org/luci/swarming/proto/api_v2/swarming.proto",
}

Tasks_ServiceDesc is the grpc.ServiceDesc for Tasks service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func FileDescriptorSet 

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterBotsServer 

func RegisterBotsServer(s grpc.ServiceRegistrar, srv BotsServer)

func RegisterSwarmingServer 

func RegisterSwarmingServer(s grpc.ServiceRegistrar, srv SwarmingServer)

func RegisterTasksServer 

func RegisterTasksServer(s grpc.ServiceRegistrar, srv TasksServer)

Types

type BatchGetResultRequest 

type BatchGetResultRequest struct {

	// One or more task IDs (ending with '0'), must have no duplicates.
	TaskIds []string `protobuf:"bytes,1,rep,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	// If true, populate `performance_stats` in the output.
	IncludePerformanceStats bool `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BatchGetResultRequest) Descriptor deprecated 

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

Deprecated: Use BatchGetResultRequest.ProtoReflect.Descriptor instead.

func (*BatchGetResultRequest) GetIncludePerformanceStats 

func (x *BatchGetResultRequest) GetIncludePerformanceStats() bool

func (*BatchGetResultRequest) GetTaskIds 

func (x *BatchGetResultRequest) GetTaskIds() []string

func (*BatchGetResultRequest) ProtoMessage 

func (*BatchGetResultRequest) ProtoMessage()

func (*BatchGetResultRequest) ProtoReflect 

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

func (*BatchGetResultRequest) Reset 

func (x *BatchGetResultRequest) Reset()

func (*BatchGetResultRequest) String 

func (x *BatchGetResultRequest) String() string

type BatchGetResultResponse 

type BatchGetResultResponse struct {

	// Task results or errors, in the same order as `task_ids` in the request.
	Results []*BatchGetResultResponse_ResultOrError `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchGetResultResponse) Descriptor deprecated 

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

Deprecated: Use BatchGetResultResponse.ProtoReflect.Descriptor instead.

func (*BatchGetResultResponse) GetResults 

func (x *BatchGetResultResponse) GetResults() []*BatchGetResultResponse_ResultOrError

func (*BatchGetResultResponse) ProtoMessage 

func (*BatchGetResultResponse) ProtoMessage()

func (*BatchGetResultResponse) ProtoReflect 

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

func (*BatchGetResultResponse) Reset 

func (x *BatchGetResultResponse) Reset()

func (*BatchGetResultResponse) String 

func (x *BatchGetResultResponse) String() string

type BatchGetResultResponse_ResultOrError 

type BatchGetResultResponse_ResultOrError struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Types that are assignable to Outcome:
	//
	//	*BatchGetResultResponse_ResultOrError_Result
	//	*BatchGetResultResponse_ResultOrError_Error
	Outcome isBatchGetResultResponse_ResultOrError_Outcome `protobuf_oneof:"outcome"`
	// contains filtered or unexported fields
}

Outcome of fetching one task's result.

func (*BatchGetResultResponse_ResultOrError) Descriptor deprecated 

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

Deprecated: Use BatchGetResultResponse_ResultOrError.ProtoReflect.Descriptor instead.

func (*BatchGetResultResponse_ResultOrError) GetError 

func (x *BatchGetResultResponse_ResultOrError) GetError() *status.Status

func (*BatchGetResultResponse_ResultOrError) GetOutcome 

func (m *BatchGetResultResponse_ResultOrError) GetOutcome() isBatchGetResultResponse_ResultOrError_Outcome

func (*BatchGetResultResponse_ResultOrError) GetResult 

func (x *BatchGetResultResponse_ResultOrError) GetResult() *TaskResultResponse

func (*BatchGetResultResponse_ResultOrError) GetTaskId 

func (x *BatchGetResultResponse_ResultOrError) GetTaskId() string

func (*BatchGetResultResponse_ResultOrError) ProtoMessage 

func (*BatchGetResultResponse_ResultOrError) ProtoMessage()

func (*BatchGetResultResponse_ResultOrError) ProtoReflect 

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

func (*BatchGetResultResponse_ResultOrError) Reset 

func (x *BatchGetResultResponse_ResultOrError) Reset()

func (*BatchGetResultResponse_ResultOrError) String 

func (x *BatchGetResultResponse_ResultOrError) String() string

type BatchGetResultResponse_ResultOrError_Error 

type BatchGetResultResponse_ResultOrError_Error struct {
	Error *status.Status `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type BatchGetResultResponse_ResultOrError_Result 

type BatchGetResultResponse_ResultOrError_Result struct {
	Result *TaskResultResponse `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type BootstrapToken 

type BootstrapToken struct {
	BootstrapToken string `protobuf:"bytes,1,opt,name=bootstrap_token,json=bootstrapToken,proto3" json:"bootstrap_token,omitempty"`
	// contains filtered or unexported fields
}

An opaque token that can be used to bootstrap a new bot.

func (*BootstrapToken) Descriptor deprecated 

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

Deprecated: Use BootstrapToken.ProtoReflect.Descriptor instead.

func (*BootstrapToken) GetBootstrapToken 

func (x *BootstrapToken) GetBootstrapToken() string

func (*BootstrapToken) ProtoMessage 

func (*BootstrapToken) ProtoMessage()

func (*BootstrapToken) ProtoReflect 

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

func (*BootstrapToken) Reset 

func (x *BootstrapToken) Reset()

func (*BootstrapToken) String 

func (x *BootstrapToken) String() string

type BotEventResponse 

type BotEventResponse struct {

	// google.protobuf.Timestamp of this event.
	Ts *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=ts,proto3" json:"ts,omitempty"`
	// Type of event.
	EventType string `protobuf:"bytes,2,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	// Message included in the event.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Bot dimensions at that moment.
	Dimensions []*StringListPair `protobuf:"bytes,4,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Bot state at that moment, encoded as json.
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state,omitempty"`
	// IP address as seen by the HTTP handler.
	ExternalIp string `protobuf:"bytes,6,opt,name=external_ip,json=externalIp,proto3" json:"external_ip,omitempty"`
	// Bot identity as seen by the HTTP handler.
	AuthenticatedAs string `protobuf:"bytes,7,opt,name=authenticated_as,json=authenticatedAs,proto3" json:"authenticated_as,omitempty"`
	// Version of swarming_bot.zip the bot is currently running.
	Version string `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	// If True, the bot is not accepting task due to being quarantined.
	Quarantined bool `protobuf:"varint,9,opt,name=quarantined,proto3" json:"quarantined,omitempty"`
	// If set, the bot is rejecting tasks due to maintenance.
	MaintenanceMsg string `protobuf:"bytes,10,opt,name=maintenance_msg,json=maintenanceMsg,proto3" json:"maintenance_msg,omitempty"`
	// Affected by event_type == 'request_task', 'task_completed', 'task_error'.
	TaskId string `protobuf:"bytes,11,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// The bot session that reported this event.
	SessionId string `protobuf:"bytes,12,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BotEventResponse) Descriptor deprecated 

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

Deprecated: Use BotEventResponse.ProtoReflect.Descriptor instead.

func (*BotEventResponse) GetAuthenticatedAs 

func (x *BotEventResponse) GetAuthenticatedAs() string

func (*BotEventResponse) GetDimensions 

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

func (*BotEventResponse) GetEventType 

func (x *BotEventResponse) GetEventType() string

func (*BotEventResponse) GetExternalIp 

func (x *BotEventResponse) GetExternalIp() string

func (*BotEventResponse) GetMaintenanceMsg 

func (x *BotEventResponse) GetMaintenanceMsg() string

func (*BotEventResponse) GetMessage 

func (x *BotEventResponse) GetMessage() string

func (*BotEventResponse) GetQuarantined 

func (x *BotEventResponse) GetQuarantined() bool

func (*BotEventResponse) GetSessionId 

func (x *BotEventResponse) GetSessionId() string

func (*BotEventResponse) GetState 

func (x *BotEventResponse) GetState() string

func (*BotEventResponse) GetTaskId 

func (x *BotEventResponse) GetTaskId() string

func (*BotEventResponse) GetTs 

func (x *BotEventResponse) GetTs() *timestamppb.Timestamp

func (*BotEventResponse) GetVersion 

func (x *BotEventResponse) GetVersion() string

func (*BotEventResponse) ProtoMessage 

func (*BotEventResponse) ProtoMessage()

func (*BotEventResponse) ProtoReflect 

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

func (*BotEventResponse) Reset 

func (x *BotEventResponse) Reset()

func (*BotEventResponse) String 

func (x *BotEventResponse) String() string

type BotEventsRequest 

type BotEventsRequest struct {
	BotId  string                 `protobuf:"bytes,1,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	Limit  int32                  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Cursor string                 `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Start  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start,proto3" json:"start,omitempty"`
	End    *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*BotEventsRequest) Descriptor deprecated 

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

Deprecated: Use BotEventsRequest.ProtoReflect.Descriptor instead.

func (*BotEventsRequest) GetBotId 

func (x *BotEventsRequest) GetBotId() string

func (*BotEventsRequest) GetCursor 

func (x *BotEventsRequest) GetCursor() string

func (*BotEventsRequest) GetEnd 

func (x *BotEventsRequest) GetEnd() *timestamppb.Timestamp

func (*BotEventsRequest) GetLimit 

func (x *BotEventsRequest) GetLimit() int32

func (*BotEventsRequest) GetStart 

func (x *BotEventsRequest) GetStart() *timestamppb.Timestamp

func (*BotEventsRequest) ProtoMessage 

func (*BotEventsRequest) ProtoMessage()

func (*BotEventsRequest) ProtoReflect 

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

func (*BotEventsRequest) Reset 

func (x *BotEventsRequest) Reset()

func (*BotEventsRequest) String 

func (x *BotEventsRequest) String() string

type BotEventsResponse 

type BotEventsResponse struct {
	Cursor string                 `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Items  []*BotEventResponse    `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	Now    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

func (*BotEventsResponse) Descriptor deprecated 

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

Deprecated: Use BotEventsResponse.ProtoReflect.Descriptor instead.

func (*BotEventsResponse) GetCursor 

func (x *BotEventsResponse) GetCursor() string

func (*BotEventsResponse) GetItems 

func (x *BotEventsResponse) GetItems() []*BotEventResponse

func (*BotEventsResponse) GetNow 

func (x *BotEventsResponse) GetNow() *timestamppb.Timestamp

func (*BotEventsResponse) ProtoMessage 

func (*BotEventsResponse) ProtoMessage()

func (*BotEventsResponse) ProtoReflect 

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

func (*BotEventsResponse) Reset 

func (x *BotEventsResponse) Reset()

func (*BotEventsResponse) String 

func (x *BotEventsResponse) String() string

type BotInfo 

type BotInfo struct {
	BotId           string                 `protobuf:"bytes,1,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	TaskId          string                 `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ExternalIp      string                 `protobuf:"bytes,3,opt,name=external_ip,json=externalIp,proto3" json:"external_ip,omitempty"`
	AuthenticatedAs string                 `protobuf:"bytes,4,opt,name=authenticated_as,json=authenticatedAs,proto3" json:"authenticated_as,omitempty"`
	FirstSeenTs     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=first_seen_ts,json=firstSeenTs,proto3" json:"first_seen_ts,omitempty"`
	IsDead          bool                   `protobuf:"varint,6,opt,name=is_dead,json=isDead,proto3" json:"is_dead,omitempty"`
	LastSeenTs      *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_seen_ts,json=lastSeenTs,proto3" json:"last_seen_ts,omitempty"`
	Quarantined     bool                   `protobuf:"varint,8,opt,name=quarantined,proto3" json:"quarantined,omitempty"`
	MaintenanceMsg  string                 `protobuf:"bytes,9,opt,name=maintenance_msg,json=maintenanceMsg,proto3" json:"maintenance_msg,omitempty"`
	Dimensions      []*StringListPair      `protobuf:"bytes,10,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	TaskName        string                 `protobuf:"bytes,11,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Version         string                 `protobuf:"bytes,12,opt,name=version,proto3" json:"version,omitempty"`
	// Encoded as json since it's an arbitrary dict.
	State     string `protobuf:"bytes,13,opt,name=state,proto3" json:"state,omitempty"`
	Deleted   bool   `protobuf:"varint,14,opt,name=deleted,proto3" json:"deleted,omitempty"`
	SessionId string `protobuf:"bytes,15,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

Representation of the BotInfo ndb model.

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) GetBotId 

func (x *BotInfo) GetBotId() string

func (*BotInfo) GetDeleted 

func (x *BotInfo) GetDeleted() bool

func (*BotInfo) GetDimensions 

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

func (*BotInfo) GetExternalIp 

func (x *BotInfo) GetExternalIp() string

func (*BotInfo) GetFirstSeenTs 

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

func (*BotInfo) GetIsDead 

func (x *BotInfo) GetIsDead() bool

func (*BotInfo) GetLastSeenTs 

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

func (*BotInfo) GetMaintenanceMsg 

func (x *BotInfo) GetMaintenanceMsg() string

func (*BotInfo) GetQuarantined 

func (x *BotInfo) GetQuarantined() bool

func (*BotInfo) GetSessionId 

func (x *BotInfo) GetSessionId() string

func (*BotInfo) GetState 

func (x *BotInfo) GetState() string

func (*BotInfo) GetTaskId 

func (x *BotInfo) GetTaskId() string

func (*BotInfo) GetTaskName 

func (x *BotInfo) GetTaskName() 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 BotInfoListResponse 

type BotInfoListResponse struct {
	Cursor       string                 `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Items        []*BotInfo             `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	Now          *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=now,proto3" json:"now,omitempty"`
	DeathTimeout int32                  `protobuf:"varint,4,opt,name=death_timeout,json=deathTimeout,proto3" json:"death_timeout,omitempty"`
	// contains filtered or unexported fields
}

Wraps a list of BotInfo.

func (*BotInfoListResponse) Descriptor deprecated 

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

Deprecated: Use BotInfoListResponse.ProtoReflect.Descriptor instead.

func (*BotInfoListResponse) GetCursor 

func (x *BotInfoListResponse) GetCursor() string

func (*BotInfoListResponse) GetDeathTimeout 

func (x *BotInfoListResponse) GetDeathTimeout() int32

func (*BotInfoListResponse) GetItems 

func (x *BotInfoListResponse) GetItems() []*BotInfo

func (*BotInfoListResponse) GetNow 

func (x *BotInfoListResponse) GetNow() *timestamppb.Timestamp

func (*BotInfoListResponse) ProtoMessage 

func (*BotInfoListResponse) ProtoMessage()

func (*BotInfoListResponse) ProtoReflect 

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

func (*BotInfoListResponse) Reset 

func (x *BotInfoListResponse) Reset()

func (*BotInfoListResponse) String 

func (x *BotInfoListResponse) String() string

type BotRequest 

type BotRequest struct {
	BotId string `protobuf:"bytes,1,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BotRequest) Descriptor deprecated 

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

Deprecated: Use BotRequest.ProtoReflect.Descriptor instead.

func (*BotRequest) GetBotId 

func (x *BotRequest) GetBotId() string

func (*BotRequest) ProtoMessage 

func (*BotRequest) ProtoMessage()

func (*BotRequest) ProtoReflect 

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

func (*BotRequest) Reset 

func (x *BotRequest) Reset()

func (*BotRequest) String 

func (x *BotRequest) String() string

type BotTasksRequest 

type BotTasksRequest struct {
	BotId                   string                 `protobuf:"bytes,1,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	Limit                   int32                  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Cursor                  string                 `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Start                   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start,proto3" json:"start,omitempty"`
	End                     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end,proto3" json:"end,omitempty"`
	State                   StateQuery             `protobuf:"varint,6,opt,name=state,proto3,enum=swarming.v2.StateQuery" json:"state,omitempty"`
	Sort                    SortQuery              `protobuf:"varint,7,opt,name=sort,proto3,enum=swarming.v2.SortQuery" json:"sort,omitempty"`
	IncludePerformanceStats bool                   `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BotTasksRequest) Descriptor deprecated 

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

Deprecated: Use BotTasksRequest.ProtoReflect.Descriptor instead.

func (*BotTasksRequest) GetBotId 

func (x *BotTasksRequest) GetBotId() string

func (*BotTasksRequest) GetCursor 

func (x *BotTasksRequest) GetCursor() string

func (*BotTasksRequest) GetEnd 

func (x *BotTasksRequest) GetEnd() *timestamppb.Timestamp

func (*BotTasksRequest) GetIncludePerformanceStats 

func (x *BotTasksRequest) GetIncludePerformanceStats() bool

func (*BotTasksRequest) GetLimit 

func (x *BotTasksRequest) GetLimit() int32

func (*BotTasksRequest) GetSort 

func (x *BotTasksRequest) GetSort() SortQuery

func (*BotTasksRequest) GetStart 

func (x *BotTasksRequest) GetStart() *timestamppb.Timestamp

func (*BotTasksRequest) GetState 

func (x *BotTasksRequest) GetState() StateQuery

func (*BotTasksRequest) ProtoMessage 

func (*BotTasksRequest) ProtoMessage()

func (*BotTasksRequest) ProtoReflect 

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

func (*BotTasksRequest) Reset 

func (x *BotTasksRequest) Reset()

func (*BotTasksRequest) String 

func (x *BotTasksRequest) String() string

type BotsClient 

type BotsClient interface {
	// GetBot returns information on a single bot
	GetBot(ctx context.Context, in *BotRequest, opts ...grpc.CallOption) (*BotInfo, error)
	// DeleteBot makes Swarming forget about a single bot.
	//
	// This includes the event history, task history and current state (dimensions,
	// cache state, etc). Once deleted, Swarming will not send tasks to this bot.
	// A still running bot will fininsh executing its task and then not have any
	// further tasks queued on it.
	//
	// For non-GCE-Provider bots, this does not remove any data on the bot
	// machine itself, and if the bot is still running on that machine, it will
	// likely show up again in swarming shortly after calling this API.
	//
	// If this bot is managed with GCE Provider, the underlying VM will be recycled
	// and all data on that VM will be lost.
	//
	// If you wish to shut the bot down, call TerminateBot.
	DeleteBot(ctx context.Context, in *BotRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// ListBotEvents returns a section of the Events (limited in quantity, time range)
	// related to a single Bot.
	//
	// The bot in question must still be 'known' to Swarming.
	ListBotEvents(ctx context.Context, in *BotEventsRequest, opts ...grpc.CallOption) (*BotEventsResponse, error)
	// TerminateBot asks a bot to terminate itself gracefully.
	// The bot will stay in the DB, use 'delete' to remove it from the DB
	// afterward. This request returns a pseudo-taskid that can be waited for to
	// wait for the bot to turn down.
	// This command is particularly useful when a privileged user needs to safely
	// debug a machine specific issue. The user can trigger a terminate for one of
	// the bot exhibiting the issue, wait for the pseudo-task to run then access
	// the machine with the guarantee that the bot is not running anymore.
	TerminateBot(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
	// ListBotTasks returns a section of the Task history (limited in quantity, time
	// range) in the context of a single bot.
	//
	// The bot in question must still be 'known' to Swarming.
	ListBotTasks(ctx context.Context, in *BotTasksRequest, opts ...grpc.CallOption) (*TaskListResponse, error)
	// ListBots returns the state of a filtered (dimensions, state) list of known bots.
	ListBots(ctx context.Context, in *BotsRequest, opts ...grpc.CallOption) (*BotInfoListResponse, error)
	// CountBots returns the number of bots which match given set of filters.
	CountBots(ctx context.Context, in *BotsCountRequest, opts ...grpc.CallOption) (*BotsCount, error)
	// GetBotDimensions returns a list of known dimensions/values for bots currently
	// connected to a given pool.
	GetBotDimensions(ctx context.Context, in *BotsDimensionsRequest, opts ...grpc.CallOption) (*BotsDimensions, error)
}

BotsClient is the client API for Bots service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewBotsClient 

func NewBotsClient(cc grpc.ClientConnInterface) BotsClient

type BotsCount 

type BotsCount struct {
	Now         *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=now,proto3" json:"now,omitempty"`
	Count       int32                  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	Quarantined int32                  `protobuf:"varint,3,opt,name=quarantined,proto3" json:"quarantined,omitempty"`
	Maintenance int32                  `protobuf:"varint,4,opt,name=maintenance,proto3" json:"maintenance,omitempty"`
	Dead        int32                  `protobuf:"varint,5,opt,name=dead,proto3" json:"dead,omitempty"`
	Busy        int32                  `protobuf:"varint,6,opt,name=busy,proto3" json:"busy,omitempty"`
	// contains filtered or unexported fields
}

Returns the count, as requested.

func (*BotsCount) Descriptor deprecated 

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

Deprecated: Use BotsCount.ProtoReflect.Descriptor instead.

func (*BotsCount) GetBusy 

func (x *BotsCount) GetBusy() int32

func (*BotsCount) GetCount 

func (x *BotsCount) GetCount() int32

func (*BotsCount) GetDead 

func (x *BotsCount) GetDead() int32

func (*BotsCount) GetMaintenance 

func (x *BotsCount) GetMaintenance() int32

func (*BotsCount) GetNow 

func (x *BotsCount) GetNow() *timestamppb.Timestamp

func (*BotsCount) GetQuarantined 

func (x *BotsCount) GetQuarantined() int32

func (*BotsCount) ProtoMessage 

func (*BotsCount) ProtoMessage()

func (*BotsCount) ProtoReflect 

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

func (*BotsCount) Reset 

func (x *BotsCount) Reset()

func (*BotsCount) String 

func (x *BotsCount) String() string

type BotsCountRequest 

type BotsCountRequest struct {
	Dimensions []*StringPair `protobuf:"bytes,1,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// contains filtered or unexported fields
}

func (*BotsCountRequest) Descriptor deprecated 

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

Deprecated: Use BotsCountRequest.ProtoReflect.Descriptor instead.

func (*BotsCountRequest) GetDimensions 

func (x *BotsCountRequest) GetDimensions() []*StringPair

func (*BotsCountRequest) ProtoMessage 

func (*BotsCountRequest) ProtoMessage()

func (*BotsCountRequest) ProtoReflect 

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

func (*BotsCountRequest) Reset 

func (x *BotsCountRequest) Reset()

func (*BotsCountRequest) String 

func (x *BotsCountRequest) String() string

type BotsDimensions 

type BotsDimensions struct {
	BotsDimensions []*StringListPair `protobuf:"bytes,1,rep,name=bots_dimensions,json=botsDimensions,proto3" json:"bots_dimensions,omitempty"`
	// Time at which this summary was calculated.
	Ts *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

Returns all the dimensions and dimension possibilities in the fleet.

func (*BotsDimensions) Descriptor deprecated 

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

Deprecated: Use BotsDimensions.ProtoReflect.Descriptor instead.

func (*BotsDimensions) GetBotsDimensions 

func (x *BotsDimensions) GetBotsDimensions() []*StringListPair

func (*BotsDimensions) GetTs 

func (x *BotsDimensions) GetTs() *timestamppb.Timestamp

func (*BotsDimensions) ProtoMessage 

func (*BotsDimensions) ProtoMessage()

func (*BotsDimensions) ProtoReflect 

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

func (*BotsDimensions) Reset 

func (x *BotsDimensions) Reset()

func (*BotsDimensions) String 

func (x *BotsDimensions) String() string

type BotsDimensionsRequest 

type BotsDimensionsRequest struct {
	Pool string `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
	// contains filtered or unexported fields
}

func (*BotsDimensionsRequest) Descriptor deprecated 

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

Deprecated: Use BotsDimensionsRequest.ProtoReflect.Descriptor instead.

func (*BotsDimensionsRequest) GetPool 

func (x *BotsDimensionsRequest) GetPool() string

func (*BotsDimensionsRequest) ProtoMessage 

func (*BotsDimensionsRequest) ProtoMessage()

func (*BotsDimensionsRequest) ProtoReflect 

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

func (*BotsDimensionsRequest) Reset 

func (x *BotsDimensionsRequest) Reset()

func (*BotsDimensionsRequest) String 

func (x *BotsDimensionsRequest) String() string

type BotsRequest 

type BotsRequest struct {
	Limit         int32         `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Cursor        string        `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Dimensions    []*StringPair `protobuf:"bytes,3,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	Quarantined   NullableBool  `protobuf:"varint,4,opt,name=quarantined,proto3,enum=swarming.v2.NullableBool" json:"quarantined,omitempty"`
	InMaintenance NullableBool  `` /* 131-byte string literal not displayed */
	IsDead        NullableBool  `protobuf:"varint,6,opt,name=is_dead,json=isDead,proto3,enum=swarming.v2.NullableBool" json:"is_dead,omitempty"`
	IsBusy        NullableBool  `protobuf:"varint,7,opt,name=is_busy,json=isBusy,proto3,enum=swarming.v2.NullableBool" json:"is_busy,omitempty"`
	// contains filtered or unexported fields
}

func (*BotsRequest) Descriptor deprecated 

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

Deprecated: Use BotsRequest.ProtoReflect.Descriptor instead.

func (*BotsRequest) GetCursor 

func (x *BotsRequest) GetCursor() string

func (*BotsRequest) GetDimensions 

func (x *BotsRequest) GetDimensions() []*StringPair

func (*BotsRequest) GetInMaintenance 

func (x *BotsRequest) GetInMaintenance() NullableBool

func (*BotsRequest) GetIsBusy 

func (x *BotsRequest) GetIsBusy() NullableBool

func (*BotsRequest) GetIsDead 

func (x *BotsRequest) GetIsDead() NullableBool

func (*BotsRequest) GetLimit 

func (x *BotsRequest) GetLimit() int32

func (*BotsRequest) GetQuarantined 

func (x *BotsRequest) GetQuarantined() NullableBool

func (*BotsRequest) ProtoMessage 

func (*BotsRequest) ProtoMessage()

func (*BotsRequest) ProtoReflect 

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

func (*BotsRequest) Reset 

func (x *BotsRequest) Reset()

func (*BotsRequest) String 

func (x *BotsRequest) String() string

type BotsServer 

type BotsServer interface {
	// GetBot returns information on a single bot
	GetBot(context.Context, *BotRequest) (*BotInfo, error)
	// DeleteBot makes Swarming forget about a single bot.
	//
	// This includes the event history, task history and current state (dimensions,
	// cache state, etc). Once deleted, Swarming will not send tasks to this bot.
	// A still running bot will fininsh executing its task and then not have any
	// further tasks queued on it.
	//
	// For non-GCE-Provider bots, this does not remove any data on the bot
	// machine itself, and if the bot is still running on that machine, it will
	// likely show up again in swarming shortly after calling this API.
	//
	// If this bot is managed with GCE Provider, the underlying VM will be recycled
	// and all data on that VM will be lost.
	//
	// If you wish to shut the bot down, call TerminateBot.
	DeleteBot(context.Context, *BotRequest) (*DeleteResponse, error)
	// ListBotEvents returns a section of the Events (limited in quantity, time range)
	// related to a single Bot.
	//
	// The bot in question must still be 'known' to Swarming.
	ListBotEvents(context.Context, *BotEventsRequest) (*BotEventsResponse, error)
	// TerminateBot asks a bot to terminate itself gracefully.
	// The bot will stay in the DB, use 'delete' to remove it from the DB
	// afterward. This request returns a pseudo-taskid that can be waited for to
	// wait for the bot to turn down.
	// This command is particularly useful when a privileged user needs to safely
	// debug a machine specific issue. The user can trigger a terminate for one of
	// the bot exhibiting the issue, wait for the pseudo-task to run then access
	// the machine with the guarantee that the bot is not running anymore.
	TerminateBot(context.Context, *TerminateRequest) (*TerminateResponse, error)
	// ListBotTasks returns a section of the Task history (limited in quantity, time
	// range) in the context of a single bot.
	//
	// The bot in question must still be 'known' to Swarming.
	ListBotTasks(context.Context, *BotTasksRequest) (*TaskListResponse, error)
	// ListBots returns the state of a filtered (dimensions, state) list of known bots.
	ListBots(context.Context, *BotsRequest) (*BotInfoListResponse, error)
	// CountBots returns the number of bots which match given set of filters.
	CountBots(context.Context, *BotsCountRequest) (*BotsCount, error)
	// GetBotDimensions returns a list of known dimensions/values for bots currently
	// connected to a given pool.
	GetBotDimensions(context.Context, *BotsDimensionsRequest) (*BotsDimensions, error)
	// contains filtered or unexported methods
}

BotsServer is the server API for Bots service. All implementations must embed UnimplementedBotsServer for forward compatibility.

type CASOperationStats 

type CASOperationStats struct {

	// Duration in seconds.
	Duration           float32 `protobuf:"fixed32,1,opt,name=duration,proto3" json:"duration,omitempty"`
	InitialNumberItems int32   `protobuf:"varint,2,opt,name=initial_number_items,json=initialNumberItems,proto3" json:"initial_number_items,omitempty"`
	InitialSize        int64   `protobuf:"varint,3,opt,name=initial_size,json=initialSize,proto3" json:"initial_size,omitempty"`
	// These buffers are compressed as deflate'd delta-encoded varints. They are
	// all the items for an isolated operation, which can scale in the 100k range.
	// So can be large! See //client/utils/large.py for the code to handle these.
	ItemsCold []byte `protobuf:"bytes,4,opt,name=items_cold,json=itemsCold,proto3" json:"items_cold,omitempty"`
	ItemsHot  []byte `protobuf:"bytes,5,opt,name=items_hot,json=itemsHot,proto3" json:"items_hot,omitempty"`
	// Corresponding summaries; for each list above, sum of the number of files
	// and the sum bytes of the files.
	NumItemsCold        int64 `protobuf:"varint,6,opt,name=num_items_cold,json=numItemsCold,proto3" json:"num_items_cold,omitempty"`
	TotalBytesItemsCold int64 `protobuf:"varint,7,opt,name=total_bytes_items_cold,json=totalBytesItemsCold,proto3" json:"total_bytes_items_cold,omitempty"`
	NumItemsHot         int64 `protobuf:"varint,8,opt,name=num_items_hot,json=numItemsHot,proto3" json:"num_items_hot,omitempty"`
	TotalBytesItemsHot  int64 `protobuf:"varint,9,opt,name=total_bytes_items_hot,json=totalBytesItemsHot,proto3" json:"total_bytes_items_hot,omitempty"`
	// contains filtered or unexported fields
}

func (*CASOperationStats) Descriptor deprecated 

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

Deprecated: Use CASOperationStats.ProtoReflect.Descriptor instead.

func (*CASOperationStats) GetDuration 

func (x *CASOperationStats) GetDuration() float32

func (*CASOperationStats) GetInitialNumberItems 

func (x *CASOperationStats) GetInitialNumberItems() int32

func (*CASOperationStats) GetInitialSize 

func (x *CASOperationStats) GetInitialSize() int64

func (*CASOperationStats) GetItemsCold 

func (x *CASOperationStats) GetItemsCold() []byte

func (*CASOperationStats) GetItemsHot 

func (x *CASOperationStats) GetItemsHot() []byte

func (*CASOperationStats) GetNumItemsCold 

func (x *CASOperationStats) GetNumItemsCold() int64

func (*CASOperationStats) GetNumItemsHot 

func (x *CASOperationStats) GetNumItemsHot() int64

func (*CASOperationStats) GetTotalBytesItemsCold 

func (x *CASOperationStats) GetTotalBytesItemsCold() int64

func (*CASOperationStats) GetTotalBytesItemsHot 

func (x *CASOperationStats) GetTotalBytesItemsHot() int64

func (*CASOperationStats) ProtoMessage 

func (*CASOperationStats) ProtoMessage()

func (*CASOperationStats) ProtoReflect 

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

func (*CASOperationStats) Reset 

func (x *CASOperationStats) Reset()

func (*CASOperationStats) String 

func (x *CASOperationStats) String() string

type CASReference 

type CASReference struct {

	// Full name of RBE-CAS instance. `projects/{project_id}/instances/{instance}`.
	// e.g. projects/chromium-swarm/instances/default_instance
	CasInstance string `protobuf:"bytes,1,opt,name=cas_instance,json=casInstance,proto3" json:"cas_instance,omitempty"`
	// CAS Digest consists of hash and size bytes.
	Digest *Digest `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	// contains filtered or unexported fields
}

func (*CASReference) Descriptor deprecated 

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

Deprecated: Use CASReference.ProtoReflect.Descriptor instead.

func (*CASReference) GetCasInstance 

func (x *CASReference) GetCasInstance() string

func (*CASReference) GetDigest 

func (x *CASReference) GetDigest() *Digest

func (*CASReference) ProtoMessage 

func (*CASReference) ProtoMessage()

func (*CASReference) ProtoReflect 

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

func (*CASReference) Reset 

func (x *CASReference) Reset()

func (*CASReference) String 

func (x *CASReference) String() string

type CacheEntry 

type CacheEntry struct {

	// Unique name of the cache. Required. Length is limited to 4096.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Relative path to the directory that will be linked to the named cache.
	// Required.
	// 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.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

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

A CacheEntry in a task specified that the task prefers the cache to be present on the bot. A symlink to the cache directory is created at <run_dir>/|path|. If cache is not present on the machine, the directory is empty. If the tasks makes any changes to the contents of the cache directory, they are persisted on the machine. If another task runs on the same machine and requests the same named cache, even if mapped to a different path, it will see the changes.

func (*CacheEntry) Descriptor deprecated 

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

Deprecated: Use CacheEntry.ProtoReflect.Descriptor instead.

func (*CacheEntry) GetName 

func (x *CacheEntry) GetName() string

func (*CacheEntry) GetPath 

func (x *CacheEntry) GetPath() string

func (*CacheEntry) ProtoMessage 

func (*CacheEntry) ProtoMessage()

func (*CacheEntry) ProtoReflect 

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

func (*CacheEntry) Reset 

func (x *CacheEntry) Reset()

func (*CacheEntry) String 

func (x *CacheEntry) String() string

type CancelResponse 

type CancelResponse struct {

	// True if the cancellation succeeded. Either the task atomically changed
	// from PENDING to CANCELED or it was RUNNING and killing bit has been set.
	Canceled bool `protobuf:"varint,1,opt,name=canceled,proto3" json:"canceled,omitempty"`
	// True if the task was running while it was canceled.
	WasRunning bool `protobuf:"varint,2,opt,name=was_running,json=wasRunning,proto3" json:"was_running,omitempty"`
	// contains filtered or unexported fields
}

Result of a request to cancel a task.

func (*CancelResponse) Descriptor deprecated 

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

Deprecated: Use CancelResponse.ProtoReflect.Descriptor instead.

func (*CancelResponse) GetCanceled 

func (x *CancelResponse) GetCanceled() bool

func (*CancelResponse) GetWasRunning 

func (x *CancelResponse) GetWasRunning() bool

func (*CancelResponse) ProtoMessage 

func (*CancelResponse) ProtoMessage()

func (*CancelResponse) ProtoReflect 

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

func (*CancelResponse) Reset 

func (x *CancelResponse) Reset()

func (*CancelResponse) String 

func (x *CancelResponse) String() string

type CipdInput 

type CipdInput struct {

	// URL of the CIPD server. Must start with "https://" or "http://".
	// This field or its subfields are optional if default cipd client is defined
	// in the server config.
	Server string `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	// CIPD package of CIPD client to use.
	// client_package.version is required.
	// This field is optional is default value is defined in the server config.
	// client_package.path must be empty.
	ClientPackage *CipdPackage `protobuf:"bytes,2,opt,name=client_package,json=clientPackage,proto3" json:"client_package,omitempty"`
	// List of CIPD packages to install.
	Packages []*CipdPackage `protobuf:"bytes,3,rep,name=packages,proto3" json:"packages,omitempty"`
	// contains filtered or unexported fields
}

Defines CIPD packages to install in task run directory.

func (*CipdInput) Descriptor deprecated 

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

Deprecated: Use CipdInput.ProtoReflect.Descriptor instead.

func (*CipdInput) GetClientPackage 

func (x *CipdInput) GetClientPackage() *CipdPackage

func (*CipdInput) GetPackages 

func (x *CipdInput) GetPackages() []*CipdPackage

func (*CipdInput) GetServer 

func (x *CipdInput) GetServer() string

func (*CipdInput) ProtoMessage 

func (*CipdInput) ProtoMessage()

func (*CipdInput) ProtoReflect 

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

func (*CipdInput) Reset 

func (x *CipdInput) Reset()

func (*CipdInput) String 

func (x *CipdInput) String() string

type CipdPackage 

type CipdPackage struct {

	// A CIPD package to install in the run dir before task execution."""
	// A template of a full CIPD package name, e.g.
	// "infra/tools/authutil/${platform}"
	// See also cipd.ALL_PARAMS.
	PackageName string `protobuf:"bytes,1,opt,name=package_name,json=packageName,proto3" json:"package_name,omitempty"`
	// Valid package version for all packages matched by package name.
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Path to dir, relative to the root dir, where to install the package.
	// If empty, the package will be installed a the root of the mapped directory.
	// If file names in the package and in the isolate clash, it will cause a
	// failure.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*CipdPackage) Descriptor deprecated 

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

Deprecated: Use CipdPackage.ProtoReflect.Descriptor instead.

func (*CipdPackage) GetPackageName 

func (x *CipdPackage) GetPackageName() string

func (*CipdPackage) GetPath 

func (x *CipdPackage) GetPath() 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 CipdPins 

type CipdPins struct {

	// The pinned package + version of the CIPD client that was actually used.
	ClientPackage *CipdPackage `protobuf:"bytes,1,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,2,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) 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 ClientPermissions 

type ClientPermissions struct {

	// True if allowed to delete the specified bot.
	DeleteBot bool `protobuf:"varint,1,opt,name=delete_bot,json=deleteBot,proto3" json:"delete_bot,omitempty"`
	// True if allowed to delete bots in all specified pools.
	DeleteBots bool `protobuf:"varint,2,opt,name=delete_bots,json=deleteBots,proto3" json:"delete_bots,omitempty"`
	// True if allowed to terminate the specified bot.
	TerminateBot bool `protobuf:"varint,3,opt,name=terminate_bot,json=terminateBot,proto3" json:"terminate_bot,omitempty"`
	// Not used, always false.
	//
	// Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.
	GetConfigs bool `protobuf:"varint,4,opt,name=get_configs,json=getConfigs,proto3" json:"get_configs,omitempty"`
	// Not used, always false.
	//
	// Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.
	PutConfigs bool `protobuf:"varint,5,opt,name=put_configs,json=putConfigs,proto3" json:"put_configs,omitempty"`
	// True if allowed to cancel the specified task.
	CancelTask bool `protobuf:"varint,6,opt,name=cancel_task,json=cancelTask,proto3" json:"cancel_task,omitempty"`
	// True if allowed to request a bot bootstrap token.
	GetBootstrapToken bool `protobuf:"varint,7,opt,name=get_bootstrap_token,json=getBootstrapToken,proto3" json:"get_bootstrap_token,omitempty"`
	// True if allowed to cancel tasks in all specified pools.
	CancelTasks bool `protobuf:"varint,8,opt,name=cancel_tasks,json=cancelTasks,proto3" json:"cancel_tasks,omitempty"`
	// All known pools in which the caller is permitted to list all bots.
	ListBots []string `protobuf:"bytes,9,rep,name=list_bots,json=listBots,proto3" json:"list_bots,omitempty"`
	// All known pools in which the caller is permitted to list all tasks.
	ListTasks []string `protobuf:"bytes,10,rep,name=list_tasks,json=listTasks,proto3" json:"list_tasks,omitempty"`
	// contains filtered or unexported fields
}

Actions the caller is permitted to perform over a resource.

The subject of an action is either a bot, a task or a bunch of pools, as specified in the PermissionsRequest message. Pools as specified indirectly via "pool:<name>" tags.

This methods exists primarily to be used by the Web UI e.g. to hide inaccessible elements.

func (*ClientPermissions) Descriptor deprecated 

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

Deprecated: Use ClientPermissions.ProtoReflect.Descriptor instead.

func (*ClientPermissions) GetCancelTask 

func (x *ClientPermissions) GetCancelTask() bool

func (*ClientPermissions) GetCancelTasks 

func (x *ClientPermissions) GetCancelTasks() bool

func (*ClientPermissions) GetDeleteBot 

func (x *ClientPermissions) GetDeleteBot() bool

func (*ClientPermissions) GetDeleteBots 

func (x *ClientPermissions) GetDeleteBots() bool

func (*ClientPermissions) GetGetBootstrapToken 

func (x *ClientPermissions) GetGetBootstrapToken() bool

func (*ClientPermissions) GetGetConfigs deprecated 

func (x *ClientPermissions) GetGetConfigs() bool

Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.

func (*ClientPermissions) GetListBots 

func (x *ClientPermissions) GetListBots() []string

func (*ClientPermissions) GetListTasks 

func (x *ClientPermissions) GetListTasks() []string

func (*ClientPermissions) GetPutConfigs deprecated 

func (x *ClientPermissions) GetPutConfigs() bool

Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.

func (*ClientPermissions) GetTerminateBot 

func (x *ClientPermissions) GetTerminateBot() bool

func (*ClientPermissions) ProtoMessage 

func (*ClientPermissions) ProtoMessage()

func (*ClientPermissions) ProtoReflect 

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

func (*ClientPermissions) Reset 

func (x *ClientPermissions) Reset()

func (*ClientPermissions) String 

func (x *ClientPermissions) String() string

type Containment 

type Containment struct {

	// Lowers the priority of the task process when started. Doesn't require
	// containment. This gives the bot a chance to survive when the task starts an
	// overwhelming number of children processes.
	LowerPriority bool `protobuf:"varint,1,opt,name=lower_priority,json=lowerPriority,proto3" json:"lower_priority,omitempty"`
	// Defines the type of containment used.
	ContainmentType Containment_ContainmentType `` /* 152-byte string literal not displayed */
	// Limits the number of concurrent active processes.
	LimitProcesses int64 `protobuf:"varint,3,opt,name=limit_processes,json=limitProcesses,proto3" json:"limit_processes,omitempty"`
	// Limits the total amount of memory allocated by processes.
	LimitTotalCommittedMemory int64 `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

Defines the type of "sandbox" to run the task process in.

Unimplemented.

func (*Containment) Descriptor deprecated 

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

Deprecated: Use Containment.ProtoReflect.Descriptor instead.

func (*Containment) GetContainmentType 

func (x *Containment) GetContainmentType() Containment_ContainmentType

func (*Containment) GetLimitProcesses 

func (x *Containment) GetLimitProcesses() int64

func (*Containment) GetLimitTotalCommittedMemory 

func (x *Containment) GetLimitTotalCommittedMemory() int64

func (*Containment) GetLowerPriority 

func (x *Containment) GetLowerPriority() bool

func (*Containment) ProtoMessage 

func (*Containment) ProtoMessage()

func (*Containment) ProtoReflect 

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

func (*Containment) Reset 

func (x *Containment) Reset()

func (*Containment) String 

func (x *Containment) String() string

type Containment_ContainmentType 

type Containment_ContainmentType int32
const (
	// Historical value, not specified. Containment may or may not be used.
	Containment_NOT_SPECIFIED Containment_ContainmentType = 0
	// No containment, the default for now.
	Containment_NONE Containment_ContainmentType = 1
	// Use the containment appropriate on the platform.
	Containment_AUTO Containment_ContainmentType = 2
	// Use Job Object on Windows. Will fail if used on other platforms.
	Containment_JOB_OBJECT Containment_ContainmentType = 3
)

func (Containment_ContainmentType) Descriptor 

func (Containment_ContainmentType) Descriptor() protoreflect.EnumDescriptor

func (Containment_ContainmentType) Enum 

func (x Containment_ContainmentType) Enum() *Containment_ContainmentType

func (Containment_ContainmentType) EnumDescriptor deprecated 

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

Deprecated: Use Containment_ContainmentType.Descriptor instead.

func (Containment_ContainmentType) Number 

func (x Containment_ContainmentType) Number() protoreflect.EnumNumber

func (Containment_ContainmentType) String 

func (x Containment_ContainmentType) String() string

func (Containment_ContainmentType) Type 

func (Containment_ContainmentType) Type() protoreflect.EnumType

type DeleteResponse 

type DeleteResponse struct {
	Deleted bool `protobuf:"varint,1,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

Indicates whether a bot was deleted.

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetDeleted 

func (x *DeleteResponse) GetDeleted() bool

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type Digest 

type Digest struct {
	Hash      string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	SizeBytes int64  `protobuf:"varint,2,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"`
	// contains filtered or unexported fields
}

This is a Digest[build.bazel.remote.execution.v2.Digest] of a blob on RBE-CAS. See the explanations at the original definition. pylint: disable=line-too-long https://github.com/bazelbuild/remote-apis/blob/77cfb44a88577a7ade5dd2400425f6d50469ec6d/build/bazel/remote/execution/v2/remote_execution.proto#L753-L791

func (*Digest) Descriptor deprecated 

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

Deprecated: Use Digest.ProtoReflect.Descriptor instead.

func (*Digest) GetHash 

func (x *Digest) GetHash() string

func (*Digest) GetSizeBytes 

func (x *Digest) GetSizeBytes() int64

func (*Digest) ProtoMessage 

func (*Digest) ProtoMessage()

func (*Digest) ProtoReflect 

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

func (*Digest) Reset 

func (x *Digest) Reset()

func (*Digest) String 

func (x *Digest) String() string

type NewTaskRequest 

type NewTaskRequest struct {

	// DEPRECATED. Use task_slices[0].expiration_secs.
	ExpirationSecs int32 `protobuf:"varint,1,opt,name=expiration_secs,json=expirationSecs,proto3" json:"expiration_secs,omitempty"`
	// Task name for display purpose.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Parent Swarming run ID of the process requesting this task. This is to tell
	// the server about reentrancy: when a task creates children Swarming tasks, so
	// that the tree of tasks can be presented in the UI; the parent task will list
	// all the children tasks that were triggered.
	ParentTaskId string `protobuf:"bytes,3,opt,name=parent_task_id,json=parentTaskId,proto3" json:"parent_task_id,omitempty"`
	// Task priority, the lower the more important.
	Priority int32 `protobuf:"varint,4,opt,name=priority,proto3" json:"priority,omitempty"`
	// DEPRECATED. Use task_slices[0].properties.
	Properties *TaskProperties `protobuf:"bytes,5,opt,name=properties,proto3" json:"properties,omitempty"`
	// Slice of TaskSlice, along their scheduling parameters. Cannot be used at the
	// same time as properties and expiration_secs.
	//
	// This defines all the various possible task execution for a task request to
	// be run on the Swarming infrastructure. They are processed in order, and it
	// is guaranteed that at most one of these will be processed.
	TaskSlices []*TaskSlice `protobuf:"bytes,6,rep,name=task_slices,json=taskSlices,proto3" json:"task_slices,omitempty"`
	// Tags are 'key:value' strings that describes what the task is about. This can
	// later be leveraged to search for kinds of tasks per tag.
	Tags []string `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	// User on which behalf this task is run, if relevant. Not validated.
	User string `protobuf:"bytes,8,opt,name=user,proto3" json:"user,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). If this is unsuitable
	// use 'idempotent=False' or include a service account name in properties
	// separately.
	ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Full topic name to post task state updates to, e.g.
	// "projects/<id>/topics/<id>".
	PubsubTopic string `protobuf:"bytes,10,opt,name=pubsub_topic,json=pubsubTopic,proto3" json:"pubsub_topic,omitempty"`
	// Secret string to put into "auth_token" attribute of PubSub message.
	PubsubAuthToken string `protobuf:"bytes,11,opt,name=pubsub_auth_token,json=pubsubAuthToken,proto3" json:"pubsub_auth_token,omitempty"`
	// Will be but into "userdata" fields of PubSub message.
	PubsubUserdata string `protobuf:"bytes,12,opt,name=pubsub_userdata,json=pubsubUserdata,proto3" json:"pubsub_userdata,omitempty"`
	// Only evaluate the task, as if we were going to schedule it, but don't
	// actually schedule it. This will return the TaskRequest, but without
	// a task_id.
	EvaluateOnly     bool                                 `protobuf:"varint,13,opt,name=evaluate_only,json=evaluateOnly,proto3" json:"evaluate_only,omitempty"`
	PoolTaskTemplate NewTaskRequest_PoolTaskTemplateField `` /* 167-byte string literal not displayed */
	// Maximum delay between bot pings before the bot is considered dead
	// while running a task.
	BotPingToleranceSecs int32 `` /* 127-byte string literal not displayed */
	// This is used to make new task request idempotent in best effort.
	// If new request has request_uuid field, it checks memcache before scheduling
	// actual task to check there is already the task triggered by same request
	// previously.
	RequestUuid string `protobuf:"bytes,16,opt,name=request_uuid,json=requestUuid,proto3" json:"request_uuid,omitempty"`
	// Configuration of Swarming:ResultDB integration.
	Resultdb *ResultDBCfg `protobuf:"bytes,17,opt,name=resultdb,proto3" json:"resultdb,omitempty"`
	// Task realm.
	// See api/swarming.proto for more details.
	Realm string `protobuf:"bytes,18,opt,name=realm,proto3" json:"realm,omitempty"`
	// contains filtered or unexported fields
}

Description of a new task request as described by the client. This message is used to create a new task.

func (*NewTaskRequest) Descriptor deprecated 

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

Deprecated: Use NewTaskRequest.ProtoReflect.Descriptor instead.

func (*NewTaskRequest) GetBotPingToleranceSecs 

func (x *NewTaskRequest) GetBotPingToleranceSecs() int32

func (*NewTaskRequest) GetEvaluateOnly 

func (x *NewTaskRequest) GetEvaluateOnly() bool

func (*NewTaskRequest) GetExpirationSecs 

func (x *NewTaskRequest) GetExpirationSecs() int32

func (*NewTaskRequest) GetName 

func (x *NewTaskRequest) GetName() string

func (*NewTaskRequest) GetParentTaskId 

func (x *NewTaskRequest) GetParentTaskId() string

func (*NewTaskRequest) GetPoolTaskTemplate 

func (x *NewTaskRequest) GetPoolTaskTemplate() NewTaskRequest_PoolTaskTemplateField

func (*NewTaskRequest) GetPriority 

func (x *NewTaskRequest) GetPriority() int32

func (*NewTaskRequest) GetProperties 

func (x *NewTaskRequest) GetProperties() *TaskProperties

func (*NewTaskRequest) GetPubsubAuthToken 

func (x *NewTaskRequest) GetPubsubAuthToken() string

func (*NewTaskRequest) GetPubsubTopic 

func (x *NewTaskRequest) GetPubsubTopic() string

func (*NewTaskRequest) GetPubsubUserdata 

func (x *NewTaskRequest) GetPubsubUserdata() string

func (*NewTaskRequest) GetRealm 

func (x *NewTaskRequest) GetRealm() string

func (*NewTaskRequest) GetRequestUuid 

func (x *NewTaskRequest) GetRequestUuid() string

func (*NewTaskRequest) GetResultdb 

func (x *NewTaskRequest) GetResultdb() *ResultDBCfg

func (*NewTaskRequest) GetServiceAccount 

func (x *NewTaskRequest) GetServiceAccount() string

func (*NewTaskRequest) GetTags 

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

func (*NewTaskRequest) GetTaskSlices 

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

func (*NewTaskRequest) GetUser 

func (x *NewTaskRequest) GetUser() string

func (*NewTaskRequest) ProtoMessage 

func (*NewTaskRequest) ProtoMessage()

func (*NewTaskRequest) ProtoReflect 

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

func (*NewTaskRequest) Reset 

func (x *NewTaskRequest) Reset()

func (*NewTaskRequest) String 

func (x *NewTaskRequest) String() string

type NewTaskRequest_PoolTaskTemplateField 

type NewTaskRequest_PoolTaskTemplateField int32

Controls the application of the pool's TaskTemplate to the creation of this task. By default this will automatically select the pool's preference for template, but you can also instruct swarming to prefer/prevent the application of canary templates, as well as skipping the template altogether. 

const (
	NewTaskRequest_AUTO          NewTaskRequest_PoolTaskTemplateField = 0
	NewTaskRequest_CANARY_PREFER NewTaskRequest_PoolTaskTemplateField = 1
	NewTaskRequest_CANARY_NEVER  NewTaskRequest_PoolTaskTemplateField = 2
	NewTaskRequest_SKIP          NewTaskRequest_PoolTaskTemplateField = 3
)

func (NewTaskRequest_PoolTaskTemplateField) Descriptor 

func (NewTaskRequest_PoolTaskTemplateField) Descriptor() protoreflect.EnumDescriptor

func (NewTaskRequest_PoolTaskTemplateField) Enum 

func (x NewTaskRequest_PoolTaskTemplateField) Enum() *NewTaskRequest_PoolTaskTemplateField

func (NewTaskRequest_PoolTaskTemplateField) EnumDescriptor deprecated 

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

Deprecated: Use NewTaskRequest_PoolTaskTemplateField.Descriptor instead.

func (NewTaskRequest_PoolTaskTemplateField) Number 

func (x NewTaskRequest_PoolTaskTemplateField) Number() protoreflect.EnumNumber

func (NewTaskRequest_PoolTaskTemplateField) String 

func (x NewTaskRequest_PoolTaskTemplateField) String() string

func (NewTaskRequest_PoolTaskTemplateField) Type 

func (NewTaskRequest_PoolTaskTemplateField) Type() protoreflect.EnumType

type NullableBool 

type NullableBool int32
const (
	NullableBool_NULL  NullableBool = 0
	NullableBool_FALSE NullableBool = 1
	NullableBool_TRUE  NullableBool = 2
)

func (NullableBool) Descriptor 

func (NullableBool) Descriptor() protoreflect.EnumDescriptor

func (NullableBool) Enum 

func (x NullableBool) Enum() *NullableBool

func (NullableBool) EnumDescriptor deprecated 

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

Deprecated: Use NullableBool.Descriptor instead.

func (NullableBool) Number 

func (x NullableBool) Number() protoreflect.EnumNumber

func (NullableBool) String 

func (x NullableBool) String() string

func (NullableBool) Type 

func (NullableBool) Type() protoreflect.EnumType

type OperationStats 

type OperationStats struct {

	// Duration in seconds.
	Duration float32 `protobuf:"fixed32,1,opt,name=duration,proto3" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationStats) Descriptor deprecated 

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

Deprecated: Use OperationStats.ProtoReflect.Descriptor instead.

func (*OperationStats) GetDuration 

func (x *OperationStats) GetDuration() float32

func (*OperationStats) ProtoMessage 

func (*OperationStats) ProtoMessage()

func (*OperationStats) ProtoReflect 

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

func (*OperationStats) Reset 

func (x *OperationStats) Reset()

func (*OperationStats) String 

func (x *OperationStats) String() string

type PerformanceStats 

type PerformanceStats struct {
	BotOverhead          float32            `protobuf:"fixed32,1,opt,name=bot_overhead,json=botOverhead,proto3" json:"bot_overhead,omitempty"`
	IsolatedDownload     *CASOperationStats `protobuf:"bytes,2,opt,name=isolated_download,json=isolatedDownload,proto3" json:"isolated_download,omitempty"`
	IsolatedUpload       *CASOperationStats `protobuf:"bytes,3,opt,name=isolated_upload,json=isolatedUpload,proto3" json:"isolated_upload,omitempty"`
	PackageInstallation  *OperationStats    `protobuf:"bytes,4,opt,name=package_installation,json=packageInstallation,proto3" json:"package_installation,omitempty"`
	CacheTrim            *OperationStats    `protobuf:"bytes,5,opt,name=cache_trim,json=cacheTrim,proto3" json:"cache_trim,omitempty"`
	NamedCachesInstall   *OperationStats    `protobuf:"bytes,6,opt,name=named_caches_install,json=namedCachesInstall,proto3" json:"named_caches_install,omitempty"`
	NamedCachesUninstall *OperationStats    `protobuf:"bytes,7,opt,name=named_caches_uninstall,json=namedCachesUninstall,proto3" json:"named_caches_uninstall,omitempty"`
	Cleanup              *OperationStats    `protobuf:"bytes,8,opt,name=cleanup,proto3" json:"cleanup,omitempty"`
	// contains filtered or unexported fields
}

Performance stats of task execution. See task_result.PerformanceStats for details.

func (*PerformanceStats) Descriptor deprecated 

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

Deprecated: Use PerformanceStats.ProtoReflect.Descriptor instead.

func (*PerformanceStats) GetBotOverhead 

func (x *PerformanceStats) GetBotOverhead() float32

func (*PerformanceStats) GetCacheTrim 

func (x *PerformanceStats) GetCacheTrim() *OperationStats

func (*PerformanceStats) GetCleanup 

func (x *PerformanceStats) GetCleanup() *OperationStats

func (*PerformanceStats) GetIsolatedDownload 

func (x *PerformanceStats) GetIsolatedDownload() *CASOperationStats

func (*PerformanceStats) GetIsolatedUpload 

func (x *PerformanceStats) GetIsolatedUpload() *CASOperationStats

func (*PerformanceStats) GetNamedCachesInstall 

func (x *PerformanceStats) GetNamedCachesInstall() *OperationStats

func (*PerformanceStats) GetNamedCachesUninstall 

func (x *PerformanceStats) GetNamedCachesUninstall() *OperationStats

func (*PerformanceStats) GetPackageInstallation 

func (x *PerformanceStats) GetPackageInstallation() *OperationStats

func (*PerformanceStats) ProtoMessage 

func (*PerformanceStats) ProtoMessage()

func (*PerformanceStats) ProtoReflect 

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

func (*PerformanceStats) Reset 

func (x *PerformanceStats) Reset()

func (*PerformanceStats) String 

func (x *PerformanceStats) String() string

type PermissionsRequest 

type PermissionsRequest struct {
	BotId  string   `protobuf:"bytes,1,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	TaskId string   `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Tags   []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*PermissionsRequest) Descriptor deprecated 

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

Deprecated: Use PermissionsRequest.ProtoReflect.Descriptor instead.

func (*PermissionsRequest) GetBotId 

func (x *PermissionsRequest) GetBotId() string

func (*PermissionsRequest) GetTags 

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

func (*PermissionsRequest) GetTaskId 

func (x *PermissionsRequest) GetTaskId() string

func (*PermissionsRequest) ProtoMessage 

func (*PermissionsRequest) ProtoMessage()

func (*PermissionsRequest) ProtoReflect 

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

func (*PermissionsRequest) Reset 

func (x *PermissionsRequest) Reset()

func (*PermissionsRequest) String 

func (x *PermissionsRequest) String() string

type ResultDBCfg 

type ResultDBCfg struct {

	// If True and this task is not deduplicated, create
	// "task-{swarming_hostname}-{run_id}" invocation for this task,
	// provide its update token to the task subprocess via LUCI_CONTEXT
	// and finalize the invocation when the task is done.
	// If the task is deduplicated, then TaskResult.invocation_name will be the
	// invocation name of the original task.
	// Swarming:ResultDB integration is off by default, but it may change in the
	// future.
	Enable bool `protobuf:"varint,1,opt,name=enable,proto3" json:"enable,omitempty"`
	// contains filtered or unexported fields
}

Swarming:ResultDB integration configuration for a task. See NewTaskRequest.resultdb for more details.

func (*ResultDBCfg) Descriptor deprecated 

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

Deprecated: Use ResultDBCfg.ProtoReflect.Descriptor instead.

func (*ResultDBCfg) GetEnable 

func (x *ResultDBCfg) GetEnable() bool

func (*ResultDBCfg) ProtoMessage 

func (*ResultDBCfg) ProtoMessage()

func (*ResultDBCfg) ProtoReflect 

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

func (*ResultDBCfg) Reset 

func (x *ResultDBCfg) Reset()

func (*ResultDBCfg) String 

func (x *ResultDBCfg) String() string

type ResultDBInfo 

type ResultDBInfo struct {

	// ResultDB hostname, e.g. "results.api.cr.dev"
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Name of the task's ResultDB invocation.
	//
	// For example "invocations/task-chromium-swarm.appspot.com-deadbeef1".
	// Unset if Swarming:ResultDB integration was not enabled for this task.
	//
	// If the task was deduplicated, this equals invocation name of the original
	// task.
	Invocation string `protobuf:"bytes,2,opt,name=invocation,proto3" json:"invocation,omitempty"`
	// contains filtered or unexported fields
}

ResultDB properties of a completed task.

func (*ResultDBInfo) Descriptor deprecated 

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

Deprecated: Use ResultDBInfo.ProtoReflect.Descriptor instead.

func (*ResultDBInfo) GetHostname 

func (x *ResultDBInfo) GetHostname() string

func (*ResultDBInfo) GetInvocation 

func (x *ResultDBInfo) GetInvocation() string

func (*ResultDBInfo) ProtoMessage 

func (*ResultDBInfo) ProtoMessage()

func (*ResultDBInfo) ProtoReflect 

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

func (*ResultDBInfo) Reset 

func (x *ResultDBInfo) Reset()

func (*ResultDBInfo) String 

func (x *ResultDBInfo) String() string

type ServerDetails 

type ServerDetails struct {
	ServerVersion string `protobuf:"bytes,1,opt,name=server_version,json=serverVersion,proto3" json:"server_version,omitempty"`
	BotVersion    string `protobuf:"bytes,2,opt,name=bot_version,json=botVersion,proto3" json:"bot_version,omitempty"`
	// Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.
	MachineProviderTemplate  string `` /* 132-byte string literal not displayed */
	DisplayServerUrlTemplate string `` /* 137-byte string literal not displayed */
	// Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.
	LuciConfig      string `protobuf:"bytes,5,opt,name=luci_config,json=luciConfig,proto3" json:"luci_config,omitempty"`
	CasViewerServer string `protobuf:"bytes,6,opt,name=cas_viewer_server,json=casViewerServer,proto3" json:"cas_viewer_server,omitempty"`
	// contains filtered or unexported fields
}

Public details about the server.

func (*ServerDetails) Descriptor deprecated 

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

Deprecated: Use ServerDetails.ProtoReflect.Descriptor instead.

func (*ServerDetails) GetBotVersion 

func (x *ServerDetails) GetBotVersion() string

func (*ServerDetails) GetCasViewerServer 

func (x *ServerDetails) GetCasViewerServer() string

func (*ServerDetails) GetDisplayServerUrlTemplate 

func (x *ServerDetails) GetDisplayServerUrlTemplate() string

func (*ServerDetails) GetLuciConfig deprecated 

func (x *ServerDetails) GetLuciConfig() string

Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.

func (*ServerDetails) GetMachineProviderTemplate deprecated 

func (x *ServerDetails) GetMachineProviderTemplate() string

Deprecated: Marked as deprecated in go.chromium.org/luci/swarming/proto/api_v2/swarming.proto.

func (*ServerDetails) GetServerVersion 

func (x *ServerDetails) GetServerVersion() string

func (*ServerDetails) ProtoMessage 

func (*ServerDetails) ProtoMessage()

func (*ServerDetails) ProtoReflect 

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

func (*ServerDetails) Reset 

func (x *ServerDetails) Reset()

func (*ServerDetails) String 

func (x *ServerDetails) String() string

type SortQuery 

type SortQuery int32

Flag to sort returned tasks. The natural sort is CREATED_TS. 

const (
	SortQuery_QUERY_CREATED_TS   SortQuery = 0
	SortQuery_QUERY_COMPLETED_TS SortQuery = 2
	SortQuery_QUERY_ABANDONED_TS SortQuery = 3
	SortQuery_QUERY_STARTED_TS   SortQuery = 4
)

func (SortQuery) Descriptor 

func (SortQuery) Descriptor() protoreflect.EnumDescriptor

func (SortQuery) Enum 

func (x SortQuery) Enum() *SortQuery

func (SortQuery) EnumDescriptor deprecated 

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

Deprecated: Use SortQuery.Descriptor instead.

func (SortQuery) Number 

func (x SortQuery) Number() protoreflect.EnumNumber

func (SortQuery) String 

func (x SortQuery) String() string

func (SortQuery) Type 

func (SortQuery) Type() protoreflect.EnumType

type StateQuery 

type StateQuery int32

Use one of the values in this enum to query for tasks in one of the specified state.

Use 'ALL' to not use any filtering based on task state.

As an example, this enum enables querying for all tasks with state COMPLETED but non-zero exit code via COMPLETED_FAILURE.

Do not confuse StateQuery and TaskState. StateQuery is to query tasks via the API. TaskState is the current task state. 

const (
	// Query for all tasks currently TaskState.PENDING.
	StateQuery_QUERY_PENDING StateQuery = 0
	// Query for all tasks currently TaskState.RUNNING. This includes tasks
	// currently in the overhead phase; mapping input files or archiving outputs
	// back to the server.
	StateQuery_QUERY_RUNNING StateQuery = 1
	// Query for all tasks currently TaskState.PENDING or TaskState.RUNNING. This
	// is the query for the 'active' tasks.
	StateQuery_QUERY_PENDING_RUNNING StateQuery = 2
	// Query for all tasks that completed normally as TaskState.COMPLETED,
	// independent of the process exit code.
	StateQuery_QUERY_COMPLETED StateQuery = 3
	// Query for all tasks that completed normally as TaskState.COMPLETED and that
	// had exit code 0.
	StateQuery_QUERY_COMPLETED_SUCCESS StateQuery = 4
	// Query for all tasks that completed normally as TaskState.COMPLETED and that
	// had exit code not 0.
	StateQuery_QUERY_COMPLETED_FAILURE StateQuery = 5
	// Query for all tasks that are TaskState.EXPIRED.
	StateQuery_QUERY_EXPIRED StateQuery = 6
	// Query for all tasks that are TaskState.TIMED_OUT.
	StateQuery_QUERY_TIMED_OUT StateQuery = 7
	// Query for all tasks that are TaskState.BOT_DIED.
	StateQuery_QUERY_BOT_DIED StateQuery = 8
	// Query for all tasks that are TaskState.CANCELED.
	StateQuery_QUERY_CANCELED StateQuery = 9
	// Query for all tasks, independent of the task state.
	//
	// In hindsight, this constant should have been the value 0. Sorry, the
	// original author was young and foolish.
	StateQuery_QUERY_ALL StateQuery = 10
	// Query for all tasks that are TaskState.COMPLETED but that actually didn't
	// run due to TaskProperties.idempotent being True *and* that a previous task
	// with the exact same TaskProperties had successfully run before, aka
	// COMPLETED_SUCCESS.
	StateQuery_QUERY_DEDUPED StateQuery = 11
	// Query for all tasks that are TaskState.KILLED.
	StateQuery_QUERY_KILLED StateQuery = 12
	// Query for all tasks that are TaskState.NO_RESOURCE.
	StateQuery_QUERY_NO_RESOURCE StateQuery = 13
	// Query for all tasks that are TaskState.CLIENT_ERROR.
	StateQuery_QUERY_CLIENT_ERROR StateQuery = 14
)

func (StateQuery) Descriptor 

func (StateQuery) Descriptor() protoreflect.EnumDescriptor

func (StateQuery) Enum 

func (x StateQuery) Enum() *StateQuery

func (StateQuery) EnumDescriptor deprecated 

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

Deprecated: Use StateQuery.Descriptor instead.

func (StateQuery) Number 

func (x StateQuery) Number() protoreflect.EnumNumber

func (StateQuery) String 

func (x StateQuery) String() string

func (StateQuery) Type 

func (StateQuery) Type() protoreflect.EnumType

type StringListPair 

type StringListPair struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// All the values for this key. values must be sorted. Human readable.
	//
	// This string should make sense to a user in the context of 'key'.
	Value []string `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Represents a mapping of string to a list of strings.

If the StringListPair is itself repeated inside another message, the list must be sorted by key and the keys must be unique.

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) GetValue 

func (x *StringListPair) GetValue() []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 string to a string.

If the StringPair is itself repeated inside another message, the list must be sorted by key and the keys must be unique.

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 SwarmingClient 

type SwarmingClient interface {
	// GetDetails returns public information about the Swarming instance.
	GetDetails(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServerDetails, error)
	// GetToken returns a token to bootstrap a new bot.
	GetToken(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*BootstrapToken, error)
	// GetPermissions returns the caller's permissions.
	GetPermissions(ctx context.Context, in *PermissionsRequest, opts ...grpc.CallOption) (*ClientPermissions, error)
}

SwarmingClient is the client API for Swarming service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSwarmingClient 

func NewSwarmingClient(cc grpc.ClientConnInterface) SwarmingClient

type SwarmingServer 

type SwarmingServer interface {
	// GetDetails returns public information about the Swarming instance.
	GetDetails(context.Context, *emptypb.Empty) (*ServerDetails, error)
	// GetToken returns a token to bootstrap a new bot.
	GetToken(context.Context, *emptypb.Empty) (*BootstrapToken, error)
	// GetPermissions returns the caller's permissions.
	GetPermissions(context.Context, *PermissionsRequest) (*ClientPermissions, error)
	// contains filtered or unexported methods
}

SwarmingServer is the server API for Swarming service. All implementations must embed UnimplementedSwarmingServer for forward compatibility.

type SwarmingTaskBackendConfig 

type SwarmingTaskBackendConfig struct {

	// Task priority, the lower the more important.
	//
	// Valid values are between 1 and 255.
	Priority int32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	// Maximum delay (in seconds) between bot pings before the bot is considered
	// dead while running a task.
	//
	// When a task is running, the bot sends update to the server every
	// few seconds. In some cases, like when the system is overloaded,
	// the bot may be preempted and delayed in sending its updates.
	// After the delay specified here, the server will claim the bot to
	// be dead and will forcibly abort the task as BOT_DIED. This is to
	// catch system wide issues like a BSOD.
	BotPingTolerance int64 `protobuf:"varint,2,opt,name=bot_ping_tolerance,json=botPingTolerance,proto3" json:"bot_ping_tolerance,omitempty"`
	// Parent Swarming task run ID of the process requesting this task.
	//
	// This field is set on the children tasks when a Swarming task creates
	// children Swarming tasks.
	//
	// This points to the TaskResult.run_id (ending with '1', '2' or more).
	ParentRunId string `protobuf:"bytes,3,opt,name=parent_run_id,json=parentRunId,proto3" json:"parent_run_id,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). If this is
	// unsuitable use 'idempotent=False' or include a service account name in
	// properties separately.
	ServiceAccount string `protobuf:"bytes,4,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// When a task is scheduled and there are currently no bots available to run
	// the task, the TaskSlice can either be PENDING, or be denied immediately.
	// When denied, the next TaskSlice is enqueued, and if there's no following
	// TaskSlice, the task state is set to NO_RESOURCE. This should normally be
	// set to False to avoid unnecessary waiting.
	WaitForCapacity bool `protobuf:"varint,5,opt,name=wait_for_capacity,json=waitForCapacity,proto3" json:"wait_for_capacity,omitempty"`
	// CIPD package of the agent binary that should be called to run the task
	// command. Note that it will end with "${platform}"
	AgentBinaryCipdPkg string `protobuf:"bytes,6,opt,name=agent_binary_cipd_pkg,json=agentBinaryCipdPkg,proto3" json:"agent_binary_cipd_pkg,omitempty"`
	// CIPD package tag or ref of the agent binary.
	AgentBinaryCipdVers string `protobuf:"bytes,7,opt,name=agent_binary_cipd_vers,json=agentBinaryCipdVers,proto3" json:"agent_binary_cipd_vers,omitempty"`
	// Name of the file within the CIPD package and should be used to construct
	// the task command line.
	AgentBinaryCipdFilename string `` /* 134-byte string literal not displayed */
	// Name of the CIPD server.
	AgentBinaryCipdServer string `` /* 128-byte string literal not displayed */
	// Tags are 'key:value' strings that describes what the task is about.
	// This can later be leveraged to search for kinds of tasks per tag.
	Tags []string `protobuf:"bytes,10,rep,name=tags,proto3" json:"tags,omitempty"`
	// Customized name of the task.
	TaskName string `protobuf:"bytes,11,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SwarmingTaskBackendConfig) Descriptor deprecated 

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

Deprecated: Use SwarmingTaskBackendConfig.ProtoReflect.Descriptor instead.

func (*SwarmingTaskBackendConfig) GetAgentBinaryCipdFilename 

func (x *SwarmingTaskBackendConfig) GetAgentBinaryCipdFilename() string

func (*SwarmingTaskBackendConfig) GetAgentBinaryCipdPkg 

func (x *SwarmingTaskBackendConfig) GetAgentBinaryCipdPkg() string

func (*SwarmingTaskBackendConfig) GetAgentBinaryCipdServer 

func (x *SwarmingTaskBackendConfig) GetAgentBinaryCipdServer() string

func (*SwarmingTaskBackendConfig) GetAgentBinaryCipdVers 

func (x *SwarmingTaskBackendConfig) GetAgentBinaryCipdVers() string

func (*SwarmingTaskBackendConfig) GetBotPingTolerance 

func (x *SwarmingTaskBackendConfig) GetBotPingTolerance() int64

func (*SwarmingTaskBackendConfig) GetParentRunId 

func (x *SwarmingTaskBackendConfig) GetParentRunId() string

func (*SwarmingTaskBackendConfig) GetPriority 

func (x *SwarmingTaskBackendConfig) GetPriority() int32

func (*SwarmingTaskBackendConfig) GetServiceAccount 

func (x *SwarmingTaskBackendConfig) GetServiceAccount() string

func (*SwarmingTaskBackendConfig) GetTags 

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

func (*SwarmingTaskBackendConfig) GetTaskName 

func (x *SwarmingTaskBackendConfig) GetTaskName() string

func (*SwarmingTaskBackendConfig) GetWaitForCapacity 

func (x *SwarmingTaskBackendConfig) GetWaitForCapacity() bool

func (*SwarmingTaskBackendConfig) ProtoMessage 

func (*SwarmingTaskBackendConfig) ProtoMessage()

func (*SwarmingTaskBackendConfig) ProtoReflect 

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

func (*SwarmingTaskBackendConfig) Reset 

func (x *SwarmingTaskBackendConfig) Reset()

func (*SwarmingTaskBackendConfig) String 

func (x *SwarmingTaskBackendConfig) String() string

type TaskCancelRequest 

type TaskCancelRequest struct {
	TaskId      string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	KillRunning bool   `protobuf:"varint,2,opt,name=kill_running,json=killRunning,proto3" json:"kill_running,omitempty"`
	// contains filtered or unexported fields
}

Request to cancel one task.

func (*TaskCancelRequest) Descriptor deprecated 

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

Deprecated: Use TaskCancelRequest.ProtoReflect.Descriptor instead.

func (*TaskCancelRequest) GetKillRunning 

func (x *TaskCancelRequest) GetKillRunning() bool

func (*TaskCancelRequest) GetTaskId 

func (x *TaskCancelRequest) GetTaskId() string

func (*TaskCancelRequest) ProtoMessage 

func (*TaskCancelRequest) ProtoMessage()

func (*TaskCancelRequest) ProtoReflect 

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

func (*TaskCancelRequest) Reset 

func (x *TaskCancelRequest) Reset()

func (*TaskCancelRequest) String 

func (x *TaskCancelRequest) String() string

type TaskIdRequest 

type TaskIdRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskIdRequest) Descriptor deprecated 

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

Deprecated: Use TaskIdRequest.ProtoReflect.Descriptor instead.

func (*TaskIdRequest) GetTaskId 

func (x *TaskIdRequest) GetTaskId() string

func (*TaskIdRequest) ProtoMessage 

func (*TaskIdRequest) ProtoMessage()

func (*TaskIdRequest) ProtoReflect 

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

func (*TaskIdRequest) Reset 

func (x *TaskIdRequest) Reset()

func (*TaskIdRequest) String 

func (x *TaskIdRequest) String() string

type TaskIdWithOffsetRequest 

type TaskIdWithOffsetRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Length int64  `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskIdWithOffsetRequest) Descriptor deprecated 

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

Deprecated: Use TaskIdWithOffsetRequest.ProtoReflect.Descriptor instead.

func (*TaskIdWithOffsetRequest) GetLength 

func (x *TaskIdWithOffsetRequest) GetLength() int64

func (*TaskIdWithOffsetRequest) GetOffset 

func (x *TaskIdWithOffsetRequest) GetOffset() int64

func (*TaskIdWithOffsetRequest) GetTaskId 

func (x *TaskIdWithOffsetRequest) GetTaskId() string

func (*TaskIdWithOffsetRequest) ProtoMessage 

func (*TaskIdWithOffsetRequest) ProtoMessage()

func (*TaskIdWithOffsetRequest) ProtoReflect 

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

func (*TaskIdWithOffsetRequest) Reset 

func (x *TaskIdWithOffsetRequest) Reset()

func (*TaskIdWithOffsetRequest) String 

func (x *TaskIdWithOffsetRequest) String() string

type TaskIdWithPerfRequest 

type TaskIdWithPerfRequest struct {
	TaskId                  string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	IncludePerformanceStats bool   `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TaskIdWithPerfRequest) Descriptor deprecated 

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

Deprecated: Use TaskIdWithPerfRequest.ProtoReflect.Descriptor instead.

func (*TaskIdWithPerfRequest) GetIncludePerformanceStats 

func (x *TaskIdWithPerfRequest) GetIncludePerformanceStats() bool

func (*TaskIdWithPerfRequest) GetTaskId 

func (x *TaskIdWithPerfRequest) GetTaskId() string

func (*TaskIdWithPerfRequest) ProtoMessage 

func (*TaskIdWithPerfRequest) ProtoMessage()

func (*TaskIdWithPerfRequest) ProtoReflect 

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

func (*TaskIdWithPerfRequest) Reset 

func (x *TaskIdWithPerfRequest) Reset()

func (*TaskIdWithPerfRequest) String 

func (x *TaskIdWithPerfRequest) String() string

type TaskListResponse 

type TaskListResponse struct {
	Cursor string                 `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Items  []*TaskResultResponse  `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	Now    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

Wraps a list of TaskResult.

func (*TaskListResponse) Descriptor deprecated 

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

Deprecated: Use TaskListResponse.ProtoReflect.Descriptor instead.

func (*TaskListResponse) GetCursor 

func (x *TaskListResponse) GetCursor() string

func (*TaskListResponse) GetItems 

func (x *TaskListResponse) GetItems() []*TaskResultResponse

func (*TaskListResponse) GetNow 

func (x *TaskListResponse) GetNow() *timestamppb.Timestamp

func (*TaskListResponse) ProtoMessage 

func (*TaskListResponse) ProtoMessage()

func (*TaskListResponse) ProtoReflect 

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

func (*TaskListResponse) Reset 

func (x *TaskListResponse) Reset()

func (*TaskListResponse) String 

func (x *TaskListResponse) String() string

type TaskOutputResponse 

type TaskOutputResponse struct {
	Output []byte `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// Current state of the task (e.g. PENDING, RUNNING, COMPLETED, EXPIRED, etc).
	State TaskState `protobuf:"varint,2,opt,name=state,proto3,enum=swarming.v2.TaskState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

A task's output as a bytestring

func (*TaskOutputResponse) Descriptor deprecated 

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

Deprecated: Use TaskOutputResponse.ProtoReflect.Descriptor instead.

func (*TaskOutputResponse) GetOutput 

func (x *TaskOutputResponse) GetOutput() []byte

func (*TaskOutputResponse) GetState 

func (x *TaskOutputResponse) GetState() TaskState

func (*TaskOutputResponse) ProtoMessage 

func (*TaskOutputResponse) ProtoMessage()

func (*TaskOutputResponse) ProtoReflect 

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

func (*TaskOutputResponse) Reset 

func (x *TaskOutputResponse) Reset()

func (*TaskOutputResponse) String 

func (x *TaskOutputResponse) String() string

type TaskProperties 

type TaskProperties struct {

	// Specifies named caches to map into the working directory. These caches
	// outlives the task, which can then be reused by tasks later used on this bot
	// that request the same named cache.
	Caches []*CacheEntry `protobuf:"bytes,1,rep,name=caches,proto3" json:"caches,omitempty"`
	// CIPD packages to install. These packages are meant to be software that is
	// needed (a dependency) to the task being run. Unlike isolated files, the CIPD
	// packages do not expire from the server.
	CipdInput *CipdInput `protobuf:"bytes,2,opt,name=cipd_input,json=cipdInput,proto3" json:"cipd_input,omitempty"`
	// Command to run. This has priority over a command specified in the isolated
	// files.
	Command []string `protobuf:"bytes,3,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,4,opt,name=relative_cwd,json=relativeCwd,proto3" json:"relative_cwd,omitempty"`
	// Dimensions are what is used to determine which bot can run the task. The
	// bot must have all the matching dimensions, even for repeated keys with
	// multiple different values. It is a logical AND, all values must match.
	//
	// It should have been a StringListPair but this would be a breaking change.
	Dimensions []*StringPair `protobuf:"bytes,5,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Environment variables to set when running the task.
	Env []*StringPair `protobuf:"bytes,6,rep,name=env,proto3" json:"env,omitempty"`
	// Swarming-root relative paths to prepend to a given environment variable.
	//
	// These allow you to put certain subdirectories of the task into 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 (i.e. `;` on windows, `:` on POSIX).
	//
	// Each envvar can have multiple paths to prepend. They will be prepended in
	// the order seen here.
	//
	// For example, if env_prefixes was:
	//
	//	[("PATH", ["foo", "bar"]),
	//	 ("CUSTOMPATH", ["custom"])]
	//
	// The task would see:
	//
	//	PATH=/path/to/swarming/rundir/foo:/path/to/swarming/rundir/bar:$PATH
	//	CUSTOMPATH=/path/to/swarming/rundir/custom
	//
	// The path should always be specified here with forward-slashes, and it must
	// not attempt to escape the swarming root (i.e. must not contain `..`).
	//
	// These are applied AFTER evaluating `env` entries.
	EnvPrefixes []*StringListPair `protobuf:"bytes,7,rep,name=env_prefixes,json=envPrefixes,proto3" json:"env_prefixes,omitempty"`
	// Maximum number of seconds the task can run before its process is forcibly
	// terminated and the task results in TIMED_OUT.
	ExecutionTimeoutSecs int32 `protobuf:"varint,8,opt,name=execution_timeout_secs,json=executionTimeoutSecs,proto3" json:"execution_timeout_secs,omitempty"`
	// Number of second to give the child process after a SIGTERM before sending a
	// SIGKILL. See doc/Bot.md#timeout-handling
	GracePeriodSecs int32 `protobuf:"varint,9,opt,name=grace_period_secs,json=gracePeriodSecs,proto3" json:"grace_period_secs,omitempty"`
	// True if the task does not access any service through the network and is
	// believed to be 100% reproducible with the same outcome. In the case of a
	// successful task, previous results will be reused if possible.
	Idempotent bool `protobuf:"varint,10,opt,name=idempotent,proto3" json:"idempotent,omitempty"`
	// Digest of the input root uploaded to RBE-CAS.
	// This MUST be digest of [build.bazel.remote.execution.v2.Directory].
	CasInputRoot *CASReference `protobuf:"bytes,11,opt,name=cas_input_root,json=casInputRoot,proto3" json:"cas_input_root,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.
	IoTimeoutSecs int32 `protobuf:"varint,12,opt,name=io_timeout_secs,json=ioTimeoutSecs,proto3" json:"io_timeout_secs,omitempty"`
	// Paths in the working directory to archive back.
	Outputs []string `protobuf:"bytes,13,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// Secret bytes to provide to the task. Cannot be retrieved back.
	SecretBytes []byte `protobuf:"bytes,14,opt,name=secret_bytes,json=secretBytes,proto3" json:"secret_bytes,omitempty"`
	// Containment of the task processes.
	Containment *Containment `protobuf:"bytes,15,opt,name=containment,proto3" json:"containment,omitempty"`
	// contains filtered or unexported fields
}

Important metadata about a particular task.

func (*TaskProperties) Descriptor deprecated 

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

Deprecated: Use TaskProperties.ProtoReflect.Descriptor instead.

func (*TaskProperties) GetCaches 

func (x *TaskProperties) GetCaches() []*CacheEntry

func (*TaskProperties) GetCasInputRoot 

func (x *TaskProperties) GetCasInputRoot() *CASReference

func (*TaskProperties) GetCipdInput 

func (x *TaskProperties) GetCipdInput() *CipdInput

func (*TaskProperties) GetCommand 

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

func (*TaskProperties) GetContainment 

func (x *TaskProperties) GetContainment() *Containment

func (*TaskProperties) GetDimensions 

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

func (*TaskProperties) GetEnv 

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

func (*TaskProperties) GetEnvPrefixes 

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

func (*TaskProperties) GetExecutionTimeoutSecs 

func (x *TaskProperties) GetExecutionTimeoutSecs() int32

func (*TaskProperties) GetGracePeriodSecs 

func (x *TaskProperties) GetGracePeriodSecs() int32

func (*TaskProperties) GetIdempotent 

func (x *TaskProperties) GetIdempotent() bool

func (*TaskProperties) GetIoTimeoutSecs 

func (x *TaskProperties) GetIoTimeoutSecs() int32

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) 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 TaskRequestMetadataResponse 

type TaskRequestMetadataResponse struct {
	TaskId  string               `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Request *TaskRequestResponse `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	// Set to finished task result in case task was deduplicated.
	TaskResult *TaskResultResponse `protobuf:"bytes,3,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
	// contains filtered or unexported fields
}

Provides the ID of the requested TaskRequest.

func (*TaskRequestMetadataResponse) Descriptor deprecated 

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

Deprecated: Use TaskRequestMetadataResponse.ProtoReflect.Descriptor instead.

func (*TaskRequestMetadataResponse) GetRequest 

func (x *TaskRequestMetadataResponse) GetRequest() *TaskRequestResponse

func (*TaskRequestMetadataResponse) GetTaskId 

func (x *TaskRequestMetadataResponse) GetTaskId() string

func (*TaskRequestMetadataResponse) GetTaskResult 

func (x *TaskRequestMetadataResponse) GetTaskResult() *TaskResultResponse

func (*TaskRequestMetadataResponse) ProtoMessage 

func (*TaskRequestMetadataResponse) ProtoMessage()

func (*TaskRequestMetadataResponse) ProtoReflect 

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

func (*TaskRequestMetadataResponse) Reset 

func (x *TaskRequestMetadataResponse) Reset()

func (*TaskRequestMetadataResponse) String 

func (x *TaskRequestMetadataResponse) String() string

type TaskRequestResponse 

type TaskRequestResponse struct {
	TaskId         string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ExpirationSecs int32  `protobuf:"varint,2,opt,name=expiration_secs,json=expirationSecs,proto3" json:"expiration_secs,omitempty"`
	Name           string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ParentTaskId   string `protobuf:"bytes,4,opt,name=parent_task_id,json=parentTaskId,proto3" json:"parent_task_id,omitempty"`
	Priority       int32  `protobuf:"varint,5,opt,name=priority,proto3" json:"priority,omitempty"`
	// For some amount of time, the properties will be copied into the
	// task_slices and vice-versa, to give time to the clients to update.
	// Eventually, only task_slices will be supported.
	Properties *TaskProperties        `protobuf:"bytes,6,opt,name=properties,proto3" json:"properties,omitempty"`
	Tags       []string               `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	CreatedTs  *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"`
	User       string                 `protobuf:"bytes,9,opt,name=user,proto3" json:"user,omitempty"`
	// User name of whoever posted this task, extracted from the credentials.
	Authenticated string       `protobuf:"bytes,10,opt,name=authenticated,proto3" json:"authenticated,omitempty"`
	TaskSlices    []*TaskSlice `protobuf:"bytes,11,rep,name=task_slices,json=taskSlices,proto3" json:"task_slices,omitempty"`
	// Indicates what OAuth2 credentials the task uses when calling other services.
	ServiceAccount string `protobuf:"bytes,12,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	Realm          string `protobuf:"bytes,13,opt,name=realm,proto3" json:"realm,omitempty"`
	// Configuration of Swarming:ResultDB integration.
	Resultdb             *ResultDBCfg `protobuf:"bytes,14,opt,name=resultdb,proto3" json:"resultdb,omitempty"`
	PubsubTopic          string       `protobuf:"bytes,15,opt,name=pubsub_topic,json=pubsubTopic,proto3" json:"pubsub_topic,omitempty"`
	PubsubUserdata       string       `protobuf:"bytes,16,opt,name=pubsub_userdata,json=pubsubUserdata,proto3" json:"pubsub_userdata,omitempty"`
	BotPingToleranceSecs int32        `` /* 127-byte string literal not displayed */
	RbeInstance          string       `protobuf:"bytes,18,opt,name=rbe_instance,json=rbeInstance,proto3" json:"rbe_instance,omitempty"`
	// contains filtered or unexported fields
}

Description of a task request as registered by the server. This message is used when retrieving information about an existing task. See NewTaskRequest for more details.

func (*TaskRequestResponse) Descriptor deprecated 

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

Deprecated: Use TaskRequestResponse.ProtoReflect.Descriptor instead.

func (*TaskRequestResponse) GetAuthenticated 

func (x *TaskRequestResponse) GetAuthenticated() string

func (*TaskRequestResponse) GetBotPingToleranceSecs 

func (x *TaskRequestResponse) GetBotPingToleranceSecs() int32

func (*TaskRequestResponse) GetCreatedTs 

func (x *TaskRequestResponse) GetCreatedTs() *timestamppb.Timestamp

func (*TaskRequestResponse) GetExpirationSecs 

func (x *TaskRequestResponse) GetExpirationSecs() int32

func (*TaskRequestResponse) GetName 

func (x *TaskRequestResponse) GetName() string

func (*TaskRequestResponse) GetParentTaskId 

func (x *TaskRequestResponse) GetParentTaskId() string

func (*TaskRequestResponse) GetPriority 

func (x *TaskRequestResponse) GetPriority() int32

func (*TaskRequestResponse) GetProperties 

func (x *TaskRequestResponse) GetProperties() *TaskProperties

func (*TaskRequestResponse) GetPubsubTopic 

func (x *TaskRequestResponse) GetPubsubTopic() string

func (*TaskRequestResponse) GetPubsubUserdata 

func (x *TaskRequestResponse) GetPubsubUserdata() string

func (*TaskRequestResponse) GetRbeInstance 

func (x *TaskRequestResponse) GetRbeInstance() string

func (*TaskRequestResponse) GetRealm 

func (x *TaskRequestResponse) GetRealm() string

func (*TaskRequestResponse) GetResultdb 

func (x *TaskRequestResponse) GetResultdb() *ResultDBCfg

func (*TaskRequestResponse) GetServiceAccount 

func (x *TaskRequestResponse) GetServiceAccount() string

func (*TaskRequestResponse) GetTags 

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

func (*TaskRequestResponse) GetTaskId 

func (x *TaskRequestResponse) GetTaskId() string

func (*TaskRequestResponse) GetTaskSlices 

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

func (*TaskRequestResponse) GetUser 

func (x *TaskRequestResponse) GetUser() string

func (*TaskRequestResponse) ProtoMessage 

func (*TaskRequestResponse) ProtoMessage()

func (*TaskRequestResponse) ProtoReflect 

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

func (*TaskRequestResponse) Reset 

func (x *TaskRequestResponse) Reset()

func (*TaskRequestResponse) String 

func (x *TaskRequestResponse) String() string

type TaskRequestsResponse 

type TaskRequestsResponse struct {
	Cursor string                 `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Items  []*TaskRequestResponse `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	Now    *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

Wraps a list of TaskRequest.

func (*TaskRequestsResponse) Descriptor deprecated 

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

Deprecated: Use TaskRequestsResponse.ProtoReflect.Descriptor instead.

func (*TaskRequestsResponse) GetCursor 

func (x *TaskRequestsResponse) GetCursor() string

func (*TaskRequestsResponse) GetItems 

func (x *TaskRequestsResponse) GetItems() []*TaskRequestResponse

func (*TaskRequestsResponse) GetNow 

func (x *TaskRequestsResponse) GetNow() *timestamppb.Timestamp

func (*TaskRequestsResponse) ProtoMessage 

func (*TaskRequestsResponse) ProtoMessage()

func (*TaskRequestsResponse) ProtoReflect 

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

func (*TaskRequestsResponse) Reset 

func (x *TaskRequestsResponse) Reset()

func (*TaskRequestsResponse) String 

func (x *TaskRequestsResponse) String() string

type TaskResultResponse 

type TaskResultResponse struct {

	// Summary task ID (ending with '0') when creating a new task.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// Time when the task was abandoned instead of normal completion (e.g.
	// EXPIRED, BOT_DIED, KILLED).
	//
	// The same key cannot be repeated.
	BotDimensions []*StringListPair `protobuf:"bytes,2,rep,name=bot_dimensions,json=botDimensions,proto3" json:"bot_dimensions,omitempty"`
	// Unique ID of the bot.
	BotId string `protobuf:"bytes,3,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	// Time the bot became ready for a next task.
	BotIdleSinceTs *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=bot_idle_since_ts,json=botIdleSinceTs,proto3" json:"bot_idle_since_ts,omitempty"`
	// Hash of the bot code which ran the task.
	BotVersion string `protobuf:"bytes,5,opt,name=bot_version,json=botVersion,proto3" json:"bot_version,omitempty"`
	// The cloud project id where the bot saves its logs.
	BotLogsCloudProject string `protobuf:"bytes,6,opt,name=bot_logs_cloud_project,json=botLogsCloudProject,proto3" json:"bot_logs_cloud_project,omitempty"`
	// Time the task completed normally. Only one of abandoned_ts or completed_ts
	// can be set except for state == KILLED.
	//
	// In case of KILLED, completed_ts is the time the task completed.
	CompletedTs *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=completed_ts,json=completedTs,proto3" json:"completed_ts,omitempty"`
	// $ saved for task with state DEDUPED.
	CostSavedUsd float32 `protobuf:"fixed32,9,opt,name=cost_saved_usd,json=costSavedUsd,proto3" json:"cost_saved_usd,omitempty"`
	// Time the task was requested.
	CreatedTs *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=created_ts,json=createdTs,proto3" json:"created_ts,omitempty"`
	// Task ID which results was reused for state DEDUPED.
	DedupedFrom string `protobuf:"bytes,11,opt,name=deduped_from,json=dedupedFrom,proto3" json:"deduped_from,omitempty"`
	// Duration of the task in seconds. This excludes overheads.
	Duration float32 `protobuf:"fixed32,12,opt,name=duration,proto3" json:"duration,omitempty"`
	// Process exit code if relevant. May be forcibly set to -1 in exceptional
	// cases.
	ExitCode int64 `protobuf:"varint,13,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// True if exit_code != 0.
	Failure bool `protobuf:"varint,14,opt,name=failure,proto3" json:"failure,omitempty"`
	// True if state is BOT_DIED.
	InternalFailure bool `protobuf:"varint,15,opt,name=internal_failure,json=internalFailure,proto3" json:"internal_failure,omitempty"`
	// Time the results was last updated in the DB.
	ModifiedTs *timestamppb.Timestamp `protobuf:"bytes,16,opt,name=modified_ts,json=modifiedTs,proto3" json:"modified_ts,omitempty"`
	// CAS Digest of the output root uploaded to RBE-CAS.
	// This MUST be digest of [build.bazel.remote.execution.v2.Directory].
	CasOutputRoot *CASReference `protobuf:"bytes,17,opt,name=cas_output_root,json=casOutputRoot,proto3" json:"cas_output_root,omitempty"`
	// Server versions that touched this task.
	ServerVersions []string `protobuf:"bytes,18,rep,name=server_versions,json=serverVersions,proto3" json:"server_versions,omitempty"`
	// Time the task started being run by a bot.
	StartedTs *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=started_ts,json=startedTs,proto3" json:"started_ts,omitempty"`
	// Current state of the task (e.g. PENDING, RUNNING, COMPLETED, EXPIRED, etc).
	State TaskState `protobuf:"varint,20,opt,name=state,proto3,enum=swarming.v2.TaskState" json:"state,omitempty"`
	// In the case of KILLED, this records the time the user requested the task to
	// stop.
	AbandonedTs *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=abandoned_ts,json=abandonedTs,proto3" json:"abandoned_ts,omitempty"`
	// Can be multiple values only in TaskResultSummary.
	CostsUsd []float32 `protobuf:"fixed32,22,rep,packed,name=costs_usd,json=costsUsd,proto3" json:"costs_usd,omitempty"`
	// Name of the task. Only set when requesting task ID summary, ending with '0'.
	Name string `protobuf:"bytes,23,opt,name=name,proto3" json:"name,omitempty"`
	// Tags associated with the task when it was requested. Only set when
	// requesting task ID summary, ending with '0'.
	Tags []string `protobuf:"bytes,24,rep,name=tags,proto3" json:"tags,omitempty"`
	// User on behalf this task was requested. Only set when requesting task ID
	// summary, ending with '0'.
	User string `protobuf:"bytes,25,opt,name=user,proto3" json:"user,omitempty"`
	// Statistics about overhead for an isolated task. Only sent when requested.
	PerformanceStats *PerformanceStats `protobuf:"bytes,26,opt,name=performance_stats,json=performanceStats,proto3" json:"performance_stats,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").
	CipdPins *CipdPins `protobuf:"bytes,27,opt,name=cipd_pins,json=cipdPins,proto3" json:"cipd_pins,omitempty"`
	// Actual executed task id that this task represents. For deduped tasks, it is
	// the same value as deduped_from. This value can be empty if there is no
	// execution, for example the task was cancelled.
	RunId string `protobuf:"bytes,28,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// Index in the TaskRequest.task_slices (TaskSlice instance) that this result
	// represents. This is updated when a TaskSlice is enqueued to run.
	//
	// The TaskSlice contains a TaskProperties, which defines what is run.
	CurrentTaskSlice int32 `protobuf:"varint,29,opt,name=current_task_slice,json=currentTaskSlice,proto3" json:"current_task_slice,omitempty"`
	// ResultDB related information.
	// None if the integration was not enabled for this task.
	ResultdbInfo *ResultDBInfo `protobuf:"bytes,30,opt,name=resultdb_info,json=resultdbInfo,proto3" json:"resultdb_info,omitempty"`
	// Reported missing CAS packages on CLIENT_ERROR state
	MissingCas []*CASReference `protobuf:"bytes,31,rep,name=missing_cas,json=missingCas,proto3" json:"missing_cas,omitempty"`
	// Reported missing CIPD packages on CLIENT_ERROR state
	MissingCipd []*CipdPackage `protobuf:"bytes,32,rep,name=missing_cipd,json=missingCipd,proto3" json:"missing_cipd,omitempty"`
	// contains filtered or unexported fields
}

Representation of the TaskResultSummary or TaskRunResult ndb model.

func (*TaskResultResponse) Descriptor deprecated 

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

Deprecated: Use TaskResultResponse.ProtoReflect.Descriptor instead.

func (*TaskResultResponse) GetAbandonedTs 

func (x *TaskResultResponse) GetAbandonedTs() *timestamppb.Timestamp

func (*TaskResultResponse) GetBotDimensions 

func (x *TaskResultResponse) GetBotDimensions() []*StringListPair

func (*TaskResultResponse) GetBotId 

func (x *TaskResultResponse) GetBotId() string

func (*TaskResultResponse) GetBotIdleSinceTs 

func (x *TaskResultResponse) GetBotIdleSinceTs() *timestamppb.Timestamp

func (*TaskResultResponse) GetBotLogsCloudProject 

func (x *TaskResultResponse) GetBotLogsCloudProject() string

func (*TaskResultResponse) GetBotVersion 

func (x *TaskResultResponse) GetBotVersion() string

func (*TaskResultResponse) GetCasOutputRoot 

func (x *TaskResultResponse) GetCasOutputRoot() *CASReference

func (*TaskResultResponse) GetCipdPins 

func (x *TaskResultResponse) GetCipdPins() *CipdPins

func (*TaskResultResponse) GetCompletedTs 

func (x *TaskResultResponse) GetCompletedTs() *timestamppb.Timestamp

func (*TaskResultResponse) GetCostSavedUsd 

func (x *TaskResultResponse) GetCostSavedUsd() float32

func (*TaskResultResponse) GetCostsUsd 

func (x *TaskResultResponse) GetCostsUsd() []float32

func (*TaskResultResponse) GetCreatedTs 

func (x *TaskResultResponse) GetCreatedTs() *timestamppb.Timestamp

func (*TaskResultResponse) GetCurrentTaskSlice 

func (x *TaskResultResponse) GetCurrentTaskSlice() int32

func (*TaskResultResponse) GetDedupedFrom 

func (x *TaskResultResponse) GetDedupedFrom() string

func (*TaskResultResponse) GetDuration 

func (x *TaskResultResponse) GetDuration() float32

func (*TaskResultResponse) GetExitCode 

func (x *TaskResultResponse) GetExitCode() int64

func (*TaskResultResponse) GetFailure 

func (x *TaskResultResponse) GetFailure() bool

func (*TaskResultResponse) GetInternalFailure 

func (x *TaskResultResponse) GetInternalFailure() bool

func (*TaskResultResponse) GetMissingCas 

func (x *TaskResultResponse) GetMissingCas() []*CASReference

func (*TaskResultResponse) GetMissingCipd 

func (x *TaskResultResponse) GetMissingCipd() []*CipdPackage

func (*TaskResultResponse) GetModifiedTs 

func (x *TaskResultResponse) GetModifiedTs() *timestamppb.Timestamp

func (*TaskResultResponse) GetName 

func (x *TaskResultResponse) GetName() string

func (*TaskResultResponse) GetPerformanceStats 

func (x *TaskResultResponse) GetPerformanceStats() *PerformanceStats

func (*TaskResultResponse) GetResultdbInfo 

func (x *TaskResultResponse) GetResultdbInfo() *ResultDBInfo

func (*TaskResultResponse) GetRunId 

func (x *TaskResultResponse) GetRunId() string

func (*TaskResultResponse) GetServerVersions 

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

func (*TaskResultResponse) GetStartedTs 

func (x *TaskResultResponse) GetStartedTs() *timestamppb.Timestamp

func (*TaskResultResponse) GetState 

func (x *TaskResultResponse) GetState() TaskState

func (*TaskResultResponse) GetTags 

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

func (*TaskResultResponse) GetTaskId 

func (x *TaskResultResponse) GetTaskId() string

func (*TaskResultResponse) GetUser 

func (x *TaskResultResponse) GetUser() string

func (*TaskResultResponse) ProtoMessage 

func (*TaskResultResponse) ProtoMessage()

func (*TaskResultResponse) ProtoReflect 

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

func (*TaskResultResponse) Reset 

func (x *TaskResultResponse) Reset()

func (*TaskResultResponse) String 

func (x *TaskResultResponse) String() string

type TaskSlice 

type TaskSlice struct {

	// The property of the task to try to run.
	//
	// If there is no bot that can serve this properties.dimensions when this task
	// slice is enqueued, it is immediately denied. This can trigger if:
	// - There is no bot with these dimensions currently known.
	// - Bots that could run this task are either all dead or quarantined.
	// Swarming considers a bot dead if it hasn't pinged in the last N minutes
	// (currently 10 minutes).
	Properties *TaskProperties `protobuf:"bytes,1,opt,name=properties,proto3" json:"properties,omitempty"`
	// Maximum of seconds the task slice may stay PENDING.
	//
	// If this task request slice is not scheduled after waiting this long, the
	// next one will be processed. If this slice is the last one, the task state
	// will be set to EXPIRED.
	ExpirationSecs int32 `protobuf:"varint,2,opt,name=expiration_secs,json=expirationSecs,proto3" json:"expiration_secs,omitempty"`
	// When a task is scheduled and there are currently no bots available to run
	// the task, the TaskSlice can either be PENDING, or be denied immediately.
	// When denied, the next TaskSlice is enqueued, and if there's no following
	// TaskSlice, the task state is set to NO_RESOURCE. This should normally be
	// set to False to avoid unnecessary waiting.
	WaitForCapacity bool `protobuf:"varint,3,opt,name=wait_for_capacity,json=waitForCapacity,proto3" json:"wait_for_capacity,omitempty"`
	// contains filtered or unexported fields
}

Defines a possible task execution for a task request to be run on the Swarming infrastructure.

This is one of the possible fallback on a task request.

func (*TaskSlice) Descriptor deprecated 

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

Deprecated: Use TaskSlice.ProtoReflect.Descriptor instead.

func (*TaskSlice) GetExpirationSecs 

func (x *TaskSlice) GetExpirationSecs() int32

func (*TaskSlice) GetProperties 

func (x *TaskSlice) GetProperties() *TaskProperties

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

Represents the current task state.

Some states are still mutable: PENDING and RUNNING. The others are final and will not change afterward.

A task is guaranteed to be in exactly one state at any point of time.

Do not confuse StateQuery and TaskState. StateQuery is to query tasks via the API. TaskState is the current task state.

As you read the following constants, astute readers may wonder why these constants look like a bitmask. This is because of historical reasons and this is effectively an enum, not a bitmask. 

const (
	// Invalid state, do not use.
	TaskState_INVALID TaskState = 0
	// The task is currently running. This is in fact 3 phases: the initial
	// overhead to fetch input files, the actual task running, and the tear down
	// overhead to archive output files to the server.
	TaskState_RUNNING TaskState = 16
	// The task is currently pending. This means that no bot reaped the task. It
	// will stay in this state until either a task reaps it or the expiration
	// elapsed. The task pending expiration is specified as
	// TaskSlice.expiration_secs, one per task slice.
	TaskState_PENDING TaskState = 32
	// The task is not pending anymore, and 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_secs seconds.
	TaskState_EXPIRED TaskState = 48
	// The task ran for longer than the allowed time in
	// TaskProperties.execution_timeout_secs or TaskProperties.io_timeout_secs.
	// This means the bot forcefully killed the task process as described in the
	// graceful termination dance in the documentation.
	TaskState_TIMED_OUT TaskState = 64
	// The task ran but the bot had an internal failure, unrelated to the task
	// itself. It can be due to the server being unavailable to get task update,
	// the host on which the bot is running crashing or rebooting, etc.
	TaskState_BOT_DIED TaskState = 80
	// The task never ran, and was manually cancelled via the 'cancel' API before
	// it was reaped.
	TaskState_CANCELED TaskState = 96
	// The task ran and completed normally. The task process exit code may be 0 or
	// another value.
	TaskState_COMPLETED TaskState = 112
	// 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 = 128
	// 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.
	//
	// 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 = 256
	// The task run into an issue that was caused by the client. It can be due to
	// a bad CIPD or CAS package. Retrying the task with the same parameters will
	// not change the result.
	TaskState_CLIENT_ERROR TaskState = 512
)

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 TaskStates 

type TaskStates struct {
	States []TaskState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=swarming.v2.TaskState" json:"states,omitempty"`
	// contains filtered or unexported fields
}

Only holds states. Used in the 'get_states' RPC.

func (*TaskStates) Descriptor deprecated 

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

Deprecated: Use TaskStates.ProtoReflect.Descriptor instead.

func (*TaskStates) GetStates 

func (x *TaskStates) GetStates() []TaskState

func (*TaskStates) ProtoMessage 

func (*TaskStates) ProtoMessage()

func (*TaskStates) ProtoReflect 

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

func (*TaskStates) Reset 

func (x *TaskStates) Reset()

func (*TaskStates) String 

func (x *TaskStates) String() string

type TaskStatesRequest 

type TaskStatesRequest struct {
	TaskId []string `protobuf:"bytes,1,rep,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatesRequest) Descriptor deprecated 

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

Deprecated: Use TaskStatesRequest.ProtoReflect.Descriptor instead.

func (*TaskStatesRequest) GetTaskId 

func (x *TaskStatesRequest) GetTaskId() []string

func (*TaskStatesRequest) ProtoMessage 

func (*TaskStatesRequest) ProtoMessage()

func (*TaskStatesRequest) ProtoReflect 

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

func (*TaskStatesRequest) Reset 

func (x *TaskStatesRequest) Reset()

func (*TaskStatesRequest) String 

func (x *TaskStatesRequest) String() string

type TasksCancelRequest 

type TasksCancelRequest struct {

	// Number of items to cancel per request. limit must be in [1..1000].
	Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// Previous call would have returned a cursor if there were more tasks to kill.
	Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// Any task which contains one or more of tags will be cancelled.
	Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// Kill running tasks if set. Otherwise running tasks will be ignored.
	KillRunning bool `protobuf:"varint,4,opt,name=kill_running,json=killRunning,proto3" json:"kill_running,omitempty"`
	// Only tasks later or equal to start will be cancelled. No effect if unset.
	Start *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=start,proto3" json:"start,omitempty"`
	// Only tasks earlier or equal to end will be cancelled. No effect if unset.
	End *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

Request to cancel some subset of pending/running tasks.

func (*TasksCancelRequest) Descriptor deprecated 

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

Deprecated: Use TasksCancelRequest.ProtoReflect.Descriptor instead.

func (*TasksCancelRequest) GetCursor 

func (x *TasksCancelRequest) GetCursor() string

func (*TasksCancelRequest) GetEnd 

func (x *TasksCancelRequest) GetEnd() *timestamppb.Timestamp

func (*TasksCancelRequest) GetKillRunning 

func (x *TasksCancelRequest) GetKillRunning() bool

func (*TasksCancelRequest) GetLimit 

func (x *TasksCancelRequest) GetLimit() int32

func (*TasksCancelRequest) GetStart 

func (x *TasksCancelRequest) GetStart() *timestamppb.Timestamp

func (*TasksCancelRequest) GetTags 

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

func (*TasksCancelRequest) ProtoMessage 

func (*TasksCancelRequest) ProtoMessage()

func (*TasksCancelRequest) ProtoReflect 

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

func (*TasksCancelRequest) Reset 

func (x *TasksCancelRequest) Reset()

func (*TasksCancelRequest) String 

func (x *TasksCancelRequest) String() string

type TasksCancelResponse 

type TasksCancelResponse struct {
	Cursor  string                 `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Now     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=now,proto3" json:"now,omitempty"`
	Matched int32                  `protobuf:"varint,3,opt,name=matched,proto3" json:"matched,omitempty"`
	// contains filtered or unexported fields
}

Result of canceling some subset of pending tasks.

func (*TasksCancelResponse) Descriptor deprecated 

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

Deprecated: Use TasksCancelResponse.ProtoReflect.Descriptor instead.

func (*TasksCancelResponse) GetCursor 

func (x *TasksCancelResponse) GetCursor() string

func (*TasksCancelResponse) GetMatched 

func (x *TasksCancelResponse) GetMatched() int32

func (*TasksCancelResponse) GetNow 

func (x *TasksCancelResponse) GetNow() *timestamppb.Timestamp

func (*TasksCancelResponse) ProtoMessage 

func (*TasksCancelResponse) ProtoMessage()

func (*TasksCancelResponse) ProtoReflect 

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

func (*TasksCancelResponse) Reset 

func (x *TasksCancelResponse) Reset()

func (*TasksCancelResponse) String 

func (x *TasksCancelResponse) String() string

type TasksClient 

type TasksClient interface {
	// GetResult reports the result of the task corresponding to a task ID.
	// It can be a 'run' ID specifying a specific retry or a 'summary' ID hidding
	// the fact that a task may have been retried transparently, when a bot reports
	// BOT_DIED.
	// A summary ID ends with '0', a run ID ends with '1' or '2'.
	//
	// TODO(vadimsh): Require the summary ID ending with '0'.
	GetResult(ctx context.Context, in *TaskIdWithPerfRequest, opts ...grpc.CallOption) (*TaskResultResponse, error)
	// BatchGetResult returns results of many tasks at once.
	BatchGetResult(ctx context.Context, in *BatchGetResultRequest, opts ...grpc.CallOption) (*BatchGetResultResponse, error)
	// GetRequest returns the task request corresponding to a task ID.
	GetRequest(ctx context.Context, in *TaskIdRequest, opts ...grpc.CallOption) (*TaskRequestResponse, error)
	// CancelTask cancels a task. If a bot was running the task, the bot will forcibly cancel the task.
	CancelTask(ctx context.Context, in *TaskCancelRequest, opts ...grpc.CallOption) (*CancelResponse, error)
	// GetStdout returns the output of the task corresponding to a task ID.
	GetStdout(ctx context.Context, in *TaskIdWithOffsetRequest, opts ...grpc.CallOption) (*TaskOutputResponse, error)
	// NewTask creates a new task.
	// The task will be enqueued in the tasks list and will be executed at the
	// earliest opportunity by a bot that has at least the dimensions as described
	// in the task request.
	NewTask(ctx context.Context, in *NewTaskRequest, opts ...grpc.CallOption) (*TaskRequestMetadataResponse, error)
	// ListTasks returns full task results based on the filters.
	// This endpoint is significantly slower than 'count'. Use 'count' when
	// possible. If you just want the state of tasks, use 'get_states'.
	ListTasks(ctx context.Context, in *TasksWithPerfRequest, opts ...grpc.CallOption) (*TaskListResponse, error)
	// ListTaskStates returns task state for a specific set of tasks."""
	ListTaskStates(ctx context.Context, in *TaskStatesRequest, opts ...grpc.CallOption) (*TaskStates, error)
	// GetTaskRequests returns the task request corresponding to a task ID.
	ListTaskRequests(ctx context.Context, in *TasksRequest, opts ...grpc.CallOption) (*TaskRequestsResponse, error)
	// CancelTasks cancels a subset of pending tasks based on the tags.
	// Cancellation happens asynchronously, so when this call returns,
	// cancellations will not have completed yet.
	CancelTasks(ctx context.Context, in *TasksCancelRequest, opts ...grpc.CallOption) (*TasksCancelResponse, error)
	// CountTasks returns the number of tasks in a given state."""
	CountTasks(ctx context.Context, in *TasksCountRequest, opts ...grpc.CallOption) (*TasksCount, error)
}

TasksClient is the client API for Tasks service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTasksClient 

func NewTasksClient(cc grpc.ClientConnInterface) TasksClient

type TasksCount 

type TasksCount struct {
	Count int32                  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Now   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=now,proto3" json:"now,omitempty"`
	// contains filtered or unexported fields
}

Returns the count, as requested.

func (*TasksCount) Descriptor deprecated 

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

Deprecated: Use TasksCount.ProtoReflect.Descriptor instead.

func (*TasksCount) GetCount 

func (x *TasksCount) GetCount() int32

func (*TasksCount) GetNow 

func (x *TasksCount) GetNow() *timestamppb.Timestamp

func (*TasksCount) ProtoMessage 

func (*TasksCount) ProtoMessage()

func (*TasksCount) ProtoReflect 

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

func (*TasksCount) Reset 

func (x *TasksCount) Reset()

func (*TasksCount) String 

func (x *TasksCount) String() string

type TasksCountRequest 

type TasksCountRequest struct {
	Start *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	State StateQuery             `protobuf:"varint,3,opt,name=state,proto3,enum=swarming.v2.StateQuery" json:"state,omitempty"`
	Tags  []string               `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*TasksCountRequest) Descriptor deprecated 

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

Deprecated: Use TasksCountRequest.ProtoReflect.Descriptor instead.

func (*TasksCountRequest) GetEnd 

func (x *TasksCountRequest) GetEnd() *timestamppb.Timestamp

func (*TasksCountRequest) GetStart 

func (x *TasksCountRequest) GetStart() *timestamppb.Timestamp

func (*TasksCountRequest) GetState 

func (x *TasksCountRequest) GetState() StateQuery

func (*TasksCountRequest) GetTags 

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

func (*TasksCountRequest) ProtoMessage 

func (*TasksCountRequest) ProtoMessage()

func (*TasksCountRequest) ProtoReflect 

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

func (*TasksCountRequest) Reset 

func (x *TasksCountRequest) Reset()

func (*TasksCountRequest) String 

func (x *TasksCountRequest) String() string

type TasksRequest 

type TasksRequest struct {
	Limit  int32  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// These were floats in the legacy protorpc api
	Start *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"`
	End   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"`
	State StateQuery             `protobuf:"varint,5,opt,name=state,proto3,enum=swarming.v2.StateQuery" json:"state,omitempty"`
	Sort  SortQuery              `protobuf:"varint,6,opt,name=sort,proto3,enum=swarming.v2.SortQuery" json:"sort,omitempty"`
	Tags  []string               `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*TasksRequest) Descriptor deprecated 

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

Deprecated: Use TasksRequest.ProtoReflect.Descriptor instead.

func (*TasksRequest) GetCursor 

func (x *TasksRequest) GetCursor() string

func (*TasksRequest) GetEnd 

func (x *TasksRequest) GetEnd() *timestamppb.Timestamp

func (*TasksRequest) GetLimit 

func (x *TasksRequest) GetLimit() int32

func (*TasksRequest) GetSort 

func (x *TasksRequest) GetSort() SortQuery

func (*TasksRequest) GetStart 

func (x *TasksRequest) GetStart() *timestamppb.Timestamp

func (*TasksRequest) GetState 

func (x *TasksRequest) GetState() StateQuery

func (*TasksRequest) GetTags 

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

func (*TasksRequest) ProtoMessage 

func (*TasksRequest) ProtoMessage()

func (*TasksRequest) ProtoReflect 

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

func (*TasksRequest) Reset 

func (x *TasksRequest) Reset()

func (*TasksRequest) String 

func (x *TasksRequest) String() string

type TasksServer 

type TasksServer interface {
	// GetResult reports the result of the task corresponding to a task ID.
	// It can be a 'run' ID specifying a specific retry or a 'summary' ID hidding
	// the fact that a task may have been retried transparently, when a bot reports
	// BOT_DIED.
	// A summary ID ends with '0', a run ID ends with '1' or '2'.
	//
	// TODO(vadimsh): Require the summary ID ending with '0'.
	GetResult(context.Context, *TaskIdWithPerfRequest) (*TaskResultResponse, error)
	// BatchGetResult returns results of many tasks at once.
	BatchGetResult(context.Context, *BatchGetResultRequest) (*BatchGetResultResponse, error)
	// GetRequest returns the task request corresponding to a task ID.
	GetRequest(context.Context, *TaskIdRequest) (*TaskRequestResponse, error)
	// CancelTask cancels a task. If a bot was running the task, the bot will forcibly cancel the task.
	CancelTask(context.Context, *TaskCancelRequest) (*CancelResponse, error)
	// GetStdout returns the output of the task corresponding to a task ID.
	GetStdout(context.Context, *TaskIdWithOffsetRequest) (*TaskOutputResponse, error)
	// NewTask creates a new task.
	// The task will be enqueued in the tasks list and will be executed at the
	// earliest opportunity by a bot that has at least the dimensions as described
	// in the task request.
	NewTask(context.Context, *NewTaskRequest) (*TaskRequestMetadataResponse, error)
	// ListTasks returns full task results based on the filters.
	// This endpoint is significantly slower than 'count'. Use 'count' when
	// possible. If you just want the state of tasks, use 'get_states'.
	ListTasks(context.Context, *TasksWithPerfRequest) (*TaskListResponse, error)
	// ListTaskStates returns task state for a specific set of tasks."""
	ListTaskStates(context.Context, *TaskStatesRequest) (*TaskStates, error)
	// GetTaskRequests returns the task request corresponding to a task ID.
	ListTaskRequests(context.Context, *TasksRequest) (*TaskRequestsResponse, error)
	// CancelTasks cancels a subset of pending tasks based on the tags.
	// Cancellation happens asynchronously, so when this call returns,
	// cancellations will not have completed yet.
	CancelTasks(context.Context, *TasksCancelRequest) (*TasksCancelResponse, error)
	// CountTasks returns the number of tasks in a given state."""
	CountTasks(context.Context, *TasksCountRequest) (*TasksCount, error)
	// contains filtered or unexported methods
}

TasksServer is the server API for Tasks service. All implementations must embed UnimplementedTasksServer for forward compatibility.

type TasksWithPerfRequest 

type TasksWithPerfRequest struct {
	Limit  int32  `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Cursor string `protobuf:"bytes,2,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// These were floats in the legacy protorpc api
	Start                   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"`
	End                     *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"`
	State                   StateQuery             `protobuf:"varint,5,opt,name=state,proto3,enum=swarming.v2.StateQuery" json:"state,omitempty"`
	Sort                    SortQuery              `protobuf:"varint,6,opt,name=sort,proto3,enum=swarming.v2.SortQuery" json:"sort,omitempty"`
	Tags                    []string               `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	IncludePerformanceStats bool                   `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TasksWithPerfRequest) Descriptor deprecated 

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

Deprecated: Use TasksWithPerfRequest.ProtoReflect.Descriptor instead.

func (*TasksWithPerfRequest) GetCursor 

func (x *TasksWithPerfRequest) GetCursor() string

func (*TasksWithPerfRequest) GetEnd 

func (x *TasksWithPerfRequest) GetEnd() *timestamppb.Timestamp

func (*TasksWithPerfRequest) GetIncludePerformanceStats 

func (x *TasksWithPerfRequest) GetIncludePerformanceStats() bool

func (*TasksWithPerfRequest) GetLimit 

func (x *TasksWithPerfRequest) GetLimit() int32

func (*TasksWithPerfRequest) GetSort 

func (x *TasksWithPerfRequest) GetSort() SortQuery

func (*TasksWithPerfRequest) GetStart 

func (x *TasksWithPerfRequest) GetStart() *timestamppb.Timestamp

func (*TasksWithPerfRequest) GetState 

func (x *TasksWithPerfRequest) GetState() StateQuery

func (*TasksWithPerfRequest) GetTags 

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

func (*TasksWithPerfRequest) ProtoMessage 

func (*TasksWithPerfRequest) ProtoMessage()

func (*TasksWithPerfRequest) ProtoReflect 

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

func (*TasksWithPerfRequest) Reset 

func (x *TasksWithPerfRequest) Reset()

func (*TasksWithPerfRequest) String 

func (x *TasksWithPerfRequest) String() string

type TerminateRequest 

type TerminateRequest struct {

	// Id of bot to terminate.
	BotId string `protobuf:"bytes,1,opt,name=bot_id,json=botId,proto3" json:"bot_id,omitempty"`
	// Reason why the termination was created.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminateRequest) Descriptor deprecated 

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetBotId 

func (x *TerminateRequest) GetBotId() string

func (*TerminateRequest) GetReason 

func (x *TerminateRequest) GetReason() string

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type TerminateResponse 

type TerminateResponse struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

Returns the pseudo taskid to wait for the bot to shut down.

func (*TerminateResponse) Descriptor deprecated 

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

Deprecated: Use TerminateResponse.ProtoReflect.Descriptor instead.

func (*TerminateResponse) GetTaskId 

func (x *TerminateResponse) GetTaskId() string

func (*TerminateResponse) ProtoMessage 

func (*TerminateResponse) ProtoMessage()

func (*TerminateResponse) ProtoReflect 

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

func (*TerminateResponse) Reset 

func (x *TerminateResponse) Reset()

func (*TerminateResponse) String 

func (x *TerminateResponse) String() string

type UnimplementedBotsServer 

type UnimplementedBotsServer struct{}

UnimplementedBotsServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedBotsServer) CountBots 

func (UnimplementedBotsServer) CountBots(context.Context, *BotsCountRequest) (*BotsCount, error)

func (UnimplementedBotsServer) DeleteBot 

func (UnimplementedBotsServer) DeleteBot(context.Context, *BotRequest) (*DeleteResponse, error)

func (UnimplementedBotsServer) GetBot 

func (UnimplementedBotsServer) GetBot(context.Context, *BotRequest) (*BotInfo, error)

func (UnimplementedBotsServer) GetBotDimensions 

func (UnimplementedBotsServer) GetBotDimensions(context.Context, *BotsDimensionsRequest) (*BotsDimensions, error)

func (UnimplementedBotsServer) ListBotEvents 

func (UnimplementedBotsServer) ListBotEvents(context.Context, *BotEventsRequest) (*BotEventsResponse, error)

func (UnimplementedBotsServer) ListBotTasks 

func (UnimplementedBotsServer) ListBotTasks(context.Context, *BotTasksRequest) (*TaskListResponse, error)

func (UnimplementedBotsServer) ListBots 

func (UnimplementedBotsServer) ListBots(context.Context, *BotsRequest) (*BotInfoListResponse, error)

func (UnimplementedBotsServer) TerminateBot 

func (UnimplementedBotsServer) TerminateBot(context.Context, *TerminateRequest) (*TerminateResponse, error)

type UnimplementedSwarmingServer 

type UnimplementedSwarmingServer struct{}

UnimplementedSwarmingServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSwarmingServer) GetDetails 

func (UnimplementedSwarmingServer) GetDetails(context.Context, *emptypb.Empty) (*ServerDetails, error)

func (UnimplementedSwarmingServer) GetPermissions 

func (UnimplementedSwarmingServer) GetPermissions(context.Context, *PermissionsRequest) (*ClientPermissions, error)

func (UnimplementedSwarmingServer) GetToken 

func (UnimplementedSwarmingServer) GetToken(context.Context, *emptypb.Empty) (*BootstrapToken, error)

type UnimplementedTasksServer 

type UnimplementedTasksServer struct{}

UnimplementedTasksServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTasksServer) BatchGetResult 

func (UnimplementedTasksServer) BatchGetResult(context.Context, *BatchGetResultRequest) (*BatchGetResultResponse, error)

func (UnimplementedTasksServer) CancelTask 

func (UnimplementedTasksServer) CancelTask(context.Context, *TaskCancelRequest) (*CancelResponse, error)

func (UnimplementedTasksServer) CancelTasks 

func (UnimplementedTasksServer) CancelTasks(context.Context, *TasksCancelRequest) (*TasksCancelResponse, error)

func (UnimplementedTasksServer) CountTasks 

func (UnimplementedTasksServer) CountTasks(context.Context, *TasksCountRequest) (*TasksCount, error)

func (UnimplementedTasksServer) GetRequest 

func (UnimplementedTasksServer) GetRequest(context.Context, *TaskIdRequest) (*TaskRequestResponse, error)

func (UnimplementedTasksServer) GetResult 

func (UnimplementedTasksServer) GetResult(context.Context, *TaskIdWithPerfRequest) (*TaskResultResponse, error)

func (UnimplementedTasksServer) GetStdout 

func (UnimplementedTasksServer) GetStdout(context.Context, *TaskIdWithOffsetRequest) (*TaskOutputResponse, error)

func (UnimplementedTasksServer) ListTaskRequests 

func (UnimplementedTasksServer) ListTaskRequests(context.Context, *TasksRequest) (*TaskRequestsResponse, error)

func (UnimplementedTasksServer) ListTaskStates 

func (UnimplementedTasksServer) ListTaskStates(context.Context, *TaskStatesRequest) (*TaskStates, error)

func (UnimplementedTasksServer) ListTasks 

func (UnimplementedTasksServer) ListTasks(context.Context, *TasksWithPerfRequest) (*TaskListResponse, error)

func (UnimplementedTasksServer) NewTask 

func (UnimplementedTasksServer) NewTask(context.Context, *NewTaskRequest) (*TaskRequestMetadataResponse, error)

type UnsafeBotsServer 

type UnsafeBotsServer interface {
	// contains filtered or unexported methods
}

UnsafeBotsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BotsServer will result in compilation errors.

type UnsafeSwarmingServer 

type UnsafeSwarmingServer interface {
	// contains filtered or unexported methods
}

UnsafeSwarmingServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SwarmingServer will result in compilation errors.

type UnsafeTasksServer 

type UnsafeTasksServer interface {
	// contains filtered or unexported methods
}

UnsafeTasksServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TasksServer will result in compilation errors.

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.