commands

package
v0.0.0-...-9994f1b Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2025 License: BSD-3-Clause Imports: 44 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// Server related commands
	CommandsServerCmdType interfaces.CommandType = "CommandsServer"

	// Build/env related commands
	BuildInputValidationCmdType interfaces.CommandType = "BuildInputValidation"
	ParseEnvInfoCmdType         interfaces.CommandType = "ParseEnvInfoCmd"
	ProcessResultsCmdType       interfaces.CommandType = "ProcessResultsCmd"
	ParseArgsCmdType            interfaces.CommandType = "ParseArgs"

	// Container related commands
	UpdateContainerImagesLocallyCmdType interfaces.CommandType = "UpdateContainerImagesLocally"
	FetchContainerMetadataCmdType       interfaces.CommandType = "FetchContainerMetadata"

	// Inventory service related commands
	InvServiceStartCmdType  interfaces.CommandType = "InvServiceStart"
	InvServiceStopCmdType   interfaces.CommandType = "InvServiceStop"
	LoadDutTopologyCmdType  interfaces.CommandType = "LoadDutTopology"
	BuildDutTopologyCmdType interfaces.CommandType = "BuildDutTopology"
	ParseDutTopologyCmdType interfaces.CommandType = "ParseDutTopology"

	// SSH service related commands
	SshStartTunnelCmdType        interfaces.CommandType = "SshTunnelStart"
	SshStartReverseTunnelCmdType interfaces.CommandType = "SshReverseTunnelStart"
	SshStopTunnelsCmdType        interfaces.CommandType = "SshTunnelsStop"

	// Cache server related commands
	CacheServerStartCmdType interfaces.CommandType = "CacheServerStart"

	// Dut service related commands
	DutServiceStartCmdType                 interfaces.CommandType = "DutServiceStart"
	AndroidCompanionDutServiceStartCmdType interfaces.CommandType = "AndroidCompanionDutServiceStart"

	// Dut VM test related commands
	DutVmGetImageCmdType         interfaces.CommandType = "DutVmGetImage"
	DutVmCacheServerStartCmdType interfaces.CommandType = "DutVmCacheServerStart"

	AndroidProvisionServiceStartCmdType interfaces.CommandType = "AndroidProvisionServiceStart"
	AndroidProvisionInstallCmdType      interfaces.CommandType = "AndroidProvisionInstall"
	ProvisionServiceStartCmdType        interfaces.CommandType = "ProvisionServiceStart"
	ProvisonInstallCmdType              interfaces.CommandType = "ProvisonInstall"
	VMProvisionServiceStartCmdType      interfaces.CommandType = "VMProvisionServiceStart"
	VMProvisionLeaseCmdType             interfaces.CommandType = "VMProvisionLease"
	VMProvisionReleaseCmdType           interfaces.CommandType = "VMProvisionRelease"
	GenericProvisionCmdType             interfaces.CommandType = "GenericProvision"

	// Test Finder service related commands
	TestFinderServiceStartCmdType interfaces.CommandType = "TestFinderServiceStart"
	TestFinderExecutionCmdType    interfaces.CommandType = "TestFinderExecution"

	// Test service related commands
	TestServiceStartCmdType interfaces.CommandType = "TestServiceStart"
	TestsExecutionCmdType   interfaces.CommandType = "TestsExecution"
	GenericTestsCmdType     interfaces.CommandType = "GenericTests"

	// Generic Service related commands
	GenericServiceCmdType interfaces.CommandType = "GenericService"

	// Post process service related commands
	GenericPostProcessCmdType interfaces.CommandType = "GenericPostProcess"

	// Publish service related commands
	GenericPublishCmdType interfaces.CommandType = "GenericPublish"

	GcsPublishStartCmdType  interfaces.CommandType = "GcsPublishStart"
	GcsPublishUploadCmdType interfaces.CommandType = "GcsPublishUpload"

	TkoPublishStartCmdType  interfaces.CommandType = "TkoPublishStart"
	TkoPublishUploadCmdType interfaces.CommandType = "TkoPublishUpload"
	TkoDirectUploadCmdType  interfaces.CommandType = "TkoDirectUpload"

	CpconPublishStartCmdType  interfaces.CommandType = "CpconPublishStart"
	CpconPublishUploadCmdType interfaces.CommandType = "CpconPublishUpload"

	RdbPublishStartCmdType  interfaces.CommandType = "RdbPublishStart"
	RdbPublishUploadCmdType interfaces.CommandType = "RdbPublishUpload"

	// Ufs related commands
	UpdateDutStateCmdType interfaces.CommandType = "UpdateDutState"

	// For testing purposes only
	UnSupportedCmdType interfaces.CommandType = "UnSupportedCmd"
)

All supported command types.

Variables

This section is empty.

Functions

func SourcesFromCFTTestRequest 

func SourcesFromCFTTestRequest(request *skylab_test_runner.CFTTestRequest) (*testapi_metadata.PublishRdbMetadata_Sources, error)

SourcesFromCFTTestRequest returns the code sources tested in the given CFT testing request.

func SourcesFromPrimaryDevice 

func SourcesFromPrimaryDevice(sk *data.HwTestStateKeeper) (*testapi_metadata.PublishRdbMetadata_Sources, error)

SourcesFromPrimaryDevice returns the code sources tested in the given testing request assuming provision was successful and the version did not shcnage during the test.

func UpdateContainer 

func UpdateContainer(ctx context.Context, chroot, imageBase, service string) error

UpdateContainer updates the container locally

Types

type AndroidCompanionDutServiceStartCmd 

type AndroidCompanionDutServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	CacheServerAddress   *labapi.IpEndpoint
	AndroidDutSshAddress *labapi.IpEndpoint

	// Updates
	AndroidDutServerAddress *labapi.IpEndpoint
}

AndroidCompanionDutServiceStartCmd represents android dut service start cmd.

func NewAndroidCompanionDutServiceStartCmd 

func NewAndroidCompanionDutServiceStartCmd(executor interfaces.ExecutorInterface) *AndroidCompanionDutServiceStartCmd

func (*AndroidCompanionDutServiceStartCmd) ExtractDependencies 

func (cmd *AndroidCompanionDutServiceStartCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*AndroidCompanionDutServiceStartCmd) UpdateStateKeeper 

func (cmd *AndroidCompanionDutServiceStartCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type AndroidProvisionInstallCmd 

type AndroidProvisionInstallCmd struct {
	*interfaces.SingleCmdByExecutor
	// Deps
	AndroidDutServerAddress *labapi.IpEndpoint
	AndroidProvisionState   *anypb.Any
	AndroidCompanionDut     *labapi.Dut
	// Updates
	AndroidProvisionResponse *testapi.InstallResponse
}

AndroidProvisionInstallCmd represents android-provision install cmd.

func NewAndroidProvisionInstallCmd 

func NewAndroidProvisionInstallCmd(executor interfaces.ExecutorInterface) *AndroidProvisionInstallCmd

NewAndroidProvisionInstallCmd returns an object of AndroidProvisionInstallCmd

func (*AndroidProvisionInstallCmd) ExtractDependencies 

func (cmd *AndroidProvisionInstallCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*AndroidProvisionInstallCmd) UpdateStateKeeper 

func (cmd *AndroidProvisionInstallCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type AndroidProvisionServiceStartCmd 

type AndroidProvisionServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor
}

AndroidProvisionServiceStartCmd represents android-provision service start cmd.

func NewAndroidProvisionServiceStartCmd 

func NewAndroidProvisionServiceStartCmd(executor interfaces.ExecutorInterface) *AndroidProvisionServiceStartCmd

NewAndroidProvisionServiceStartCmd returns an object of AndroidProvisionServiceStartCmd

type BuildDutTopologyCmd 

type BuildDutTopologyCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	DutSshAddress      *labapi.IpEndpoint
	CacheServerAddress *labapi.IpEndpoint
	Board              string

	// Updates
	DutTopology *labapi.DutTopology
}

BuildDutTopologyCmd represents load dut toplogy cmd.

func NewBuildDutTopologyCmd 

func NewBuildDutTopologyCmd(executor interfaces.ExecutorInterface) *BuildDutTopologyCmd

func (*BuildDutTopologyCmd) ExtractDependencies 

func (cmd *BuildDutTopologyCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*BuildDutTopologyCmd) UpdateStateKeeper 

func (cmd *BuildDutTopologyCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type BuildInputValidationCmd 

type BuildInputValidationCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor

	// Deps
	CftTestRequest        *skylab_test_runner.CFTTestRequest
	CrosTestRunnerRequest *api.CrosTestRunnerDynamicRequest
}

BuildInputValidationCmd represents build input validation command.

func NewBuildInputValidationCmd 

func NewBuildInputValidationCmd() *BuildInputValidationCmd

func (*BuildInputValidationCmd) Execute 

func (cmd *BuildInputValidationCmd) Execute(ctx context.Context) error

Execute executes the command by wrapping unwrappedExecute with a custom error message.

func (*BuildInputValidationCmd) ExtractDependencies 

func (cmd *BuildInputValidationCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type CacheServerStartCmd 

type CacheServerStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Updates
	CacheServerAddress *labapi.IpEndpoint
}

DutServiceStartCmd represents dut service start cmd.

func NewCacheServerStartCmd 

func NewCacheServerStartCmd(executor interfaces.ExecutorInterface) *CacheServerStartCmd

func (*CacheServerStartCmd) UpdateStateKeeper 

func (cmd *CacheServerStartCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type CpconPublishServiceStartCmd 

type CpconPublishServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	CpconPublishSrcDir string
}

CpconPublishServiceStartCmd represents Cpcon publish service cmd.

func NewCpconPublishServiceStartCmd 

func NewCpconPublishServiceStartCmd(executor interfaces.ExecutorInterface) *CpconPublishServiceStartCmd

func (*CpconPublishServiceStartCmd) ExtractDependencies 

func (cmd *CpconPublishServiceStartCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type CpconPublishUploadCmd 

type CpconPublishUploadCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	CpconPublishSrcDir   string
	CpconJobName         string
	GcsURL               string
	Build                string
	Suite                string
	ParentSwarmingTaskID string
}

CpconPublishUploadCmd represents cpcon publish upload cmd.

func NewCpconPublishUploadCmd 

func NewCpconPublishUploadCmd(executor interfaces.ExecutorInterface) *CpconPublishUploadCmd

func (*CpconPublishUploadCmd) ExtractDependencies 

func (cmd *CpconPublishUploadCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type DeviceInfo 

type DeviceInfo struct {
	Device   *testapi.CrosTestRequest_Device
	Metadata *skylab_test_runner.CFTTestRequest_Device
}

type DutServiceStartCmd 

type DutServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	CacheServerAddress *labapi.IpEndpoint
	DutSshAddress      *labapi.IpEndpoint

	// Updates
	DutServerAddress *labapi.IpEndpoint
}

DutServiceStartCmd represents dut service start cmd.

func NewDutServiceStartCmd 

func NewDutServiceStartCmd(executor interfaces.ExecutorInterface) *DutServiceStartCmd

func (*DutServiceStartCmd) ExtractDependencies 

func (cmd *DutServiceStartCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*DutServiceStartCmd) UpdateStateKeeper 

func (cmd *DutServiceStartCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type DutVmCacheServerStartCmd 

type DutVmCacheServerStartCmd struct {
	*interfaces.SingleCmdByExecutor
	// Deps
	DutTopology *labapi.DutTopology

	// Updates
	CacheServerAddress *labapi.IpEndpoint
}

DutVmCacheServerStartCmd defines the I/O to start a cache server on GCE.

func NewDutVmCacheServerStartCmd 

func NewDutVmCacheServerStartCmd(executor interfaces.ExecutorInterface) *DutVmCacheServerStartCmd

func (*DutVmCacheServerStartCmd) ExtractDependencies 

func (cmd *DutVmCacheServerStartCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*DutVmCacheServerStartCmd) UpdateStateKeeper 

func (cmd *DutVmCacheServerStartCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type DutVmGetImageCmd 

type DutVmGetImageCmd struct {
	*interfaces.SingleCmdByExecutor
	// Deps
	Build string

	// Updates
	DutVmGceImage *vmlabapi.GceImage
}

DutVmGetImageCmd defines the step I/O of get the GCE image of Dut VM.

func NewDutVmGetImageCmd 

func NewDutVmGetImageCmd(executor interfaces.ExecutorInterface) *DutVmGetImageCmd

func (*DutVmGetImageCmd) ExtractDependencies 

func (cmd *DutVmGetImageCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*DutVmGetImageCmd) UpdateStateKeeper 

func (cmd *DutVmGetImageCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type FetchContainerMetadataCmd 

type FetchContainerMetadataCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor
	ExecutorConfig interfaces.ExecutorConfigInterface

	// Deps (optional)
	Board  string
	Bucket string
	Number string

	// Updates
	Containers map[string]*api.ContainerImageInfo
	ImagePath  string
}

FetchContainerMetadataCmd represents build input validation command.

func NewFetchContainerMetadataCmd 

func NewFetchContainerMetadataCmd() *FetchContainerMetadataCmd

func (*FetchContainerMetadataCmd) Execute 

func (cmd *FetchContainerMetadataCmd) Execute(ctx context.Context) error

Execute executes the command.

func (*FetchContainerMetadataCmd) ExtractDependencies 

func (cmd *FetchContainerMetadataCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*FetchContainerMetadataCmd) UpdateStateKeeper 

func (cmd *FetchContainerMetadataCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type GcsPublishServiceStartCmd 

type GcsPublishServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	GcsPublishSrcDir string
}

GcsPublishServiceStartCmd represents gcs publish service cmd.

func NewGcsPublishServiceStartCmd 

func NewGcsPublishServiceStartCmd(executor interfaces.ExecutorInterface) *GcsPublishServiceStartCmd

func (*GcsPublishServiceStartCmd) ExtractDependencies 

func (cmd *GcsPublishServiceStartCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type GcsPublishUploadCmd 

type GcsPublishUploadCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	GcsURL               string
	IsALRun              bool
	Product              string
	Build                string
	ParentSwarmingTaskID string
	XTSResultsGCSPrefix  string
	XTSAPFEGCSPrefix     string
	EnableXTSArchiver    bool
}

GcsPublishUploadCmd represents gcs publish upload cmd.

func NewGcsPublishUploadCmd 

func NewGcsPublishUploadCmd(executor interfaces.ExecutorInterface) *GcsPublishUploadCmd

func (*GcsPublishUploadCmd) ExtractDependencies 

func (cmd *GcsPublishUploadCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type GenericPostProcessCmd 

type GenericPostProcessCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	PostProcessRequest *testapi.PostTestTask
	Identifier         string

	// Updates
	StartUpResp       *testapi.PostTestStartUpResponse
	RunActivitiesResp *testapi.RunActivitiesResponse
}

GenericPostProcessCmd represents post process service commands.

func NewGenericPostProcessCmd 

func NewGenericPostProcessCmd(executor interfaces.ExecutorInterface) *GenericPostProcessCmd

NewGenericPostProcessCmd creates a new generic post process command.

func (*GenericPostProcessCmd) ExtractDependencies 

func (cmd *GenericPostProcessCmd) ExtractDependencies(ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*GenericPostProcessCmd) Instantiate 

func (cmd *GenericPostProcessCmd) Instantiate(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

Instantiate extracts initial state info from the state keeper.

func (*GenericPostProcessCmd) UpdateStateKeeper 

func (cmd *GenericPostProcessCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type GenericProvisionCmd 

type GenericProvisionCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	ProvisionRequest *api.ProvisionTask
	Identifier       string
	TargetDevice     string

	// Updates
	InstallResp *api.InstallResponse
	StartUpResp *api.ProvisionStartupResponse
}

GenericProvisionCmd represents gcloud auth cmd.

func NewGenericProvisionCmd 

func NewGenericProvisionCmd(executor interfaces.ExecutorInterface) *GenericProvisionCmd

func (*GenericProvisionCmd) ExtractDependencies 

func (cmd *GenericProvisionCmd) ExtractDependencies(ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*GenericProvisionCmd) Instantiate 

func (cmd *GenericProvisionCmd) Instantiate(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

Instantiate extracts initial state info from the state keeper.

func (*GenericProvisionCmd) UpdateStateKeeper 

func (cmd *GenericProvisionCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type GenericPublishCmd 

type GenericPublishCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	PublishRequest *api.PublishTask
	Identifier     string

	// Updates
	PublishResp *testapi.PublishResponse
}

GenericPublishCmd represents gcloud auth cmd.

func NewGenericPublishCmd 

func NewGenericPublishCmd(executor interfaces.ExecutorInterface) *GenericPublishCmd

func (*GenericPublishCmd) ExtractDependencies 

func (cmd *GenericPublishCmd) ExtractDependencies(ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*GenericPublishCmd) Instantiate 

func (cmd *GenericPublishCmd) Instantiate(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

Instantiate extracts initial state info from the state keeper.

func (*GenericPublishCmd) UpdateStateKeeper 

func (cmd *GenericPublishCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type GenericServiceCmd 

type GenericServiceCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	GenericRequest *api.GenericTask
	Identifier     string

	// Updates
	StartResp *testapi.GenericStartResponse
	RunResp   *testapi.GenericRunResponse
	StopResp  *testapi.GenericStopResponse
}

GenericServiceCmd represents gcloud auth cmd.

func NewGenericServiceCmd 

func NewGenericServiceCmd(executor interfaces.ExecutorInterface) *GenericServiceCmd

func (*GenericServiceCmd) ExtractDependencies 

func (cmd *GenericServiceCmd) ExtractDependencies(ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*GenericServiceCmd) Instantiate 

func (cmd *GenericServiceCmd) Instantiate(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

Instantiate extracts initial state info from the state keeper.

func (*GenericServiceCmd) UpdateStateKeeper 

func (cmd *GenericServiceCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type GenericTestsCmd 

type GenericTestsCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	TestRequest *api.TestTask
	Identifier  string

	// Updates
	TestResponses *api.CrosTestResponse
}

GenericTestsCmd represents gcloud auth cmd.

func NewGenericTestsCmd 

func NewGenericTestsCmd(executor interfaces.ExecutorInterface) *GenericTestsCmd

func (*GenericTestsCmd) ExtractDependencies 

func (cmd *GenericTestsCmd) ExtractDependencies(ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*GenericTestsCmd) Instantiate 

func (cmd *GenericTestsCmd) Instantiate(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

Instantiate extracts initial state info from the state keeper.

func (*GenericTestsCmd) UpdateStateKeeper 

func (cmd *GenericTestsCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type InvServiceStartCmd 

type InvServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor
}

InvServiceStartCmd represents inventory service start cmd.

func NewInvServiceStartCmd 

func NewInvServiceStartCmd(executor interfaces.ExecutorInterface) *InvServiceStartCmd

type InvServiceStopCmd 

type InvServiceStopCmd struct {
	*interfaces.SingleCmdByExecutor
}

InvServiceStopCmd represents inventory service stop cmd.

func NewInvServiceStopCmd 

func NewInvServiceStopCmd(executor interfaces.ExecutorInterface) *InvServiceStopCmd

type LoadDutTopologyCmd 

type LoadDutTopologyCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	HostName string

	// Updates
	DutTopology *labapi.DutTopology
}

LoadDutTopologyCmd represents load dut toplogy cmd.

func NewLoadDutTopologyCmd 

func NewLoadDutTopologyCmd(executor interfaces.ExecutorInterface) *LoadDutTopologyCmd

func (*LoadDutTopologyCmd) ExtractDependencies 

func (cmd *LoadDutTopologyCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*LoadDutTopologyCmd) UpdateStateKeeper 

func (cmd *LoadDutTopologyCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type ParseArgsCmd 

type ParseArgsCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor

	// Deps
	Args *data.LocalArgs

	// Updates
	Tests                           []string
	Tags                            []string
	TagsExclude                     []string
	ContainerKeysRequestedForUpdate []string
	DutAddress                      *labapi.IpEndpoint
	DutCacheAddress                 *labapi.IpEndpoint
	CacheAddress                    *labapi.IpEndpoint
}

ParseArgsCmd represents build input validation command.

func NewParseArgsCmd 

func NewParseArgsCmd() *ParseArgsCmd

func (*ParseArgsCmd) Execute 

func (cmd *ParseArgsCmd) Execute(ctx context.Context) error

Execute executes the command.

func (*ParseArgsCmd) ExtractDependencies 

func (cmd *ParseArgsCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*ParseArgsCmd) UpdateStateKeeper 

func (cmd *ParseArgsCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type ParseDutTopologyCmd 

type ParseDutTopologyCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor

	// Deps
	DutTopology        *labapi.DutTopology
	PrimaryDutModel    *labapi.DutModel
	CompanionDutModels []*labapi.DutModel

	// Updates
	Devices           map[string]*testapi.CrosTestRequest_Device
	DevicesMetadata   map[string]*skylab_test_runner.CFTTestRequest_Device
	DeviceIdentifiers []string
	CacheServer       *labapi.IpEndpoint
}

ParseDutTopologyCmd represents build input validation command.

func NewParseDutTopologyCmd 

func NewParseDutTopologyCmd() *ParseDutTopologyCmd

func (*ParseDutTopologyCmd) Execute 

func (cmd *ParseDutTopologyCmd) Execute(ctx context.Context) error

Execute executes the command.

func (*ParseDutTopologyCmd) ExtractDependencies 

func (cmd *ParseDutTopologyCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*ParseDutTopologyCmd) UpdateStateKeeper 

func (cmd *ParseDutTopologyCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type ParseEnvInfoCmd 

type ParseEnvInfoCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor

	// Updates
	HostName            string
	CurrentInvocationId string
}

ParseEnvInfoCmd represents parse env info cmd.

func NewParseEnvInfoCmd 

func NewParseEnvInfoCmd() *ParseEnvInfoCmd

func (*ParseEnvInfoCmd) Execute 

func (cmd *ParseEnvInfoCmd) Execute(ctx context.Context) error

func (*ParseEnvInfoCmd) UpdateStateKeeper 

func (cmd *ParseEnvInfoCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type ProcessResultsCmd 

type ProcessResultsCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor

	// Deps (all are optional)
	CftTestRequest  *skylab_test_runner.CFTTestRequest
	GcsURL          string
	TesthausURL     string
	ProvisionResps  map[string][]*api.InstallResponse
	TestResponses   *api.CrosTestResponse
	CurrentDutState dutstate.State // optional

	// Updates
	SkylabResult           *skylab_test_runner.Result
	TestExecutionStartTime *timestamp.Timestamp
	TestExecutionEndTime   *timestamp.Timestamp

	ANTSInvocationID string
	// contains filtered or unexported fields
}

ProcessResultsCmd represents process results command.

func NewProcessResultsCmd 

func NewProcessResultsCmd() *ProcessResultsCmd

func (*ProcessResultsCmd) Execute 

func (cmd *ProcessResultsCmd) Execute(ctx context.Context) error

Execute executes the command.

func (*ProcessResultsCmd) ExtractDependencies 

func (cmd *ProcessResultsCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*ProcessResultsCmd) UpdateStateKeeper 

func (cmd *ProcessResultsCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type ProvisionInstallCmd 

type ProvisionInstallCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	OsImagePath     *_go.StoragePath
	PreventReboot   bool
	InstallMetadata *anypb.Any

	// Updates
	ProvisionResp *testapi.InstallResponse
}

ProvisionInstallCmd represents provision install cmd.

func NewProvisionInstallCmd 

func NewProvisionInstallCmd(executor interfaces.ExecutorInterface) *ProvisionInstallCmd

func (*ProvisionInstallCmd) ExtractDependencies 

func (cmd *ProvisionInstallCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*ProvisionInstallCmd) UpdateStateKeeper 

func (cmd *ProvisionInstallCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type ProvisionServiceStartCmd 

type ProvisionServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	ProvisionState    *testapi.ProvisionState
	DutServerAddress  *labapi.IpEndpoint
	PrimaryDut        *labapi.Dut
	ServoNexusAddress *labapi.IpEndpoint
}

ProvisionServiceStartCmd represents provision service start cmd.

func NewProvisionServiceStartCmd 

func NewProvisionServiceStartCmd(executor interfaces.ExecutorInterface) *ProvisionServiceStartCmd

func (*ProvisionServiceStartCmd) ExtractDependencies 

func (cmd *ProvisionServiceStartCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type RdbPublishServiceStartCmd 

type RdbPublishServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	RdbPublishSrcDir string
}

RdbPublishServiceStartCmd represents rdb publish service start cmd.

func NewRdbPublishServiceStartCmd 

func NewRdbPublishServiceStartCmd(executor interfaces.ExecutorInterface) *RdbPublishServiceStartCmd

func (*RdbPublishServiceStartCmd) ExtractDependencies 

func (cmd *RdbPublishServiceStartCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type RdbPublishUploadCmd 

type RdbPublishUploadCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	CurrentInvocationId  string
	TesthausURL          string
	Sources              *testapi_metadata.PublishRdbMetadata_Sources
	BaseVariant          map[string]string
	PostProcessResponses *testapi.RunActivitiesResponse

	// Either constructed TestResultForRdb is required,
	TestResultForRdb *artifactpb.TestResult
	// Or all these are required.
	GcsURL        string
	TestResponses *testapipb.CrosTestResponse
}

RdbPublishUploadCmd represents rdb publish upload cmd.

func NewRdbPublishUploadCmd 

func NewRdbPublishUploadCmd(executor interfaces.ExecutorInterface) *RdbPublishUploadCmd

func (*RdbPublishUploadCmd) ExtractDependencies 

func (cmd *RdbPublishUploadCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type SshStartReverseTunnelCmd 

type SshStartReverseTunnelCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	HostName        string
	CacheServerPort uint16

	// Updates
	SshReverseTunnelPort uint16
}

DutServiceStartCmd represents dut service start cmd.

func NewSshStartReverseTunnelCmd 

func NewSshStartReverseTunnelCmd(executor interfaces.ExecutorInterface) *SshStartReverseTunnelCmd

func (*SshStartReverseTunnelCmd) ExtractDependencies 

func (cmd *SshStartReverseTunnelCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*SshStartReverseTunnelCmd) UpdateStateKeeper 

func (cmd *SshStartReverseTunnelCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type SshStartTunnelCmd 

type SshStartTunnelCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	HostName string

	// Updates
	SshTunnelPort uint16
}

DutServiceStartCmd represents dut service start cmd.

func NewSshStartTunnelCmd 

func NewSshStartTunnelCmd(executor interfaces.ExecutorInterface) *SshStartTunnelCmd

func (*SshStartTunnelCmd) ExtractDependencies 

func (cmd *SshStartTunnelCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*SshStartTunnelCmd) UpdateStateKeeper 

func (cmd *SshStartTunnelCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type SshStopTunnelsCmd 

type SshStopTunnelsCmd struct {
	*interfaces.SingleCmdByExecutor
}

DutServiceStartCmd represents dut service start cmd.

func NewSshStopTunnelsCmd 

func NewSshStopTunnelsCmd(executor interfaces.ExecutorInterface) *SshStopTunnelsCmd

type TestFinderExecutionCmd 

type TestFinderExecutionCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps (optional)
	Tests       []string
	Tags        []string
	TagsExclude []string

	// Updates
	TestSuites []*testapi.TestSuite
}

TestFinderExecutionCmd represents test execution cmd.

func NewTestFinderExecutionCmd 

func NewTestFinderExecutionCmd(executor interfaces.ExecutorInterface) *TestFinderExecutionCmd

func (*TestFinderExecutionCmd) ExtractDependencies 

func (cmd *TestFinderExecutionCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*TestFinderExecutionCmd) UpdateStateKeeper 

func (cmd *TestFinderExecutionCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type TestFinderServiceStartCmd 

type TestFinderServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor
}

TestFinderServiceStartCmd represents test service start cmd.

func NewTestFinderServiceStartCmd 

func NewTestFinderServiceStartCmd(executor interfaces.ExecutorInterface) *TestFinderServiceStartCmd

type TestServiceStartCmd 

type TestServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor
}

TestServiceStartCmd represents test service start cmd.

func NewTestServiceStartCmd 

func NewTestServiceStartCmd(executor interfaces.ExecutorInterface) *TestServiceStartCmd

type TestsExecutionCmd 

type TestsExecutionCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	DutServerAddress *labapi.IpEndpoint
	TestSuites       []*testapi.TestSuite
	PrimaryDevice    *testapi.CrosTestRequest_Device
	CompanionDevices []*testapi.CrosTestRequest_Device
	TestArgs         *testapi.AutotestExecutionMetadata
	TastArgs         *testapi.TastExecutionMetadata

	// Updates
	TestResponses      *testapi.CrosTestResponse
	TkoPublishSrcDir   string
	CpconPublishSrcDir string
}

TestsExecutionCmd represents test execution cmd.

func NewTestsExecutionCmd 

func NewTestsExecutionCmd(executor interfaces.ExecutorInterface) *TestsExecutionCmd

func (*TestsExecutionCmd) ExtractDependencies 

func (cmd *TestsExecutionCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*TestsExecutionCmd) UpdateStateKeeper 

func (cmd *TestsExecutionCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type TkoDirectUploadCmd 

type TkoDirectUploadCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor

	// Deps
	TkoPublishSrcDir string
	TestResponses    *testapi.CrosTestResponse
	CftTestRequest   *skylab_test_runner.CFTTestRequest
	TkoJobName       string // Optional but depends on env var
	GcsURL           string // Optional
	TesthausURL      string // Optional
}

UpdateDutStateCmd represents update dut state command.

func NewTkoDirectUploadCmd 

func NewTkoDirectUploadCmd() *TkoDirectUploadCmd

func (*TkoDirectUploadCmd) Execute 

func (cmd *TkoDirectUploadCmd) Execute(ctx context.Context) error

Execute executes the command.

func (*TkoDirectUploadCmd) ExtractDependencies 

func (cmd *TkoDirectUploadCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type TkoPublishServiceStartCmd 

type TkoPublishServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	TkoPublishSrcDir string
}

TkoPublishServiceStartCmd represents tko publish service cmd.

func NewTkoPublishServiceStartCmd 

func NewTkoPublishServiceStartCmd(executor interfaces.ExecutorInterface) *TkoPublishServiceStartCmd

func (*TkoPublishServiceStartCmd) ExtractDependencies 

func (cmd *TkoPublishServiceStartCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type TkoPublishUploadCmd 

type TkoPublishUploadCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	TkoJobName string
}

TkoPublishUploadCmd represents tko publish upload cmd.

func NewTkoPublishUploadCmd 

func NewTkoPublishUploadCmd(executor interfaces.ExecutorInterface) *TkoPublishUploadCmd

func (*TkoPublishUploadCmd) ExtractDependencies 

func (cmd *TkoPublishUploadCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

type UpdateContainerImagesLocallyCmd 

type UpdateContainerImagesLocallyCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor
	ExecutorConfig interfaces.ExecutorConfigInterface

	// Const Deps
	UpdateableContainers map[string]struct{}

	// Deps
	ContainerKeysRequestedForUpdate []string
	ContainersAvailable             map[string]*api.ContainerImageInfo
	Chroot                          string

	// Updates
	Containers map[string]*api.ContainerImageInfo
}

UpdateContainerImagesLocallyCmd represents build input validation command.

func NewUpdateContainerImagesLocallyCmd 

func NewUpdateContainerImagesLocallyCmd() *UpdateContainerImagesLocallyCmd

func (*UpdateContainerImagesLocallyCmd) Execute 

func (cmd *UpdateContainerImagesLocallyCmd) Execute(ctx context.Context) error

Execute executes the command.

func (*UpdateContainerImagesLocallyCmd) ExtractDependencies 

func (cmd *UpdateContainerImagesLocallyCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*UpdateContainerImagesLocallyCmd) UpdateStateKeeper 

func (cmd *UpdateContainerImagesLocallyCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type UpdateDutStateCmd 

type UpdateDutStateCmd struct {
	*interfaces.AbstractSingleCmdByNoExecutor

	// Deps
	TestResponses      *api.CrosTestResponse // optional
	UfsNameSpace       string                // optional
	ProvisionResponses map[string][]*api.InstallResponse
	ProvisionDevices   map[string]*api.CrosTestRequest_Device
	SkipReason         string
	IsAlRun            bool

	// Updates
	CurrentDutState dutstate.State
}

UpdateDutStateCmd represents update dut state command.

func NewUpdateDutStateCmd 

func NewUpdateDutStateCmd() *UpdateDutStateCmd

func (*UpdateDutStateCmd) Execute 

func (cmd *UpdateDutStateCmd) Execute(ctx context.Context) error

Execute executes the command.

func (*UpdateDutStateCmd) ExtractDependencies 

func (cmd *UpdateDutStateCmd) ExtractDependencies(ctx context.Context, ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*UpdateDutStateCmd) UpdateStateKeeper 

func (cmd *UpdateDutStateCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type VMProvisionLeaseCmd 

type VMProvisionLeaseCmd struct {
	*interfaces.SingleCmdByExecutor

	// Deps
	DutVmGceImage *vmlabapi.GceImage
	BuildState    *build.State
	// Updates
	LeaseVMResponse *testapi.LeaseVMResponse
}

VMProvisionLeaseCmd represents vm-provision service lease cmd.

func NewVMProvisionLeaseCmd 

func NewVMProvisionLeaseCmd(executor interfaces.ExecutorInterface) *VMProvisionLeaseCmd

func (*VMProvisionLeaseCmd) ExtractDependencies 

func (cmd *VMProvisionLeaseCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*VMProvisionLeaseCmd) UpdateStateKeeper 

func (cmd *VMProvisionLeaseCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type VMProvisionReleaseCmd 

type VMProvisionReleaseCmd struct {
	*interfaces.SingleCmdByExecutor

	//Deps
	LeaseVMResponse *api.LeaseVMResponse
}

VMProvisionReleaseCmd represents vm-provision service release cmd.

func NewVMProvisionReleaseCmd 

func NewVMProvisionReleaseCmd(executor interfaces.ExecutorInterface) *VMProvisionReleaseCmd

func (*VMProvisionReleaseCmd) ExtractDependencies 

func (cmd *VMProvisionReleaseCmd) ExtractDependencies(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

ExtractDependencies extracts all the command dependencies from state keeper.

func (*VMProvisionReleaseCmd) UpdateStateKeeper 

func (cmd *VMProvisionReleaseCmd) UpdateStateKeeper(
	ctx context.Context,
	ski interfaces.StateKeeperInterface) error

UpdateStateKeeper updates the state keeper with info from the cmd.

type VMProvisionServiceStartCmd 

type VMProvisionServiceStartCmd struct {
	*interfaces.SingleCmdByExecutor
}

VMProvisionServiceStartCmd represents vm-provision service start cmd.

func NewVMProvisionServiceStartCmd 

func NewVMProvisionServiceStartCmd(executor interfaces.ExecutorInterface) *VMProvisionServiceStartCmd

Source Files

View all Source files

Jump to

Keyboard shortcuts

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