skylab_test_runner

package
v0.0.0-...-5dc5008 Latest Latest
Warning

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

Go to latest
Published: Apr 19, 2024 License: BSD-3-Clause Imports: 17 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Trv2Config_BuildType_name = map[int32]string{
		0: "CQ",
		1: "RELEASE",
		2: "POSTSUBMIT",
	}
	Trv2Config_BuildType_value = map[string]int32{
		"CQ":         0,
		"RELEASE":    1,
		"POSTSUBMIT": 2,
	}
)

Enum value maps for Trv2Config_BuildType.

View Source
var (
	Result_Autotest_TestCase_Verdict_name = map[int32]string{
		0: "VERDICT_UNDEFINED",
		1: "VERDICT_PASS",
		2: "VERDICT_FAIL",
		3: "VERDICT_NO_VERDICT",
		4: "VERDICT_ERROR",
		5: "VERDICT_ABORT",
	}
	Result_Autotest_TestCase_Verdict_value = map[string]int32{
		"VERDICT_UNDEFINED":  0,
		"VERDICT_PASS":       1,
		"VERDICT_FAIL":       2,
		"VERDICT_NO_VERDICT": 3,
		"VERDICT_ERROR":      4,
		"VERDICT_ABORT":      5,
	}
)

Enum value maps for Result_Autotest_TestCase_Verdict.

View Source
var (
	Result_Prejob_Step_Verdict_name = map[int32]string{
		0: "VERDICT_UNDEFINED",
		1: "VERDICT_PASS",
		2: "VERDICT_FAIL",
	}
	Result_Prejob_Step_Verdict_value = map[string]int32{
		"VERDICT_UNDEFINED": 0,
		"VERDICT_PASS":      1,
		"VERDICT_FAIL":      2,
	}
)

Enum value maps for Result_Prejob_Step_Verdict.

View Source
var CrosTestRunnerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "test_platform.skylab_test_runner.CrosTestRunnerService",
	HandlerType: (*CrosTestRunnerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Execute",
			Handler:    _CrosTestRunnerService_Execute_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "test_platform/skylab_test_runner/cros_test_runner_service.proto",
}

CrosTestRunnerService_ServiceDesc is the grpc.ServiceDesc for CrosTestRunnerService 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_test_platform_skylab_test_runner_cft_request_proto protoreflect.FileDescriptor
View Source
var File_test_platform_skylab_test_runner_common_config_proto protoreflect.FileDescriptor
View Source
var File_test_platform_skylab_test_runner_config_proto protoreflect.FileDescriptor
View Source
var File_test_platform_skylab_test_runner_cros_test_runner_request_proto protoreflect.FileDescriptor
View Source
var File_test_platform_skylab_test_runner_cros_test_runner_service_proto protoreflect.FileDescriptor
View Source
var File_test_platform_skylab_test_runner_request_proto protoreflect.FileDescriptor
View Source
var File_test_platform_skylab_test_runner_result_proto protoreflect.FileDescriptor

Functions

func RegisterCrosTestRunnerServiceServer

func RegisterCrosTestRunnerServiceServer(s grpc.ServiceRegistrar, srv CrosTestRunnerServiceServer)

Types

type BuildMode

type BuildMode struct {

	// The buildbucket ID of the CTP build that sent this test_runner request.
	ParentBuildId int64 `protobuf:"varint,1,opt,name=parent_build_id,json=parentBuildId,proto3" json:"parent_build_id,omitempty"`
	// The UID of the individual CTP request which kicked off this test run.
	// Note that distinct requests inside a multi-request CTP build will have
	// different UIDs.
	ParentRequestUid string `protobuf:"bytes,2,opt,name=parent_request_uid,json=parentRequestUid,proto3" json:"parent_request_uid,omitempty"`
	// contains filtered or unexported fields
}

BuildMode provides the necessary parameters by which test execution using a build may be achieved.

func (*BuildMode) Descriptor deprecated

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

Deprecated: Use BuildMode.ProtoReflect.Descriptor instead.

func (*BuildMode) GetParentBuildId

func (x *BuildMode) GetParentBuildId() int64

func (*BuildMode) GetParentRequestUid

func (x *BuildMode) GetParentRequestUid() string

func (*BuildMode) ProtoMessage

func (*BuildMode) ProtoMessage()

func (*BuildMode) ProtoReflect

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

func (*BuildMode) Reset

func (x *BuildMode) Reset()

func (*BuildMode) String

func (x *BuildMode) String() string

type CFTTestRequest

type CFTTestRequest struct {

	// Primary Dut info
	PrimaryDut *CFTTestRequest_Device `protobuf:"bytes,1,opt,name=primary_dut,json=primaryDut,proto3" json:"primary_dut,omitempty"`
	// Companion Duts info
	CompanionDuts []*CFTTestRequest_Device `protobuf:"bytes,2,rep,name=companion_duts,json=companionDuts,proto3" json:"companion_duts,omitempty"`
	// Test suites to run by tag or explicit list of tests.
	TestSuites []*api.TestSuite `protobuf:"bytes,3,rep,name=test_suites,json=testSuites,proto3" json:"test_suites,omitempty"`
	// Provision/Test execution will need to be invoked before this.
	// Currently CTR do not take any deadline. But in future, if it does, this
	// should be passed in.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// The UID of the individual CTP request which kicked off this test run.
	// Note that distinct requests inside a multi-request CTP build will have
	// different UIDs.
	ParentRequestUid string `protobuf:"bytes,5,opt,name=parent_request_uid,json=parentRequestUid,proto3" json:"parent_request_uid,omitempty"`
	// The buildbucket ID of the CTP build that sent this test_runner request.
	ParentBuildId int64 `protobuf:"varint,6,opt,name=parent_build_id,json=parentBuildId,proto3" json:"parent_build_id,omitempty"`
	// AutotestKeyvals are (key, value) pairs that will be added to all
	// autotest tasks run.
	AutotestKeyvals map[string]string `` /* 194-byte string literal not displayed */
	// TestExecutionBehavior specifies how tests should be run.
	// This can include information about whether the tests should run and
	// if failures should be exonerated.
	DefaultTestExecutionBehavior test_platform.Request_Params_TestExecutionBehavior `` /* 206-byte string literal not displayed */
	// Container metadata to be used in test execution.
	ContainerMetadata *api1.ContainerMetadata `protobuf:"bytes,9,opt,name=container_metadata,json=containerMetadata,proto3" json:"container_metadata,omitempty"`
	// The retry attempt identifier. Details how many retries
	// this build has performed.
	RetryNumber int32 `protobuf:"varint,10,opt,name=retry_number,json=retryNumber,proto3" json:"retry_number,omitempty"`
	// Steps config for cft test execution. If not provided, all desired steps
	// will be executed by default.
	StepsConfig *common.CftStepsConfig `protobuf:"bytes,11,opt,name=steps_config,json=stepsConfig,proto3" json:"steps_config,omitempty"`
	// b/267268890: temporary flag to enable trv2 integration testing and
	// gradual rollout. Should be deprecated after full rollout.
	RunViaTrv2 bool `protobuf:"varint,12,opt,name=run_via_trv2,json=runViaTrv2,proto3" json:"run_via_trv2,omitempty"`
	// Translate the request into a CrosTestRunnerRequest within TRv2.
	// Requires run_via_trv2 set to true.
	TranslateTrv2Request bool `protobuf:"varint,13,opt,name=translate_trv2_request,json=translateTrv2Request,proto3" json:"translate_trv2_request,omitempty"`
	// Test case ids that have been filtered by CTP.
	// Uploaded to results as SKIPPED.
	FilteredTestCaseIds []string `protobuf:"bytes,14,rep,name=filtered_test_case_ids,json=filteredTestCaseIds,proto3" json:"filtered_test_case_ids,omitempty"`
	// contains filtered or unexported fields
}

CFTTestRequest represents a request for running an individual test suite via CFT workflow in skylab_test_runner recipe.

func (*CFTTestRequest) Descriptor deprecated

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

Deprecated: Use CFTTestRequest.ProtoReflect.Descriptor instead.

func (*CFTTestRequest) GetAutotestKeyvals

func (x *CFTTestRequest) GetAutotestKeyvals() map[string]string

func (*CFTTestRequest) GetCompanionDuts

func (x *CFTTestRequest) GetCompanionDuts() []*CFTTestRequest_Device

func (*CFTTestRequest) GetContainerMetadata

func (x *CFTTestRequest) GetContainerMetadata() *api1.ContainerMetadata

func (*CFTTestRequest) GetDeadline

func (x *CFTTestRequest) GetDeadline() *timestamppb.Timestamp

func (*CFTTestRequest) GetDefaultTestExecutionBehavior

func (x *CFTTestRequest) GetDefaultTestExecutionBehavior() test_platform.Request_Params_TestExecutionBehavior

func (*CFTTestRequest) GetFilteredTestCaseIds

func (x *CFTTestRequest) GetFilteredTestCaseIds() []string

func (*CFTTestRequest) GetParentBuildId

func (x *CFTTestRequest) GetParentBuildId() int64

func (*CFTTestRequest) GetParentRequestUid

func (x *CFTTestRequest) GetParentRequestUid() string

func (*CFTTestRequest) GetPrimaryDut

func (x *CFTTestRequest) GetPrimaryDut() *CFTTestRequest_Device

func (*CFTTestRequest) GetRetryNumber

func (x *CFTTestRequest) GetRetryNumber() int32

func (*CFTTestRequest) GetRunViaTrv2

func (x *CFTTestRequest) GetRunViaTrv2() bool

func (*CFTTestRequest) GetStepsConfig

func (x *CFTTestRequest) GetStepsConfig() *common.CftStepsConfig

func (*CFTTestRequest) GetTestSuites

func (x *CFTTestRequest) GetTestSuites() []*api.TestSuite

func (*CFTTestRequest) GetTranslateTrv2Request

func (x *CFTTestRequest) GetTranslateTrv2Request() bool

func (*CFTTestRequest) ProtoMessage

func (*CFTTestRequest) ProtoMessage()

func (*CFTTestRequest) ProtoReflect

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

func (*CFTTestRequest) Reset

func (x *CFTTestRequest) Reset()

func (*CFTTestRequest) String

func (x *CFTTestRequest) String() string

type CFTTestRequest_Device

type CFTTestRequest_Device struct {

	// DUT model to be provisioned.
	DutModel *api2.DutModel `protobuf:"bytes,1,opt,name=dut_model,json=dutModel,proto3" json:"dut_model,omitempty"`
	// Provision state for this device.
	ProvisionState *api.ProvisionState `protobuf:"bytes,2,opt,name=provision_state,json=provisionState,proto3" json:"provision_state,omitempty"`
	// ContainerMetadataKey is the key to search in the ContainerMetadata map
	// defined in container_metadata.proto
	ContainerMetadataKey string `protobuf:"bytes,3,opt,name=container_metadata_key,json=containerMetadataKey,proto3" json:"container_metadata_key,omitempty"`
	// contains filtered or unexported fields
}

func (*CFTTestRequest_Device) Descriptor deprecated

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

Deprecated: Use CFTTestRequest_Device.ProtoReflect.Descriptor instead.

func (*CFTTestRequest_Device) GetContainerMetadataKey

func (x *CFTTestRequest_Device) GetContainerMetadataKey() string

func (*CFTTestRequest_Device) GetDutModel

func (x *CFTTestRequest_Device) GetDutModel() *api2.DutModel

func (*CFTTestRequest_Device) GetProvisionState

func (x *CFTTestRequest_Device) GetProvisionState() *api.ProvisionState

func (*CFTTestRequest_Device) ProtoMessage

func (*CFTTestRequest_Device) ProtoMessage()

func (*CFTTestRequest_Device) ProtoReflect

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

func (*CFTTestRequest_Device) Reset

func (x *CFTTestRequest_Device) Reset()

func (*CFTTestRequest_Device) String

func (x *CFTTestRequest_Device) String() string

type CommonConfig

type CommonConfig struct {
	CrosFirmwareUpdateConfig *CommonConfig_CrosFirmwareUpdateConfig `` /* 137-byte string literal not displayed */
	// If true, indicates this bucket runs partner-private tests not intended to
	// be shared generally/through Omnilab
	PartnerPrivate bool `protobuf:"varint,2,opt,name=partner_private,json=partnerPrivate,proto3" json:"partner_private,omitempty"`
	// Config to define when test_runner should execute via trv2.
	EnableTrv2Config *Trv2Config `protobuf:"bytes,3,opt,name=enable_trv2_config,json=enableTrv2Config,proto3" json:"enable_trv2_config,omitempty"`
	// Config to define when test_runner should use ile-de-france.
	EnableIleDeFranceConfig *IleDeFranceConfig `` /* 136-byte string literal not displayed */
	// If true, the board/model realm we attempt to publish to will not be
	// verified via fetching a definitive list. This should only be enabled for
	// builders where fetching an (internal) file from git is not possible.
	//
	// If this is enabled and an invalid board-model realm is determined, it's
	// likely the result will not be visible to anyone.
	SkipBoardModelRealmCheck bool                        `` /* 140-byte string literal not displayed */
	RdbConfig                *CommonConfig_RdbConfig     `protobuf:"bytes,6,opt,name=rdb_config,json=rdbConfig,proto3" json:"rdb_config,omitempty"`
	UfsConfig                *CommonConfig_UfsConfig     `protobuf:"bytes,7,opt,name=ufs_config,json=ufsConfig,proto3" json:"ufs_config,omitempty"`
	PartnerConfig            *CommonConfig_PartnerConfig `protobuf:"bytes,8,opt,name=partner_config,json=partnerConfig,proto3" json:"partner_config,omitempty"`
	// contains filtered or unexported fields
}

Config defines configuration parameters of skylab_test_runner.

func (*CommonConfig) Descriptor deprecated

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

Deprecated: Use CommonConfig.ProtoReflect.Descriptor instead.

func (*CommonConfig) GetCrosFirmwareUpdateConfig

func (x *CommonConfig) GetCrosFirmwareUpdateConfig() *CommonConfig_CrosFirmwareUpdateConfig

func (*CommonConfig) GetEnableIleDeFranceConfig

func (x *CommonConfig) GetEnableIleDeFranceConfig() *IleDeFranceConfig

func (*CommonConfig) GetEnableTrv2Config

func (x *CommonConfig) GetEnableTrv2Config() *Trv2Config

func (*CommonConfig) GetPartnerConfig

func (x *CommonConfig) GetPartnerConfig() *CommonConfig_PartnerConfig

func (*CommonConfig) GetPartnerPrivate

func (x *CommonConfig) GetPartnerPrivate() bool

func (*CommonConfig) GetRdbConfig

func (x *CommonConfig) GetRdbConfig() *CommonConfig_RdbConfig

func (*CommonConfig) GetSkipBoardModelRealmCheck

func (x *CommonConfig) GetSkipBoardModelRealmCheck() bool

func (*CommonConfig) GetUfsConfig

func (x *CommonConfig) GetUfsConfig() *CommonConfig_UfsConfig

func (*CommonConfig) ProtoMessage

func (*CommonConfig) ProtoMessage()

func (*CommonConfig) ProtoReflect

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

func (*CommonConfig) Reset

func (x *CommonConfig) Reset()

func (*CommonConfig) String

func (x *CommonConfig) String() string

type CommonConfig_CrosFirmwareUpdateConfig

type CommonConfig_CrosFirmwareUpdateConfig struct {

	// Global flag to control OS bundled firmware update in prejob.
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Types that are assignable to CrosFirmwareUpdateSelector:
	//	*CommonConfig_CrosFirmwareUpdateConfig_AllowList
	//	*CommonConfig_CrosFirmwareUpdateConfig_BlockList
	CrosFirmwareUpdateSelector isCommonConfig_CrosFirmwareUpdateConfig_CrosFirmwareUpdateSelector `protobuf_oneof:"cros_firmware_update_selector"`
	// contains filtered or unexported fields
}

func (*CommonConfig_CrosFirmwareUpdateConfig) Descriptor deprecated

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

Deprecated: Use CommonConfig_CrosFirmwareUpdateConfig.ProtoReflect.Descriptor instead.

func (*CommonConfig_CrosFirmwareUpdateConfig) GetAllowList

func (*CommonConfig_CrosFirmwareUpdateConfig) GetBlockList

func (*CommonConfig_CrosFirmwareUpdateConfig) GetCrosFirmwareUpdateSelector

func (m *CommonConfig_CrosFirmwareUpdateConfig) GetCrosFirmwareUpdateSelector() isCommonConfig_CrosFirmwareUpdateConfig_CrosFirmwareUpdateSelector

func (*CommonConfig_CrosFirmwareUpdateConfig) GetEnabled

func (*CommonConfig_CrosFirmwareUpdateConfig) ProtoMessage

func (*CommonConfig_CrosFirmwareUpdateConfig) ProtoMessage()

func (*CommonConfig_CrosFirmwareUpdateConfig) ProtoReflect

func (*CommonConfig_CrosFirmwareUpdateConfig) Reset

func (*CommonConfig_CrosFirmwareUpdateConfig) String

type CommonConfig_CrosFirmwareUpdateConfig_AllowList

type CommonConfig_CrosFirmwareUpdateConfig_AllowList struct {
	// Only update OS bundled firmware on boards/models match with the list.
	AllowList *CommonConfig_CrosFirmwareUpdateConfig_CrosSlector `protobuf:"bytes,2,opt,name=allow_list,json=allowList,proto3,oneof"`
}

type CommonConfig_CrosFirmwareUpdateConfig_BlockList

type CommonConfig_CrosFirmwareUpdateConfig_BlockList struct {
	// Block OS bundled firmware update on boards/models match with the list.
	BlockList *CommonConfig_CrosFirmwareUpdateConfig_CrosSlector `protobuf:"bytes,3,opt,name=block_list,json=blockList,proto3,oneof"`
}

type CommonConfig_CrosFirmwareUpdateConfig_CrosSlector

type CommonConfig_CrosFirmwareUpdateConfig_CrosSlector struct {

	// List of ChromeOS board names.
	Boards []string `protobuf:"bytes,1,rep,name=boards,proto3" json:"boards,omitempty"`
	// List of ChromeOS model names.
	Models []string `protobuf:"bytes,2,rep,name=models,proto3" json:"models,omitempty"`
	// contains filtered or unexported fields
}

Selects DUTs based on its board/model to determine if OS bundled firmware update should be executed. Both board and model can be used and it allows overlap, e.g. it considers a match as long as one of criteria is matched.

func (*CommonConfig_CrosFirmwareUpdateConfig_CrosSlector) Descriptor deprecated

Deprecated: Use CommonConfig_CrosFirmwareUpdateConfig_CrosSlector.ProtoReflect.Descriptor instead.

func (*CommonConfig_CrosFirmwareUpdateConfig_CrosSlector) GetBoards

func (*CommonConfig_CrosFirmwareUpdateConfig_CrosSlector) GetModels

func (*CommonConfig_CrosFirmwareUpdateConfig_CrosSlector) ProtoMessage

func (*CommonConfig_CrosFirmwareUpdateConfig_CrosSlector) ProtoReflect

func (*CommonConfig_CrosFirmwareUpdateConfig_CrosSlector) Reset

func (*CommonConfig_CrosFirmwareUpdateConfig_CrosSlector) String

type CommonConfig_PartnerConfig

type CommonConfig_PartnerConfig struct {

	// Account ID for the partner.
	AccountId int64 `protobuf:"varint,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	// contains filtered or unexported fields
}

PartnerConfig determines any configuration around Partner settings.

func (*CommonConfig_PartnerConfig) Descriptor deprecated

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

Deprecated: Use CommonConfig_PartnerConfig.ProtoReflect.Descriptor instead.

func (*CommonConfig_PartnerConfig) GetAccountId

func (x *CommonConfig_PartnerConfig) GetAccountId() int64

func (*CommonConfig_PartnerConfig) ProtoMessage

func (*CommonConfig_PartnerConfig) ProtoMessage()

func (*CommonConfig_PartnerConfig) ProtoReflect

func (*CommonConfig_PartnerConfig) Reset

func (x *CommonConfig_PartnerConfig) Reset()

func (*CommonConfig_PartnerConfig) String

func (x *CommonConfig_PartnerConfig) String() string

type CommonConfig_RdbConfig

type CommonConfig_RdbConfig struct {

	// If request.results_upload_config.TestResultsUploadVisibility is
	// CUSTOM_REALM this value will be the realm the configs are uploaded to.
	CustomRealmName string `protobuf:"bytes,1,opt,name=custom_realm_name,json=customRealmName,proto3" json:"custom_realm_name,omitempty"`
	// contains filtered or unexported fields
}

RdbConfig determines any configuration around ResultDB uploads.

func (*CommonConfig_RdbConfig) Descriptor deprecated

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

Deprecated: Use CommonConfig_RdbConfig.ProtoReflect.Descriptor instead.

func (*CommonConfig_RdbConfig) GetCustomRealmName

func (x *CommonConfig_RdbConfig) GetCustomRealmName() string

func (*CommonConfig_RdbConfig) ProtoMessage

func (*CommonConfig_RdbConfig) ProtoMessage()

func (*CommonConfig_RdbConfig) ProtoReflect

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

func (*CommonConfig_RdbConfig) Reset

func (x *CommonConfig_RdbConfig) Reset()

func (*CommonConfig_RdbConfig) String

func (x *CommonConfig_RdbConfig) String() string

type CommonConfig_UfsConfig

type CommonConfig_UfsConfig struct {

	// ufs namespace to be used for talking to ufs.
	UfsNamespace string `protobuf:"bytes,1,opt,name=ufs_namespace,json=ufsNamespace,proto3" json:"ufs_namespace,omitempty"`
	// contains filtered or unexported fields
}

UfsConfig determines any configuration around Ufs api calls.

func (*CommonConfig_UfsConfig) Descriptor deprecated

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

Deprecated: Use CommonConfig_UfsConfig.ProtoReflect.Descriptor instead.

func (*CommonConfig_UfsConfig) GetUfsNamespace

func (x *CommonConfig_UfsConfig) GetUfsNamespace() string

func (*CommonConfig_UfsConfig) ProtoMessage

func (*CommonConfig_UfsConfig) ProtoMessage()

func (*CommonConfig_UfsConfig) ProtoReflect

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

func (*CommonConfig_UfsConfig) Reset

func (x *CommonConfig_UfsConfig) Reset()

func (*CommonConfig_UfsConfig) String

func (x *CommonConfig_UfsConfig) String() string

type Config

type Config struct {
	Lab     *Config_Lab     `protobuf:"bytes,1,opt,name=lab,proto3" json:"lab,omitempty"`
	Harness *Config_Harness `protobuf:"bytes,2,opt,name=harness,proto3" json:"harness,omitempty"`
	Output  *Config_Output  `protobuf:"bytes,3,opt,name=output,proto3" json:"output,omitempty"`
	// Result flow topic: test_runner publishes messages to this topic at the
	// start and the end of the build.
	// The messages in this topic should be ACKed only by the result_flow
	// pipeline.
	ResultFlowPubsub  *Config_PubSub                `protobuf:"bytes,4,opt,name=result_flow_pubsub,json=resultFlowPubsub,proto3" json:"result_flow_pubsub,omitempty"`
	LogDataUploadStep *phosphorus.LogDataUploadStep `protobuf:"bytes,5,opt,name=log_data_upload_step,json=logDataUploadStep,proto3" json:"log_data_upload_step,omitempty"`
	FetchCrashesStep  *phosphorus.FetchCrashesStep  `protobuf:"bytes,6,opt,name=fetch_crashes_step,json=fetchCrashesStep,proto3" json:"fetch_crashes_step,omitempty"`
	PrejobStep        *phosphorus.PrejobStep        `protobuf:"bytes,7,opt,name=prejob_step,json=prejobStep,proto3" json:"prejob_step,omitempty"`
	// contains filtered or unexported fields
}

Config defines configuration parameters of skylab_test_runner.

func (*Config) Descriptor deprecated

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetFetchCrashesStep

func (x *Config) GetFetchCrashesStep() *phosphorus.FetchCrashesStep

func (*Config) GetHarness

func (x *Config) GetHarness() *Config_Harness

func (*Config) GetLab

func (x *Config) GetLab() *Config_Lab

func (*Config) GetLogDataUploadStep

func (x *Config) GetLogDataUploadStep() *phosphorus.LogDataUploadStep

func (*Config) GetOutput

func (x *Config) GetOutput() *Config_Output

func (*Config) GetPrejobStep

func (x *Config) GetPrejobStep() *phosphorus.PrejobStep

func (*Config) GetResultFlowPubsub

func (x *Config) GetResultFlowPubsub() *Config_PubSub

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

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

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type Config_Harness

type Config_Harness struct {

	// Autotest directory inside the drone container,
	// e.g. "/usr/local/autotest".
	AutotestDir string `protobuf:"bytes,1,opt,name=autotest_dir,json=autotestDir,proto3" json:"autotest_dir,omitempty"`
	// The name of the base lxc image used for Server Side Packaging (SSP).
	//
	// autoserv fetches the base image from a hard-coded path on Google
	// Storage: gs://abci-ssp/autotest-containers/{name}.tar.xz
	//
	// See go/ctp-ssp for an overview of SSP.
	SspBaseImageName string `protobuf:"bytes,3,opt,name=ssp_base_image_name,json=sspBaseImageName,proto3" json:"ssp_base_image_name,omitempty"`
	// The maximum duration for prejobs (e.g. provisioning).
	PrejobDeadlineSeconds int64 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Harness defines configuration parameters related to the test harness (autotest, tast, etc).

func (*Config_Harness) Descriptor deprecated

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

Deprecated: Use Config_Harness.ProtoReflect.Descriptor instead.

func (*Config_Harness) GetAutotestDir

func (x *Config_Harness) GetAutotestDir() string

func (*Config_Harness) GetPrejobDeadlineSeconds

func (x *Config_Harness) GetPrejobDeadlineSeconds() int64

func (*Config_Harness) GetSspBaseImageName

func (x *Config_Harness) GetSspBaseImageName() string

func (*Config_Harness) ProtoMessage

func (*Config_Harness) ProtoMessage()

func (*Config_Harness) ProtoReflect

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

func (*Config_Harness) Reset

func (x *Config_Harness) Reset()

func (*Config_Harness) String

func (x *Config_Harness) String() string

type Config_Lab

type Config_Lab struct {

	// Admin service host, e.g. foo.appspot.com.
	AdminService string `protobuf:"bytes,1,opt,name=admin_service,json=adminService,proto3" json:"admin_service,omitempty"`
	// Inventory V2 service host, e.g. cros-lab-inventory.appspot.com.
	CrosInventoryService string `protobuf:"bytes,2,opt,name=cros_inventory_service,json=crosInventoryService,proto3" json:"cros_inventory_service,omitempty"`
	// Unified Fleet System service host, e.g. ufs.api.cr.dev.
	CrosUfsService string `protobuf:"bytes,3,opt,name=cros_ufs_service,json=crosUfsService,proto3" json:"cros_ufs_service,omitempty"`
	// contains filtered or unexported fields
}

Lab defines configuration parameters related to the lab and the lab platform services.

func (*Config_Lab) Descriptor deprecated

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

Deprecated: Use Config_Lab.ProtoReflect.Descriptor instead.

func (*Config_Lab) GetAdminService

func (x *Config_Lab) GetAdminService() string

func (*Config_Lab) GetCrosInventoryService

func (x *Config_Lab) GetCrosInventoryService() string

func (*Config_Lab) GetCrosUfsService

func (x *Config_Lab) GetCrosUfsService() string

func (*Config_Lab) ProtoMessage

func (*Config_Lab) ProtoMessage()

func (*Config_Lab) ProtoReflect

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

func (*Config_Lab) Reset

func (x *Config_Lab) Reset()

func (*Config_Lab) String

func (x *Config_Lab) String() string

type Config_Output

type Config_Output struct {

	// A Google Storage path prefix to upload all log-data to synchronously.
	// Reflected in the test_platform.skylab_test_runner.Result.log_data
	// returned by the task.
	LogDataGsRoot string `protobuf:"bytes,2,opt,name=log_data_gs_root,json=logDataGsRoot,proto3" json:"log_data_gs_root,omitempty"`
	// contains filtered or unexported fields
}

Output defines parameters around how the task will deliver output to the callers, e.g. Google Storage bucket.

func (*Config_Output) Descriptor deprecated

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

Deprecated: Use Config_Output.ProtoReflect.Descriptor instead.

func (*Config_Output) GetLogDataGsRoot

func (x *Config_Output) GetLogDataGsRoot() string

func (*Config_Output) ProtoMessage

func (*Config_Output) ProtoMessage()

func (*Config_Output) ProtoReflect

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

func (*Config_Output) Reset

func (x *Config_Output) Reset()

func (*Config_Output) String

func (x *Config_Output) String() string

type Config_PubSub

type Config_PubSub struct {
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Topic   string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

PubSub defines the configuration parameters for PubSub topic.

func (*Config_PubSub) Descriptor deprecated

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

Deprecated: Use Config_PubSub.ProtoReflect.Descriptor instead.

func (*Config_PubSub) GetProject

func (x *Config_PubSub) GetProject() string

func (*Config_PubSub) GetTopic

func (x *Config_PubSub) GetTopic() string

func (*Config_PubSub) ProtoMessage

func (*Config_PubSub) ProtoMessage()

func (*Config_PubSub) ProtoReflect

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

func (*Config_PubSub) Reset

func (x *Config_PubSub) Reset()

func (*Config_PubSub) String

func (x *Config_PubSub) String() string

type ContainerRequest

type ContainerRequest struct {

	// Identifier for DynamicDependencies to inject this container's IpEnpoint, eg
	// cros-provision, cros-dut, etc.
	DynamicIdentifier string        `protobuf:"bytes,1,opt,name=dynamic_identifier,json=dynamicIdentifier,proto3" json:"dynamic_identifier,omitempty"`
	Container         *api.Template `protobuf:"bytes,2,opt,name=container,proto3" json:"container,omitempty"`
	// Dynamic dependencies for the templated container.
	DynamicDeps []*DynamicDep `protobuf:"bytes,3,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// Identifiable file inputs for the binary call within the generic container.
	Inputs []*ContainerRequest_FileInput `protobuf:"bytes,4,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// default = "host"
	Network           string `protobuf:"bytes,5,opt,name=network,proto3" json:"network,omitempty"`
	ContainerImageKey string `protobuf:"bytes,6,opt,name=container_image_key,json=containerImageKey,proto3" json:"container_image_key,omitempty"`
	// Location of image that can be directly pulled by docker.
	// e.g. us-docker.pkg.dev/cros-registry/test-services/cros-dut:latest
	// If set, ignore container_image_key.
	ContainerImagePath string `protobuf:"bytes,7,opt,name=container_image_path,json=containerImagePath,proto3" json:"container_image_path,omitempty"`
	// contains filtered or unexported fields
}

Starts a container and uploads its IpEndpoint to TestRunnerV2's dynamic map of locally exposed information.

Will not support dynamic injections into the container's start arguments. If the generic template is not enough, then a specific template should be implemented.

func (*ContainerRequest) Descriptor deprecated

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

Deprecated: Use ContainerRequest.ProtoReflect.Descriptor instead.

func (*ContainerRequest) GetContainer

func (x *ContainerRequest) GetContainer() *api.Template

func (*ContainerRequest) GetContainerImageKey

func (x *ContainerRequest) GetContainerImageKey() string

func (*ContainerRequest) GetContainerImagePath

func (x *ContainerRequest) GetContainerImagePath() string

func (*ContainerRequest) GetDynamicDeps

func (x *ContainerRequest) GetDynamicDeps() []*DynamicDep

func (*ContainerRequest) GetDynamicIdentifier

func (x *ContainerRequest) GetDynamicIdentifier() string

func (*ContainerRequest) GetInputs

func (x *ContainerRequest) GetInputs() []*ContainerRequest_FileInput

func (*ContainerRequest) GetNetwork

func (x *ContainerRequest) GetNetwork() string

func (*ContainerRequest) ProtoMessage

func (*ContainerRequest) ProtoMessage()

func (*ContainerRequest) ProtoReflect

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

func (*ContainerRequest) Reset

func (x *ContainerRequest) Reset()

func (*ContainerRequest) String

func (x *ContainerRequest) String() string

type ContainerRequest_FileInput

type ContainerRequest_FileInput struct {
	Identifier string     `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Content    *anypb.Any `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// Dependencies to be injected within 'context'
	DynamicDeps []*DynamicDep `protobuf:"bytes,3,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// contains filtered or unexported fields
}

Starting a binary within a container sometimes requires a "metadata" file or some type of proto file as input.

func (*ContainerRequest_FileInput) Descriptor deprecated

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

Deprecated: Use ContainerRequest_FileInput.ProtoReflect.Descriptor instead.

func (*ContainerRequest_FileInput) GetContent

func (x *ContainerRequest_FileInput) GetContent() *anypb.Any

func (*ContainerRequest_FileInput) GetDynamicDeps

func (x *ContainerRequest_FileInput) GetDynamicDeps() []*DynamicDep

func (*ContainerRequest_FileInput) GetIdentifier

func (x *ContainerRequest_FileInput) GetIdentifier() string

func (*ContainerRequest_FileInput) ProtoMessage

func (*ContainerRequest_FileInput) ProtoMessage()

func (*ContainerRequest_FileInput) ProtoReflect

func (*ContainerRequest_FileInput) Reset

func (x *ContainerRequest_FileInput) Reset()

func (*ContainerRequest_FileInput) String

func (x *ContainerRequest_FileInput) String() string

type CrosTestRunnerParams

type CrosTestRunnerParams struct {
	TestSuites []*api.TestSuite `protobuf:"bytes,1,rep,name=test_suites,json=testSuites,proto3" json:"test_suites,omitempty"`
	// Container metadata to be used in test execution.
	ContainerMetadata *api1.ContainerMetadata `protobuf:"bytes,2,opt,name=container_metadata,json=containerMetadata,proto3" json:"container_metadata,omitempty"`
	// Keyvals are (key, value) pairs
	Keyvals map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

Common parameters to include when sending a CrosTestRunnerRequest

func (*CrosTestRunnerParams) Descriptor deprecated

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

Deprecated: Use CrosTestRunnerParams.ProtoReflect.Descriptor instead.

func (*CrosTestRunnerParams) GetContainerMetadata

func (x *CrosTestRunnerParams) GetContainerMetadata() *api1.ContainerMetadata

func (*CrosTestRunnerParams) GetKeyvals

func (x *CrosTestRunnerParams) GetKeyvals() map[string]string

func (*CrosTestRunnerParams) GetTestSuites

func (x *CrosTestRunnerParams) GetTestSuites() []*api.TestSuite

func (*CrosTestRunnerParams) ProtoMessage

func (*CrosTestRunnerParams) ProtoMessage()

func (*CrosTestRunnerParams) ProtoReflect

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

func (*CrosTestRunnerParams) Reset

func (x *CrosTestRunnerParams) Reset()

func (*CrosTestRunnerParams) String

func (x *CrosTestRunnerParams) String() string

type CrosTestRunnerRequest

type CrosTestRunnerRequest struct {

	// Types that are assignable to StartRequest:
	//	*CrosTestRunnerRequest_Build
	//	*CrosTestRunnerRequest_Server
	StartRequest isCrosTestRunnerRequest_StartRequest `protobuf_oneof:"start_request"`
	Params       *CrosTestRunnerParams                `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	OrderedTasks []*CrosTestRunnerRequest_Task        `protobuf:"bytes,4,rep,name=ordered_tasks,json=orderedTasks,proto3" json:"ordered_tasks,omitempty"`
	// contains filtered or unexported fields
}

CrosTestRunnerRequest is an input to CrosTestRunner that provides greater flexibility in regards to the variability and order by which test runner tasks are executed.

next number = 5;

func (*CrosTestRunnerRequest) Descriptor deprecated

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

Deprecated: Use CrosTestRunnerRequest.ProtoReflect.Descriptor instead.

func (*CrosTestRunnerRequest) GetBuild

func (x *CrosTestRunnerRequest) GetBuild() *BuildMode

func (*CrosTestRunnerRequest) GetOrderedTasks

func (x *CrosTestRunnerRequest) GetOrderedTasks() []*CrosTestRunnerRequest_Task

func (*CrosTestRunnerRequest) GetParams

func (*CrosTestRunnerRequest) GetServer

func (*CrosTestRunnerRequest) GetStartRequest

func (m *CrosTestRunnerRequest) GetStartRequest() isCrosTestRunnerRequest_StartRequest

func (*CrosTestRunnerRequest) ProtoMessage

func (*CrosTestRunnerRequest) ProtoMessage()

func (*CrosTestRunnerRequest) ProtoReflect

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

func (*CrosTestRunnerRequest) Reset

func (x *CrosTestRunnerRequest) Reset()

func (*CrosTestRunnerRequest) String

func (x *CrosTestRunnerRequest) String() string

type CrosTestRunnerRequest_Build

type CrosTestRunnerRequest_Build struct {
	Build *BuildMode `protobuf:"bytes,1,opt,name=build,proto3,oneof"`
}

type CrosTestRunnerRequest_Server

type CrosTestRunnerRequest_Server struct {
	Server *CrosTestRunnerServerStartRequest `protobuf:"bytes,2,opt,name=server,proto3,oneof"`
}

type CrosTestRunnerRequest_Task

type CrosTestRunnerRequest_Task struct {

	// List of containers to run for this task.
	// ie container for cros-dut, then for cros-provision.
	OrderedContainerRequests []*ContainerRequest `` /* 135-byte string literal not displayed */
	// Types that are assignable to Task:
	//	*CrosTestRunnerRequest_Task_Provision
	//	*CrosTestRunnerRequest_Task_PreTest
	//	*CrosTestRunnerRequest_Task_Test
	//	*CrosTestRunnerRequest_Task_PostTest
	//	*CrosTestRunnerRequest_Task_Publish
	//	*CrosTestRunnerRequest_Task_Generic
	Task     isCrosTestRunnerRequest_Task_Task `protobuf_oneof:"task"`
	Required bool                              `protobuf:"varint,7,opt,name=required,proto3" json:"required,omitempty"`
	// contains filtered or unexported fields
}

func (*CrosTestRunnerRequest_Task) Descriptor deprecated

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

Deprecated: Use CrosTestRunnerRequest_Task.ProtoReflect.Descriptor instead.

func (*CrosTestRunnerRequest_Task) GetGeneric

func (x *CrosTestRunnerRequest_Task) GetGeneric() *GenericRequest

func (*CrosTestRunnerRequest_Task) GetOrderedContainerRequests

func (x *CrosTestRunnerRequest_Task) GetOrderedContainerRequests() []*ContainerRequest

func (*CrosTestRunnerRequest_Task) GetPostTest

func (x *CrosTestRunnerRequest_Task) GetPostTest() *PostTestRequest

func (*CrosTestRunnerRequest_Task) GetPreTest

func (x *CrosTestRunnerRequest_Task) GetPreTest() *PreTestRequest

func (*CrosTestRunnerRequest_Task) GetProvision

func (x *CrosTestRunnerRequest_Task) GetProvision() *ProvisionRequest

func (*CrosTestRunnerRequest_Task) GetPublish

func (x *CrosTestRunnerRequest_Task) GetPublish() *PublishRequest

func (*CrosTestRunnerRequest_Task) GetRequired

func (x *CrosTestRunnerRequest_Task) GetRequired() bool

func (*CrosTestRunnerRequest_Task) GetTask

func (m *CrosTestRunnerRequest_Task) GetTask() isCrosTestRunnerRequest_Task_Task

func (*CrosTestRunnerRequest_Task) GetTest

func (*CrosTestRunnerRequest_Task) ProtoMessage

func (*CrosTestRunnerRequest_Task) ProtoMessage()

func (*CrosTestRunnerRequest_Task) ProtoReflect

func (*CrosTestRunnerRequest_Task) Reset

func (x *CrosTestRunnerRequest_Task) Reset()

func (*CrosTestRunnerRequest_Task) String

func (x *CrosTestRunnerRequest_Task) String() string

type CrosTestRunnerRequest_Task_Generic

type CrosTestRunnerRequest_Task_Generic struct {
	Generic *GenericRequest `protobuf:"bytes,8,opt,name=generic,proto3,oneof"`
}

type CrosTestRunnerRequest_Task_PostTest

type CrosTestRunnerRequest_Task_PostTest struct {
	PostTest *PostTestRequest `protobuf:"bytes,5,opt,name=post_test,json=postTest,proto3,oneof"`
}

type CrosTestRunnerRequest_Task_PreTest

type CrosTestRunnerRequest_Task_PreTest struct {
	PreTest *PreTestRequest `protobuf:"bytes,3,opt,name=pre_test,json=preTest,proto3,oneof"`
}

type CrosTestRunnerRequest_Task_Provision

type CrosTestRunnerRequest_Task_Provision struct {
	Provision *ProvisionRequest `protobuf:"bytes,2,opt,name=provision,proto3,oneof"`
}

type CrosTestRunnerRequest_Task_Publish

type CrosTestRunnerRequest_Task_Publish struct {
	Publish *PublishRequest `protobuf:"bytes,6,opt,name=publish,proto3,oneof"`
}

type CrosTestRunnerRequest_Task_Test

type CrosTestRunnerRequest_Task_Test struct {
	Test *TestRequest `protobuf:"bytes,4,opt,name=test,proto3,oneof"`
}

type CrosTestRunnerServerStartRequest

type CrosTestRunnerServerStartRequest struct {
	HostName              string           `protobuf:"bytes,1,opt,name=host_name,json=hostName,proto3" json:"host_name,omitempty"`
	LogDataGsRoot         string           `protobuf:"bytes,2,opt,name=log_data_gs_root,json=logDataGsRoot,proto3" json:"log_data_gs_root,omitempty"`
	DockerKeyFileLocation string           `` /* 128-byte string literal not displayed */
	DutTopology           *api.DutTopology `protobuf:"bytes,4,opt,name=dut_topology,json=dutTopology,proto3" json:"dut_topology,omitempty"`
	UseDockerKeyDirectly  bool             `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

CrosTestRunnerServerStartRequest represents the server start request for cros test runner service. Any data that should be used throughout the whole service session should be provided through this proto.

func (*CrosTestRunnerServerStartRequest) Descriptor deprecated

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

Deprecated: Use CrosTestRunnerServerStartRequest.ProtoReflect.Descriptor instead.

func (*CrosTestRunnerServerStartRequest) GetDockerKeyFileLocation

func (x *CrosTestRunnerServerStartRequest) GetDockerKeyFileLocation() string

func (*CrosTestRunnerServerStartRequest) GetDutTopology

func (x *CrosTestRunnerServerStartRequest) GetDutTopology() *api.DutTopology

func (*CrosTestRunnerServerStartRequest) GetHostName

func (x *CrosTestRunnerServerStartRequest) GetHostName() string

func (*CrosTestRunnerServerStartRequest) GetLogDataGsRoot

func (x *CrosTestRunnerServerStartRequest) GetLogDataGsRoot() string

func (*CrosTestRunnerServerStartRequest) GetUseDockerKeyDirectly

func (x *CrosTestRunnerServerStartRequest) GetUseDockerKeyDirectly() bool

func (*CrosTestRunnerServerStartRequest) ProtoMessage

func (*CrosTestRunnerServerStartRequest) ProtoMessage()

func (*CrosTestRunnerServerStartRequest) ProtoReflect

func (*CrosTestRunnerServerStartRequest) Reset

func (*CrosTestRunnerServerStartRequest) String

type CrosTestRunnerServiceClient

type CrosTestRunnerServiceClient interface {
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
}

CrosTestRunnerServiceClient is the client API for CrosTestRunnerService 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.

type CrosTestRunnerServiceServer

type CrosTestRunnerServiceServer interface {
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	// contains filtered or unexported methods
}

CrosTestRunnerServiceServer is the server API for CrosTestRunnerService service. All implementations must embed UnimplementedCrosTestRunnerServiceServer for forward compatibility

type DynamicDep

type DynamicDep struct {

	// camelCase object identifier, seperated by "."
	// ie dutServer.address
	// If the key needs to point to an array index, simply put the index
	// after the seperator.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The identifier of the value within TestRunnerV2's map of
	// locally exposed values.
	// Separate by "." if an interior value of a top-level mapped
	// object is required.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Some information within TestRunnerV2 is required by the services it runs. This information is not known at the time of request, and thus needs to be dynamically injected within the request. This provides the definition required to handle the injection, however, the exact object being injected is unknown to this proto and must be handled by the implementation.

func (*DynamicDep) Descriptor deprecated

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

Deprecated: Use DynamicDep.ProtoReflect.Descriptor instead.

func (*DynamicDep) GetKey

func (x *DynamicDep) GetKey() string

func (*DynamicDep) GetValue

func (x *DynamicDep) GetValue() string

func (*DynamicDep) ProtoMessage

func (*DynamicDep) ProtoMessage()

func (*DynamicDep) ProtoReflect

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

func (*DynamicDep) Reset

func (x *DynamicDep) Reset()

func (*DynamicDep) String

func (x *DynamicDep) String() string

type ExecuteRequest

type ExecuteRequest struct {

	// Only one suite will be supported inside testplans.
	// Different suites will have to make separate rpc calls.
	// If test_plan provided, cft_test_request.test_suites will be constructed
	// from it.
	TestPlan *test_platform.Request_TestPlan `protobuf:"bytes,1,opt,name=test_plan,json=testPlan,proto3" json:"test_plan,omitempty"`
	// cft_test_request is always required. This also includes steps config
	// which will provide clients maximum freedom to choose which steps to
	// execute.
	CftTestRequest *CFTTestRequest `protobuf:"bytes,2,opt,name=cft_test_request,json=cftTestRequest,proto3" json:"cft_test_request,omitempty"`
	// Cros-tool-runner cipd version to use.
	CtrCipdVersion string `protobuf:"bytes,3,opt,name=ctr_cipd_version,json=ctrCipdVersion,proto3" json:"ctr_cipd_version,omitempty"`
	// Local path to cros-tool-runner binary to run with; this field is meant to
	// be an alternative to ctr_cipd_version and will take priority over it
	PathToCipdBin string `protobuf:"bytes,5,opt,name=path_to_cipd_bin,json=pathToCipdBin,proto3" json:"path_to_cipd_bin,omitempty"`
	// Path to where the test artifacts are going to be stored. It's callers
	// responsibility to make sure this path is valid and unique per execution.
	ArtifactsPath string `protobuf:"bytes,4,opt,name=artifacts_path,json=artifactsPath,proto3" json:"artifacts_path,omitempty"`
	// contains filtered or unexported fields
}

ExecuteRequest represents the request for cros test runner service.

func (*ExecuteRequest) Descriptor deprecated

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetArtifactsPath

func (x *ExecuteRequest) GetArtifactsPath() string

func (*ExecuteRequest) GetCftTestRequest

func (x *ExecuteRequest) GetCftTestRequest() *CFTTestRequest

func (*ExecuteRequest) GetCtrCipdVersion

func (x *ExecuteRequest) GetCtrCipdVersion() string

func (*ExecuteRequest) GetPathToCipdBin

func (x *ExecuteRequest) GetPathToCipdBin() string

func (*ExecuteRequest) GetTestPlan

func (x *ExecuteRequest) GetTestPlan() *test_platform.Request_TestPlan

func (*ExecuteRequest) ProtoMessage

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect

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

func (*ExecuteRequest) Reset

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String

func (x *ExecuteRequest) String() string

type ExecuteResponse

type ExecuteResponse struct {
	Result *Result `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

ExecuteResponse represents the response for cros test runner service.

func (*ExecuteResponse) Descriptor deprecated

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetResult

func (x *ExecuteResponse) GetResult() *Result

func (*ExecuteResponse) ProtoMessage

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect

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

func (*ExecuteResponse) Reset

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String

func (x *ExecuteResponse) String() string

type GenericRequest

type GenericRequest struct {
	ServiceAddress *api2.IpEndpoint         `protobuf:"bytes,1,opt,name=service_address,json=serviceAddress,proto3" json:"service_address,omitempty"`
	StartRequest   *api.GenericStartRequest `protobuf:"bytes,2,opt,name=start_request,json=startRequest,proto3" json:"start_request,omitempty"`
	RunRequest     *api.GenericRunRequest   `protobuf:"bytes,3,opt,name=run_request,json=runRequest,proto3" json:"run_request,omitempty"`
	StopRequest    *api.GenericStopRequest  `protobuf:"bytes,4,opt,name=stop_request,json=stopRequest,proto3" json:"stop_request,omitempty"`
	DynamicDeps    []*DynamicDep            `protobuf:"bytes,5,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// contains filtered or unexported fields
}

GenericRequest targets request towards services that implement the GenericService.

func (*GenericRequest) Descriptor deprecated

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

Deprecated: Use GenericRequest.ProtoReflect.Descriptor instead.

func (*GenericRequest) GetDynamicDeps

func (x *GenericRequest) GetDynamicDeps() []*DynamicDep

func (*GenericRequest) GetRunRequest

func (x *GenericRequest) GetRunRequest() *api.GenericRunRequest

func (*GenericRequest) GetServiceAddress

func (x *GenericRequest) GetServiceAddress() *api2.IpEndpoint

func (*GenericRequest) GetStartRequest

func (x *GenericRequest) GetStartRequest() *api.GenericStartRequest

func (*GenericRequest) GetStopRequest

func (x *GenericRequest) GetStopRequest() *api.GenericStopRequest

func (*GenericRequest) ProtoMessage

func (*GenericRequest) ProtoMessage()

func (*GenericRequest) ProtoReflect

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

func (*GenericRequest) Reset

func (x *GenericRequest) Reset()

func (*GenericRequest) String

func (x *GenericRequest) String() string

type IleDeFranceConfig

type IleDeFranceConfig struct {

	// Global flag to control whether the ile-de-france config is allowed to run
	// at all or not
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// Determine whether ile-de-france runs are permitted or not by specifying an
	// allowlist or a denylist.
	//
	// Types that are assignable to IleDeFranceSelector:
	//	*IleDeFranceConfig_AllowList
	//	*IleDeFranceConfig_DenyList
	IleDeFranceSelector isIleDeFranceConfig_IleDeFranceSelector `protobuf_oneof:"ile_de_france_selector"`
	// contains filtered or unexported fields
}

IleDeFranceConfig controls whether ile-de-france (the lightweight verifier) is enabled or disabled for any given model.

func (*IleDeFranceConfig) Descriptor deprecated

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

Deprecated: Use IleDeFranceConfig.ProtoReflect.Descriptor instead.

func (*IleDeFranceConfig) GetAllowList

func (*IleDeFranceConfig) GetDenyList

func (*IleDeFranceConfig) GetEnabled

func (x *IleDeFranceConfig) GetEnabled() bool

func (*IleDeFranceConfig) GetIleDeFranceSelector

func (m *IleDeFranceConfig) GetIleDeFranceSelector() isIleDeFranceConfig_IleDeFranceSelector

func (*IleDeFranceConfig) ProtoMessage

func (*IleDeFranceConfig) ProtoMessage()

func (*IleDeFranceConfig) ProtoReflect

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

func (*IleDeFranceConfig) Reset

func (x *IleDeFranceConfig) Reset()

func (*IleDeFranceConfig) String

func (x *IleDeFranceConfig) String() string

type IleDeFranceConfig_AllowList

type IleDeFranceConfig_AllowList struct {
	AllowList *IleDeFranceConfig_ModelList `protobuf:"bytes,2,opt,name=allow_list,json=allowList,proto3,oneof"`
}

type IleDeFranceConfig_DenyList

type IleDeFranceConfig_DenyList struct {
	DenyList *IleDeFranceConfig_ModelList `protobuf:"bytes,3,opt,name=deny_list,json=denyList,proto3,oneof"`
}

type IleDeFranceConfig_ModelList

type IleDeFranceConfig_ModelList struct {
	Models []string `protobuf:"bytes,1,rep,name=models,proto3" json:"models,omitempty"`
	// contains filtered or unexported fields
}

A list of models to allow or deny, as appropriate.

func (*IleDeFranceConfig_ModelList) Descriptor deprecated

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

Deprecated: Use IleDeFranceConfig_ModelList.ProtoReflect.Descriptor instead.

func (*IleDeFranceConfig_ModelList) GetModels

func (x *IleDeFranceConfig_ModelList) GetModels() []string

func (*IleDeFranceConfig_ModelList) ProtoMessage

func (*IleDeFranceConfig_ModelList) ProtoMessage()

func (*IleDeFranceConfig_ModelList) ProtoReflect

func (*IleDeFranceConfig_ModelList) Reset

func (x *IleDeFranceConfig_ModelList) Reset()

func (*IleDeFranceConfig_ModelList) String

func (x *IleDeFranceConfig_ModelList) String() string

type PostTestRequest

type PostTestRequest struct {
	ServiceAddress  *api2.IpEndpoint `protobuf:"bytes,1,opt,name=service_address,json=serviceAddress,proto3" json:"service_address,omitempty"`
	PostTestRequest *anypb.Any       `protobuf:"bytes,2,opt,name=post_test_request,json=postTestRequest,proto3" json:"post_test_request,omitempty"`
	DynamicDeps     []*DynamicDep    `protobuf:"bytes,3,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// RunActivityRequest will trigger a call to RunActivity
	// within the rpc service `PostTestService`.
	RunActivityRequest *api.RunActivityRequest `protobuf:"bytes,4,opt,name=run_activity_request,json=runActivityRequest,proto3" json:"run_activity_request,omitempty"`
	// contains filtered or unexported fields
}

PostTestRequest targets requests towards services that implement the PostTestService.

func (*PostTestRequest) Descriptor deprecated

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

Deprecated: Use PostTestRequest.ProtoReflect.Descriptor instead.

func (*PostTestRequest) GetDynamicDeps

func (x *PostTestRequest) GetDynamicDeps() []*DynamicDep

func (*PostTestRequest) GetPostTestRequest

func (x *PostTestRequest) GetPostTestRequest() *anypb.Any

func (*PostTestRequest) GetRunActivityRequest

func (x *PostTestRequest) GetRunActivityRequest() *api.RunActivityRequest

func (*PostTestRequest) GetServiceAddress

func (x *PostTestRequest) GetServiceAddress() *api2.IpEndpoint

func (*PostTestRequest) ProtoMessage

func (*PostTestRequest) ProtoMessage()

func (*PostTestRequest) ProtoReflect

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

func (*PostTestRequest) Reset

func (x *PostTestRequest) Reset()

func (*PostTestRequest) String

func (x *PostTestRequest) String() string

type PreTestRequest

type PreTestRequest struct {
	ServiceAddress *api2.IpEndpoint `protobuf:"bytes,1,opt,name=service_address,json=serviceAddress,proto3" json:"service_address,omitempty"`
	PreTestRequest *anypb.Any       `protobuf:"bytes,2,opt,name=pre_test_request,json=preTestRequest,proto3" json:"pre_test_request,omitempty"`
	DynamicDeps    []*DynamicDep    `protobuf:"bytes,3,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// contains filtered or unexported fields
}

PreTestRequest targets requests towards services that implement the PreTestService.

func (*PreTestRequest) Descriptor deprecated

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

Deprecated: Use PreTestRequest.ProtoReflect.Descriptor instead.

func (*PreTestRequest) GetDynamicDeps

func (x *PreTestRequest) GetDynamicDeps() []*DynamicDep

func (*PreTestRequest) GetPreTestRequest

func (x *PreTestRequest) GetPreTestRequest() *anypb.Any

func (*PreTestRequest) GetServiceAddress

func (x *PreTestRequest) GetServiceAddress() *api2.IpEndpoint

func (*PreTestRequest) ProtoMessage

func (*PreTestRequest) ProtoMessage()

func (*PreTestRequest) ProtoReflect

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

func (*PreTestRequest) Reset

func (x *PreTestRequest) Reset()

func (*PreTestRequest) String

func (x *PreTestRequest) String() string

type ProvisionRequest

type ProvisionRequest struct {
	ServiceAddress *api2.IpEndpoint             `protobuf:"bytes,1,opt,name=service_address,json=serviceAddress,proto3" json:"service_address,omitempty"`
	StartupRequest *api.ProvisionStartupRequest `protobuf:"bytes,2,opt,name=startup_request,json=startupRequest,proto3" json:"startup_request,omitempty"`
	InstallRequest *api.InstallRequest          `protobuf:"bytes,3,opt,name=install_request,json=installRequest,proto3" json:"install_request,omitempty"`
	DynamicDeps    []*DynamicDep                `protobuf:"bytes,4,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// target refers to the device targeted for provision.
	// i.e. primaryDevice, companionDevice_brya, companionDevice_brya_2
	Target string `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

ProvisionRequest is designed to be extensible to all provisions that implement the GenericProvisionService, not just cros-provision.

func (*ProvisionRequest) Descriptor deprecated

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

Deprecated: Use ProvisionRequest.ProtoReflect.Descriptor instead.

func (*ProvisionRequest) GetDynamicDeps

func (x *ProvisionRequest) GetDynamicDeps() []*DynamicDep

func (*ProvisionRequest) GetInstallRequest

func (x *ProvisionRequest) GetInstallRequest() *api.InstallRequest

func (*ProvisionRequest) GetServiceAddress

func (x *ProvisionRequest) GetServiceAddress() *api2.IpEndpoint

func (*ProvisionRequest) GetStartupRequest

func (x *ProvisionRequest) GetStartupRequest() *api.ProvisionStartupRequest

func (*ProvisionRequest) GetTarget

func (x *ProvisionRequest) GetTarget() string

func (*ProvisionRequest) ProtoMessage

func (*ProvisionRequest) ProtoMessage()

func (*ProvisionRequest) ProtoReflect

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

func (*ProvisionRequest) Reset

func (x *ProvisionRequest) Reset()

func (*ProvisionRequest) String

func (x *ProvisionRequest) String() string

type PublishRequest

type PublishRequest struct {
	ServiceAddress *api2.IpEndpoint    `protobuf:"bytes,1,opt,name=service_address,json=serviceAddress,proto3" json:"service_address,omitempty"`
	PublishRequest *api.PublishRequest `protobuf:"bytes,2,opt,name=publish_request,json=publishRequest,proto3" json:"publish_request,omitempty"`
	DynamicDeps    []*DynamicDep       `protobuf:"bytes,3,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// contains filtered or unexported fields
}

PublishRequest targets requests towards services that implement the GenericPublishService.

func (*PublishRequest) Descriptor deprecated

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetDynamicDeps

func (x *PublishRequest) GetDynamicDeps() []*DynamicDep

func (*PublishRequest) GetPublishRequest

func (x *PublishRequest) GetPublishRequest() *api.PublishRequest

func (*PublishRequest) GetServiceAddress

func (x *PublishRequest) GetServiceAddress() *api2.IpEndpoint

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) String

func (x *PublishRequest) String() string

type Request

type Request struct {
	Prejob *Request_Prejob `protobuf:"bytes,1,opt,name=prejob,proto3" json:"prejob,omitempty"`
	Test   *Request_Test   `protobuf:"bytes,2,opt,name=test,proto3" json:"test,omitempty"`
	// Soft deadline for test_runner execution.
	//
	// All prejob or test execution should abort beyond this deadline.
	// Clean up actions may execute beyond the deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// The UID of the individual CTP request which kicked off this test run.
	// Note that distinct requests inside a multi-request CTP build will have
	// different UIDs.
	ParentRequestUid string `protobuf:"bytes,4,opt,name=parent_request_uid,json=parentRequestUid,proto3" json:"parent_request_uid,omitempty"`
	// The buildbucket ID of the CTP build that sent this test_runner request.
	ParentBuildId int64 `protobuf:"varint,5,opt,name=parent_build_id,json=parentBuildId,proto3" json:"parent_build_id,omitempty"`
	// Set of Tests to run. The string is a UUID provided by the client
	// and used to identify each test result in the response.
	Tests map[string]*Request_Test `` /* 151-byte string literal not displayed */
	// Uniformly applied parameters for all test executions in the parent test
	// platform request.
	ExecutionParam *execution.Param `protobuf:"bytes,7,opt,name=execution_param,json=executionParam,proto3" json:"execution_param,omitempty"`
	// If set, a Docker container to use to run autoserv. The container must
	// contain autoserv under the same path as the host (e.g.
	// "/usr/local/autotest/server/autoserv").
	//
	// The container will be pulled if needed.
	//
	// Deprecated: Do not use.
	ContainerImageInfo *api.ContainerImageInfo `protobuf:"bytes,8,opt,name=container_image_info,json=containerImageInfo,proto3" json:"container_image_info,omitempty"`
	// TestExecutionBehavior specifies how tests should be run.
	// This can include information about whether the tests should run and
	// if failures should be exonerated.
	DefaultTestExecutionBehavior test_platform.Request_Params_TestExecutionBehavior `` /* 206-byte string literal not displayed */
	// The retry attempt identifier. Details how many retries
	// this build has performed.
	RetryNumber int32 `protobuf:"varint,10,opt,name=retry_number,json=retryNumber,proto3" json:"retry_number,omitempty"`
	// Configuration related to results upload of the particular test.
	ResultsUploadConfig *test_platform.Request_Params_ResultsUploadConfig `protobuf:"bytes,11,opt,name=results_upload_config,json=resultsUploadConfig,proto3" json:"results_upload_config,omitempty"`
	// contains filtered or unexported fields
}

Request represents a request for running an individual test via the skylab_test_runner recipe.

func (*Request) Descriptor deprecated

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

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetContainerImageInfo deprecated

func (x *Request) GetContainerImageInfo() *api.ContainerImageInfo

Deprecated: Do not use.

func (*Request) GetDeadline

func (x *Request) GetDeadline() *timestamppb.Timestamp

func (*Request) GetDefaultTestExecutionBehavior

func (x *Request) GetDefaultTestExecutionBehavior() test_platform.Request_Params_TestExecutionBehavior

func (*Request) GetExecutionParam

func (x *Request) GetExecutionParam() *execution.Param

func (*Request) GetParentBuildId

func (x *Request) GetParentBuildId() int64

func (*Request) GetParentRequestUid

func (x *Request) GetParentRequestUid() string

func (*Request) GetPrejob

func (x *Request) GetPrejob() *Request_Prejob

func (*Request) GetResultsUploadConfig

func (x *Request) GetResultsUploadConfig() *test_platform.Request_Params_ResultsUploadConfig

func (*Request) GetRetryNumber

func (x *Request) GetRetryNumber() int32

func (*Request) GetTest

func (x *Request) GetTest() *Request_Test

func (*Request) GetTests

func (x *Request) GetTests() map[string]*Request_Test

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

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

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Request_Prejob

type Request_Prejob struct {

	// What needs to be installed onto the DUT at the end of prejob, as
	// specified in the cros_test_platform request.
	SoftwareDependencies []*test_platform.Request_Params_SoftwareDependency `protobuf:"bytes,1,rep,name=software_dependencies,json=softwareDependencies,proto3" json:"software_dependencies,omitempty"`
	// Mutable software prerequisites. Are installed before running the test if
	// necessary. E.g. {"cros-version" : "reef-release/R77-12345.0.0"}
	// TODO(crbug.com/1162347): Delete this post-migration.
	//
	// Deprecated: Do not use.
	ProvisionableLabels map[string]string `` /* 206-byte string literal not displayed */
	// If set, use the Provision TLS API for the prejob.
	// See go/cros-prover go/cros-tls
	//
	// crbug.com/1137444: This is a transitional argument. Once go/cros-prover
	// migration is complete, all prejobs will use the TLS API and this argument
	// will be dropped.
	UseTls bool `protobuf:"varint,3,opt,name=use_tls,json=useTls,proto3" json:"use_tls,omitempty"`
	// In a multi-DUT test scenario, software_attributes and hardware_attributes
	// can help us determine primary DUT in a DUT topology.
	SoftwareAttributes *test_platform.Request_Params_SoftwareAttributes `protobuf:"bytes,4,opt,name=software_attributes,json=softwareAttributes,proto3" json:"software_attributes,omitempty"`
	HardwareAttributes *test_platform.Request_Params_HardwareAttributes `protobuf:"bytes,5,opt,name=hardware_attributes,json=hardwareAttributes,proto3" json:"hardware_attributes,omitempty"`
	// Will present in a multi-DUTs test request, it includes necessary metadata
	// to help us determine DUT topology(primary/secondaries), as well as
	// software dependencies to run prejob for secondary DUTs.
	SecondaryDevices []*test_platform.Request_Params_SecondaryDevice `protobuf:"bytes,6,rep,name=secondary_devices,json=secondaryDevices,proto3" json:"secondary_devices,omitempty"`
	// contains filtered or unexported fields
}

Prejob defines parameters that affect the steps before the actual test (e.g. provision).

func (*Request_Prejob) Descriptor deprecated

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

Deprecated: Use Request_Prejob.ProtoReflect.Descriptor instead.

func (*Request_Prejob) GetHardwareAttributes

func (*Request_Prejob) GetProvisionableLabels deprecated

func (x *Request_Prejob) GetProvisionableLabels() map[string]string

Deprecated: Do not use.

func (*Request_Prejob) GetSecondaryDevices

func (x *Request_Prejob) GetSecondaryDevices() []*test_platform.Request_Params_SecondaryDevice

func (*Request_Prejob) GetSoftwareAttributes

func (*Request_Prejob) GetSoftwareDependencies

func (x *Request_Prejob) GetSoftwareDependencies() []*test_platform.Request_Params_SoftwareDependency

func (*Request_Prejob) GetUseTls

func (x *Request_Prejob) GetUseTls() bool

func (*Request_Prejob) ProtoMessage

func (*Request_Prejob) ProtoMessage()

func (*Request_Prejob) ProtoReflect

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

func (*Request_Prejob) Reset

func (x *Request_Prejob) Reset()

func (*Request_Prejob) String

func (x *Request_Prejob) String() string

type Request_Test

type Request_Test struct {

	// Types that are assignable to Harness:
	//	*Request_Test_Autotest_
	Harness isRequest_Test_Harness       `protobuf_oneof:"harness"`
	Offload *Request_Test_OffloadOptions `protobuf:"bytes,2,opt,name=offload,proto3" json:"offload,omitempty"`
	// contains filtered or unexported fields
}

Test describes which test harness and which test(s) to run.

func (*Request_Test) Descriptor deprecated

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

Deprecated: Use Request_Test.ProtoReflect.Descriptor instead.

func (*Request_Test) GetAutotest

func (x *Request_Test) GetAutotest() *Request_Test_Autotest

func (*Request_Test) GetHarness

func (m *Request_Test) GetHarness() isRequest_Test_Harness

func (*Request_Test) GetOffload

func (x *Request_Test) GetOffload() *Request_Test_OffloadOptions

func (*Request_Test) ProtoMessage

func (*Request_Test) ProtoMessage()

func (*Request_Test) ProtoReflect

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

func (*Request_Test) Reset

func (x *Request_Test) Reset()

func (*Request_Test) String

func (x *Request_Test) String() string

type Request_Test_Autotest

type Request_Test_Autotest struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TestArgs string `protobuf:"bytes,2,opt,name=test_args,json=testArgs,proto3" json:"test_args,omitempty"`
	// Keyvals are key:value pairs added to the autoserv command.
	Keyvals map[string]string `` /* 155-byte string literal not displayed */
	// If true, run the test as a client-side test: the test logic is
	// executed in its entirety on the DUT itself.
	// Otherwise, run the test as a server-side test: the test logic is
	// executed on the drone server and interacts with the DUT as an external
	// object.
	IsClientTest bool `protobuf:"varint,4,opt,name=is_client_test,json=isClientTest,proto3" json:"is_client_test,omitempty"`
	// Name to be used to display this test's output artifacts, e.g. logs,
	// results etc. By default display_name is the same as name.
	//
	// display_name is especially useful when using test_args to distinguish
	// between multiple instances of the same test in a request.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Request_Test_Autotest) Descriptor deprecated

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

Deprecated: Use Request_Test_Autotest.ProtoReflect.Descriptor instead.

func (*Request_Test_Autotest) GetDisplayName

func (x *Request_Test_Autotest) GetDisplayName() string

func (*Request_Test_Autotest) GetIsClientTest

func (x *Request_Test_Autotest) GetIsClientTest() bool

func (*Request_Test_Autotest) GetKeyvals

func (x *Request_Test_Autotest) GetKeyvals() map[string]string

func (*Request_Test_Autotest) GetName

func (x *Request_Test_Autotest) GetName() string

func (*Request_Test_Autotest) GetTestArgs

func (x *Request_Test_Autotest) GetTestArgs() string

func (*Request_Test_Autotest) ProtoMessage

func (*Request_Test_Autotest) ProtoMessage()

func (*Request_Test_Autotest) ProtoReflect

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

func (*Request_Test_Autotest) Reset

func (x *Request_Test_Autotest) Reset()

func (*Request_Test_Autotest) String

func (x *Request_Test_Autotest) String() string

type Request_Test_Autotest_

type Request_Test_Autotest_ struct {
	Autotest *Request_Test_Autotest `protobuf:"bytes,1,opt,name=autotest,proto3,oneof"`
}

type Request_Test_OffloadOptions

type Request_Test_OffloadOptions struct {

	// If this test needs synchronous offloading of results to Google Storage
	SynchronousGsEnable bool `protobuf:"varint,1,opt,name=synchronous_gs_enable,json=synchronousGsEnable,proto3" json:"synchronous_gs_enable,omitempty"`
	// contains filtered or unexported fields
}

User-specified options for how results are served to clients

func (*Request_Test_OffloadOptions) Descriptor deprecated

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

Deprecated: Use Request_Test_OffloadOptions.ProtoReflect.Descriptor instead.

func (*Request_Test_OffloadOptions) GetSynchronousGsEnable

func (x *Request_Test_OffloadOptions) GetSynchronousGsEnable() bool

func (*Request_Test_OffloadOptions) ProtoMessage

func (*Request_Test_OffloadOptions) ProtoMessage()

func (*Request_Test_OffloadOptions) ProtoReflect

func (*Request_Test_OffloadOptions) Reset

func (x *Request_Test_OffloadOptions) Reset()

func (*Request_Test_OffloadOptions) String

func (x *Request_Test_OffloadOptions) String() string

type Result

type Result struct {

	// Which test harness was used.
	//
	// Types that are assignable to Harness:
	//	*Result_AutotestResult
	Harness     isResult_Harness    `protobuf_oneof:"harness"`
	Prejob      *Result_Prejob      `protobuf:"bytes,2,opt,name=prejob,proto3" json:"prejob,omitempty"`
	LogData     *common.TaskLogData `protobuf:"bytes,3,opt,name=log_data,json=logData,proto3" json:"log_data,omitempty"`
	StateUpdate *Result_StateUpdate `protobuf:"bytes,4,opt,name=state_update,json=stateUpdate,proto3" json:"state_update,omitempty"`
	// Set of test results. The string is a UUID used to identify each test, and
	// comes from the client.
	AutotestResults map[string]*Result_Autotest `` /* 194-byte string literal not displayed */
	// contains filtered or unexported fields
}

Result defines the output format of skylab_test_runner. It contains a summary of test results from a single Swarming task run.

func (*Result) Descriptor deprecated

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

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetAutotestResult

func (x *Result) GetAutotestResult() *Result_Autotest

func (*Result) GetAutotestResults

func (x *Result) GetAutotestResults() map[string]*Result_Autotest

func (*Result) GetHarness

func (m *Result) GetHarness() isResult_Harness

func (*Result) GetLogData

func (x *Result) GetLogData() *common.TaskLogData

func (*Result) GetPrejob

func (x *Result) GetPrejob() *Result_Prejob

func (*Result) GetStateUpdate

func (x *Result) GetStateUpdate() *Result_StateUpdate

func (*Result) ProtoMessage

func (*Result) ProtoMessage()

func (*Result) ProtoReflect

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

func (*Result) Reset

func (x *Result) Reset()

func (*Result) String

func (x *Result) String() string

type Result_Autotest

type Result_Autotest struct {
	TestCases []*Result_Autotest_TestCase `protobuf:"bytes,1,rep,name=test_cases,json=testCases,proto3" json:"test_cases,omitempty"`
	// False if test_cases represents all of the test cases to be run by the
	// task. True otherwise (e.g. the task was aborted early).
	Incomplete bool `protobuf:"varint,2,opt,name=incomplete,proto3" json:"incomplete,omitempty"`
	// contains filtered or unexported fields
}

Autotest describes the result summary for the case of autotest harness.

func (*Result_Autotest) Descriptor deprecated

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

Deprecated: Use Result_Autotest.ProtoReflect.Descriptor instead.

func (*Result_Autotest) GetIncomplete

func (x *Result_Autotest) GetIncomplete() bool

func (*Result_Autotest) GetTestCases

func (x *Result_Autotest) GetTestCases() []*Result_Autotest_TestCase

func (*Result_Autotest) ProtoMessage

func (*Result_Autotest) ProtoMessage()

func (*Result_Autotest) ProtoReflect

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

func (*Result_Autotest) Reset

func (x *Result_Autotest) Reset()

func (*Result_Autotest) String

func (x *Result_Autotest) String() string

type Result_AutotestResult

type Result_AutotestResult struct {
	AutotestResult *Result_Autotest `protobuf:"bytes,1,opt,name=autotest_result,json=autotestResult,proto3,oneof"`
}

type Result_Autotest_TestCase

type Result_Autotest_TestCase struct {

	// Test case name as it appears in status.log.
	Name    string                           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Verdict Result_Autotest_TestCase_Verdict `` /* 139-byte string literal not displayed */
	// A one line human readable description of what happened during test
	// case execution (e.g. error/warning message). Not intended to be machine
	// parseable. There's no guarantee that a given root cause will always
	// resolve to the same summary.
	HumanReadableSummary string `protobuf:"bytes,3,opt,name=human_readable_summary,json=humanReadableSummary,proto3" json:"human_readable_summary,omitempty"`
	// The start time of the test case run.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The end time of the test case run.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// contains filtered or unexported fields
}

TestCase describes the result of an individual test case. A single control file may correspond to multiple test cases. NEXT ID: 6

func (*Result_Autotest_TestCase) Descriptor deprecated

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

Deprecated: Use Result_Autotest_TestCase.ProtoReflect.Descriptor instead.

func (*Result_Autotest_TestCase) GetEndTime

func (*Result_Autotest_TestCase) GetHumanReadableSummary

func (x *Result_Autotest_TestCase) GetHumanReadableSummary() string

func (*Result_Autotest_TestCase) GetName

func (x *Result_Autotest_TestCase) GetName() string

func (*Result_Autotest_TestCase) GetStartTime

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

func (*Result_Autotest_TestCase) GetVerdict

func (*Result_Autotest_TestCase) ProtoMessage

func (*Result_Autotest_TestCase) ProtoMessage()

func (*Result_Autotest_TestCase) ProtoReflect

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

func (*Result_Autotest_TestCase) Reset

func (x *Result_Autotest_TestCase) Reset()

func (*Result_Autotest_TestCase) String

func (x *Result_Autotest_TestCase) String() string

type Result_Autotest_TestCase_Verdict

type Result_Autotest_TestCase_Verdict int32

Verdict defines the test case result to be reported. NEXT ID: 6

const (
	// Status was not specificed.
	Result_Autotest_TestCase_VERDICT_UNDEFINED Result_Autotest_TestCase_Verdict = 0
	// The test has passed.
	Result_Autotest_TestCase_VERDICT_PASS Result_Autotest_TestCase_Verdict = 1
	// The test has failed.
	Result_Autotest_TestCase_VERDICT_FAIL Result_Autotest_TestCase_Verdict = 2
	// The test was skipped before execution.
	Result_Autotest_TestCase_VERDICT_NO_VERDICT Result_Autotest_TestCase_Verdict = 3
	// The test has crashed during exectuion due to an error.
	Result_Autotest_TestCase_VERDICT_ERROR Result_Autotest_TestCase_Verdict = 4
	// The test has started but was aborted before finishing.
	Result_Autotest_TestCase_VERDICT_ABORT Result_Autotest_TestCase_Verdict = 5
)

func (Result_Autotest_TestCase_Verdict) Descriptor

func (Result_Autotest_TestCase_Verdict) Enum

func (Result_Autotest_TestCase_Verdict) EnumDescriptor deprecated

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

Deprecated: Use Result_Autotest_TestCase_Verdict.Descriptor instead.

func (Result_Autotest_TestCase_Verdict) Number

func (Result_Autotest_TestCase_Verdict) String

func (Result_Autotest_TestCase_Verdict) Type

type Result_Prejob

type Result_Prejob struct {
	Step []*Result_Prejob_Step `protobuf:"bytes,1,rep,name=step,proto3" json:"step,omitempty"`
	// contains filtered or unexported fields
}

Prejob contains all preparatory operations that run before the actual test cases.

func (*Result_Prejob) Descriptor deprecated

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

Deprecated: Use Result_Prejob.ProtoReflect.Descriptor instead.

func (*Result_Prejob) GetStep

func (x *Result_Prejob) GetStep() []*Result_Prejob_Step

func (*Result_Prejob) ProtoMessage

func (*Result_Prejob) ProtoMessage()

func (*Result_Prejob) ProtoReflect

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

func (*Result_Prejob) Reset

func (x *Result_Prejob) Reset()

func (*Result_Prejob) String

func (x *Result_Prejob) String() string

type Result_Prejob_Step

type Result_Prejob_Step struct {

	// Step name, e.g. as it appears in status.log.
	Name    string                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Verdict Result_Prejob_Step_Verdict `` /* 133-byte string literal not displayed */
	// A one line human readable description of what happened during step
	// execution (e.g. error/warning message). Not intended to be machine
	// parseable. There's no guarantee that a given root cause will always
	// resolve to the same summary.
	HumanReadableSummary string `protobuf:"bytes,3,opt,name=human_readable_summary,json=humanReadableSummary,proto3" json:"human_readable_summary,omitempty"`
	// contains filtered or unexported fields
}

Step describes an individual prejob operation e.g. provision.

func (*Result_Prejob_Step) Descriptor deprecated

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

Deprecated: Use Result_Prejob_Step.ProtoReflect.Descriptor instead.

func (*Result_Prejob_Step) GetHumanReadableSummary

func (x *Result_Prejob_Step) GetHumanReadableSummary() string

func (*Result_Prejob_Step) GetName

func (x *Result_Prejob_Step) GetName() string

func (*Result_Prejob_Step) GetVerdict

func (*Result_Prejob_Step) ProtoMessage

func (*Result_Prejob_Step) ProtoMessage()

func (*Result_Prejob_Step) ProtoReflect

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

func (*Result_Prejob_Step) Reset

func (x *Result_Prejob_Step) Reset()

func (*Result_Prejob_Step) String

func (x *Result_Prejob_Step) String() string

type Result_Prejob_Step_Verdict

type Result_Prejob_Step_Verdict int32

Verdict defines the final step status. Eventually may have different cases from the test case verdict, e.g. VERDICT_SKIPPED.

const (
	Result_Prejob_Step_VERDICT_UNDEFINED Result_Prejob_Step_Verdict = 0
	Result_Prejob_Step_VERDICT_PASS      Result_Prejob_Step_Verdict = 1
	Result_Prejob_Step_VERDICT_FAIL      Result_Prejob_Step_Verdict = 2
)

func (Result_Prejob_Step_Verdict) Descriptor

func (Result_Prejob_Step_Verdict) Enum

func (Result_Prejob_Step_Verdict) EnumDescriptor deprecated

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

Deprecated: Use Result_Prejob_Step_Verdict.Descriptor instead.

func (Result_Prejob_Step_Verdict) Number

func (Result_Prejob_Step_Verdict) String

func (Result_Prejob_Step_Verdict) Type

type Result_StateUpdate

type Result_StateUpdate struct {

	// E.g. "needs_repair", "ready" etc.
	DutState string `protobuf:"bytes,1,opt,name=dut_state,json=dutState,proto3" json:"dut_state,omitempty"`
	// contains filtered or unexported fields
}

StateUpdate contains Skylab state changes that resulted from the test run. It is consumed by `skylab_local_state save`.

func (*Result_StateUpdate) Descriptor deprecated

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

Deprecated: Use Result_StateUpdate.ProtoReflect.Descriptor instead.

func (*Result_StateUpdate) GetDutState

func (x *Result_StateUpdate) GetDutState() string

func (*Result_StateUpdate) ProtoMessage

func (*Result_StateUpdate) ProtoMessage()

func (*Result_StateUpdate) ProtoReflect

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

func (*Result_StateUpdate) Reset

func (x *Result_StateUpdate) Reset()

func (*Result_StateUpdate) String

func (x *Result_StateUpdate) String() string

type TestRequest

type TestRequest struct {
	ServiceAddress *api2.IpEndpoint     `protobuf:"bytes,1,opt,name=service_address,json=serviceAddress,proto3" json:"service_address,omitempty"`
	TestRequest    *api.CrosTestRequest `protobuf:"bytes,2,opt,name=test_request,json=testRequest,proto3" json:"test_request,omitempty"`
	DynamicDeps    []*DynamicDep        `protobuf:"bytes,3,rep,name=dynamic_deps,json=dynamicDeps,proto3" json:"dynamic_deps,omitempty"`
	// contains filtered or unexported fields
}

TestRequest targets requests towards services that implement the ExecutionService.

func (*TestRequest) Descriptor deprecated

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

Deprecated: Use TestRequest.ProtoReflect.Descriptor instead.

func (*TestRequest) GetDynamicDeps

func (x *TestRequest) GetDynamicDeps() []*DynamicDep

func (*TestRequest) GetServiceAddress

func (x *TestRequest) GetServiceAddress() *api2.IpEndpoint

func (*TestRequest) GetTestRequest

func (x *TestRequest) GetTestRequest() *api.CrosTestRequest

func (*TestRequest) ProtoMessage

func (*TestRequest) ProtoMessage()

func (*TestRequest) ProtoReflect

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

func (*TestRequest) Reset

func (x *TestRequest) Reset()

func (*TestRequest) String

func (x *TestRequest) String() string

type Trv2Config

type Trv2Config struct {

	// List of allowed suites which should run via trv2.
	// 'Or' relationship between suites.
	// 'And' relationship with allowed_boards & allowed_build_types.
	AllowedSuites []string `protobuf:"bytes,1,rep,name=allowed_suites,json=allowedSuites,proto3" json:"allowed_suites,omitempty"`
	// List of allowed suites which should run via trv2.
	// 'Or' relationship between boards.
	// 'And' relationship with allowed_suites & allowed_build_types.
	AllowedBoards []string `protobuf:"bytes,2,rep,name=allowed_boards,json=allowedBoards,proto3" json:"allowed_boards,omitempty"`
	// List of allowed build types which should run via trv2.
	// 'Or' relationship between build types.
	// 'And' relationship with allowed_boards & allowed_suites.
	AllowedBuildTypes []Trv2Config_BuildType `` /* 181-byte string literal not displayed */
	// contains filtered or unexported fields
}

b/267268890: Config to control trv2 gradual rollout in prod. Should be deprecated after full rollout.

func (*Trv2Config) Descriptor deprecated

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

Deprecated: Use Trv2Config.ProtoReflect.Descriptor instead.

func (*Trv2Config) GetAllowedBoards

func (x *Trv2Config) GetAllowedBoards() []string

func (*Trv2Config) GetAllowedBuildTypes

func (x *Trv2Config) GetAllowedBuildTypes() []Trv2Config_BuildType

func (*Trv2Config) GetAllowedSuites

func (x *Trv2Config) GetAllowedSuites() []string

func (*Trv2Config) ProtoMessage

func (*Trv2Config) ProtoMessage()

func (*Trv2Config) ProtoReflect

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

func (*Trv2Config) Reset

func (x *Trv2Config) Reset()

func (*Trv2Config) String

func (x *Trv2Config) String() string

type Trv2Config_BuildType

type Trv2Config_BuildType int32

Different build types.

const (
	Trv2Config_CQ         Trv2Config_BuildType = 0
	Trv2Config_RELEASE    Trv2Config_BuildType = 1
	Trv2Config_POSTSUBMIT Trv2Config_BuildType = 2
)

func (Trv2Config_BuildType) Descriptor

func (Trv2Config_BuildType) Enum

func (Trv2Config_BuildType) EnumDescriptor deprecated

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

Deprecated: Use Trv2Config_BuildType.Descriptor instead.

func (Trv2Config_BuildType) Number

func (Trv2Config_BuildType) String

func (x Trv2Config_BuildType) String() string

func (Trv2Config_BuildType) Type

type UnimplementedCrosTestRunnerServiceServer

type UnimplementedCrosTestRunnerServiceServer struct {
}

UnimplementedCrosTestRunnerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCrosTestRunnerServiceServer) Execute

type UnsafeCrosTestRunnerServiceServer

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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