apipb

package
v0.0.0-...-650f6e2 Latest Latest
Warning

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

Go to latest
Published: Apr 27, 2024 License: Apache-2.0 Imports: 13 Imported by: 2

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 (*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 (*BatchGetResultResponse_ResultOrError) GetOutcome

func (m *BatchGetResultResponse_ResultOrError) GetOutcome() isBatchGetResultResponse_ResultOrError_Outcome

func (*BatchGetResultResponse_ResultOrError) GetResult

func (*BatchGetResultResponse_ResultOrError) GetTaskId

func (*BatchGetResultResponse_ResultOrError) ProtoMessage

func (*BatchGetResultResponse_ResultOrError) ProtoMessage()

func (*BatchGetResultResponse_ResultOrError) ProtoReflect

func (*BatchGetResultResponse_ResultOrError) Reset

func (*BatchGetResultResponse_ResultOrError) 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"`
	// 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) GetState

func (x *BotEventResponse) GetState() string

func (*BotEventResponse) GetTaskId

func (x *BotEventResponse) GetTaskId() string

func (*BotEventResponse) GetTs

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 (*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"`
	// 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) 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 (*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) Enum

func (Containment_ContainmentType) EnumDescriptor deprecated

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

Deprecated: Use Containment_ContainmentType.Descriptor instead.

func (Containment_ContainmentType) Number

func (Containment_ContainmentType) String

func (Containment_ContainmentType) Type

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

func (NewTaskRequest_PoolTaskTemplateField) EnumDescriptor deprecated

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

Deprecated: Use NewTaskRequest_PoolTaskTemplateField.Descriptor instead.

func (NewTaskRequest_PoolTaskTemplateField) Number

func (NewTaskRequest_PoolTaskTemplateField) String

func (NewTaskRequest_PoolTaskTemplateField) Type

type NullableBool

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

func (NullableBool) Descriptor

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 (NullableBool) String

func (x NullableBool) String() string

func (NullableBool) Type

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

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

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 (*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 (*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 (*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 (*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

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 (*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 (*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 (*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 (*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 (*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.

func (UnimplementedBotsServer) CountBots

func (UnimplementedBotsServer) DeleteBot

func (UnimplementedBotsServer) GetBot

func (UnimplementedBotsServer) GetBotDimensions

func (UnimplementedBotsServer) ListBotEvents

func (UnimplementedBotsServer) ListBotTasks

func (UnimplementedBotsServer) ListBots

func (UnimplementedBotsServer) TerminateBot

type UnimplementedSwarmingServer

type UnimplementedSwarmingServer struct {
}

UnimplementedSwarmingServer must be embedded to have forward compatible implementations.

func (UnimplementedSwarmingServer) GetDetails

func (UnimplementedSwarmingServer) GetPermissions

func (UnimplementedSwarmingServer) GetToken

type UnimplementedTasksServer

type UnimplementedTasksServer struct {
}

UnimplementedTasksServer must be embedded to have forward compatible implementations.

func (UnimplementedTasksServer) BatchGetResult

func (UnimplementedTasksServer) CancelTask

func (UnimplementedTasksServer) CancelTasks

func (UnimplementedTasksServer) CountTasks

func (UnimplementedTasksServer) GetRequest

func (UnimplementedTasksServer) GetResult

func (UnimplementedTasksServer) GetStdout

func (UnimplementedTasksServer) ListTaskRequests

func (UnimplementedTasksServer) ListTaskStates

func (UnimplementedTasksServer) ListTasks

func (UnimplementedTasksServer) NewTask

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.

Jump to

Keyboard shortcuts

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