skylab_local_state

package
v0.0.0-...-f0b840c Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2024 License: BSD-3-Clause Imports: 5 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_test_platform_skylab_local_state_common_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_skylab_local_state_host_info_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_skylab_local_state_load_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_skylab_local_state_multihost_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_skylab_local_state_receive_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_skylab_local_state_remove_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_skylab_local_state_save_proto protoreflect.FileDescriptor
View Source 
var File_test_platform_skylab_local_state_serialize_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AutotestHostInfo 

type AutotestHostInfo struct {
	Attributes        map[string]string `` /* 161-byte string literal not displayed */
	Labels            []string          `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	SerializerVersion int32             `protobuf:"varint,3,opt,name=serializer_version,proto3" json:"serializer_version,omitempty"`
	// contains filtered or unexported fields
}

AutotestHostInfo defines the structure of the host info file which is used to pass host information to Autotest and receive host information changes from Autotest.

func (*AutotestHostInfo) Descriptor deprecated 

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

Deprecated: Use AutotestHostInfo.ProtoReflect.Descriptor instead.

func (*AutotestHostInfo) GetAttributes 

func (x *AutotestHostInfo) GetAttributes() map[string]string

func (*AutotestHostInfo) GetLabels 

func (x *AutotestHostInfo) GetLabels() []string

func (*AutotestHostInfo) GetSerializerVersion 

func (x *AutotestHostInfo) GetSerializerVersion() int32

func (*AutotestHostInfo) ProtoMessage 

func (*AutotestHostInfo) ProtoMessage()

func (*AutotestHostInfo) ProtoReflect 

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

func (*AutotestHostInfo) Reset 

func (x *AutotestHostInfo) Reset()

func (*AutotestHostInfo) String 

func (x *AutotestHostInfo) String() string

type Config 

type Config 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"`
	// Autotest directory on the drone, e.g. "/usr/local/autotest".
	AutotestDir string `protobuf:"bytes,2,opt,name=autotest_dir,json=autotestDir,proto3" json:"autotest_dir,omitempty"`
	// Inventory V2 service host, e.g. cros-lab-inventory.appspot.com.
	CrosInventoryService string `protobuf:"bytes,3,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,4,opt,name=cros_ufs_service,json=crosUfsService,proto3" json:"cros_ufs_service,omitempty"`
	// Swarming bot prefix to be used on the drone
	BotPrefix string `protobuf:"bytes,5,opt,name=bot_prefix,json=botPrefix,proto3" json:"bot_prefix,omitempty"`
	// Unified Fleet System service host, e.g. `os`, `os-partner`
	// If left empty, should be handled as if it were `os`
	UfsNamespace string `protobuf:"bytes,6,opt,name=ufs_namespace,json=ufsNamespace,proto3" json:"ufs_namespace,omitempty"`
	// contains filtered or unexported fields
}

Config defines configuration parameters of skylab_local_state.

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetAdminService 

func (x *Config) GetAdminService() string

func (*Config) GetAutotestDir 

func (x *Config) GetAutotestDir() string

func (*Config) GetBotPrefix 

func (x *Config) GetBotPrefix() string

func (*Config) GetCrosInventoryService 

func (x *Config) GetCrosInventoryService() string

func (*Config) GetCrosUfsService 

func (x *Config) GetCrosUfsService() string

func (*Config) GetUfsNamespace 

func (x *Config) GetUfsNamespace() string

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 Dut 

type Dut struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Board    string `protobuf:"bytes,2,opt,name=board,proto3" json:"board,omitempty"`
	Model    string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

Represents a DUT from lab.

func (*Dut) Descriptor deprecated 

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

Deprecated: Use Dut.ProtoReflect.Descriptor instead.

func (*Dut) GetBoard 

func (x *Dut) GetBoard() string

func (*Dut) GetHostname 

func (x *Dut) GetHostname() string

func (*Dut) GetModel 

func (x *Dut) GetModel() string

func (*Dut) ProtoMessage 

func (*Dut) ProtoMessage()

func (*Dut) ProtoReflect 

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

func (*Dut) Reset 

func (x *Dut) Reset()

func (*Dut) String 

func (x *Dut) String() string

type LoadRequest 

type LoadRequest struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// DUT hostname.
	DutName string `protobuf:"bytes,3,opt,name=dut_name,json=dutName,proto3" json:"dut_name,omitempty"`
	// Swarming run ID. Used in the results directory name.
	RunId string `protobuf:"bytes,4,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// DUT ID, used in the name of the DUT state cache file.
	DutId string `protobuf:"bytes,5,opt,name=dut_id,json=dutId,proto3" json:"dut_id,omitempty"`
	// Test ID, used in the results directory name.
	TestId string `protobuf:"bytes,6,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	// A flag to indicates if the dut_name is a scheduling unit dut_name.
	MultiDutsFlag bool `protobuf:"varint,7,opt,name=multi_duts_flag,json=multiDutsFlag,proto3" json:"multi_duts_flag,omitempty"`
	// contains filtered or unexported fields
}

LoadRequest defines the input of `skylab_local_state load`.

func (*LoadRequest) Descriptor deprecated 

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

Deprecated: Use LoadRequest.ProtoReflect.Descriptor instead.

func (*LoadRequest) GetConfig 

func (x *LoadRequest) GetConfig() *Config

func (*LoadRequest) GetDutId 

func (x *LoadRequest) GetDutId() string

func (*LoadRequest) GetDutName 

func (x *LoadRequest) GetDutName() string

func (*LoadRequest) GetMultiDutsFlag 

func (x *LoadRequest) GetMultiDutsFlag() bool

func (*LoadRequest) GetRunId 

func (x *LoadRequest) GetRunId() string

func (*LoadRequest) GetTestId 

func (x *LoadRequest) GetTestId() string

func (*LoadRequest) ProtoMessage 

func (*LoadRequest) ProtoMessage()

func (*LoadRequest) ProtoReflect 

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

func (*LoadRequest) Reset 

func (x *LoadRequest) Reset()

func (*LoadRequest) String 

func (x *LoadRequest) String() string

type LoadResponse 

type LoadResponse struct {

	// What is currently installed on the DUT, e.g.
	// "cros-version": "reef-release/R77-12345.0.0".
	ProvisionableLabels map[string]string `` /* 206-byte string literal not displayed */
	// The path to the newly created directory containing the host info file.
	ResultsDir string `protobuf:"bytes,2,opt,name=results_dir,json=resultsDir,proto3" json:"results_dir,omitempty"`
	// In a multi-DUTs use cases, we need return some basic information
	// of all DUTs under a scheduling unit, so that provision and test
	// exection steps can determine which of them will be used based on
	// test metadata.
	DutTopology []*Dut `protobuf:"bytes,4,rep,name=dut_topology,json=dutTopology,proto3" json:"dut_topology,omitempty"`
	// This is only used by CFT MVP.
	LabDutTopology []*api.DutTopology `protobuf:"bytes,5,rep,name=lab_dut_topology,json=labDutTopology,proto3" json:"lab_dut_topology,omitempty"`
	// contains filtered or unexported fields
}

LoadResponse defines the output of `skylab_local_state load`.

func (*LoadResponse) Descriptor deprecated 

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

Deprecated: Use LoadResponse.ProtoReflect.Descriptor instead.

func (*LoadResponse) GetDutTopology 

func (x *LoadResponse) GetDutTopology() []*Dut

func (*LoadResponse) GetLabDutTopology 

func (x *LoadResponse) GetLabDutTopology() []*api.DutTopology

func (*LoadResponse) GetProvisionableLabels 

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

func (*LoadResponse) GetResultsDir 

func (x *LoadResponse) GetResultsDir() string

func (*LoadResponse) ProtoMessage 

func (*LoadResponse) ProtoMessage()

func (*LoadResponse) ProtoReflect 

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

func (*LoadResponse) Reset 

func (x *LoadResponse) Reset()

func (*LoadResponse) String 

func (x *LoadResponse) String() string

type MultiBotHostInfo 

type MultiBotHostInfo struct {
	HostInfo *AutotestHostInfo `protobuf:"bytes,1,opt,name=host_info,json=hostInfo,proto3" json:"host_info,omitempty"`
	// DUT hostname.
	DutName string `protobuf:"bytes,2,opt,name=dut_name,json=dutName,proto3" json:"dut_name,omitempty"`
	// contains filtered or unexported fields
}

Host info and other necessary info to be shared by follower tasks in a multi-bot job

func (*MultiBotHostInfo) Descriptor deprecated 

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

Deprecated: Use MultiBotHostInfo.ProtoReflect.Descriptor instead.

func (*MultiBotHostInfo) GetDutName 

func (x *MultiBotHostInfo) GetDutName() string

func (*MultiBotHostInfo) GetHostInfo 

func (x *MultiBotHostInfo) GetHostInfo() *AutotestHostInfo

func (*MultiBotHostInfo) ProtoMessage 

func (*MultiBotHostInfo) ProtoMessage()

func (*MultiBotHostInfo) ProtoReflect 

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

func (*MultiBotHostInfo) Reset 

func (x *MultiBotHostInfo) Reset()

func (*MultiBotHostInfo) String 

func (x *MultiBotHostInfo) String() string

type ReceiveRequest 

type ReceiveRequest struct {

	// The path to the directory where host info file(s) will be placed. It will
	// be created it if does not exist yet.
	ResultsDir   string `protobuf:"bytes,1,opt,name=results_dir,json=resultsDir,proto3" json:"results_dir,omitempty"`
	MessageCount int32  `protobuf:"varint,2,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	// contains filtered or unexported fields
}

ReceiveRequest defines the input of `skylab_local_state receive`.

func (*ReceiveRequest) Descriptor deprecated 

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

Deprecated: Use ReceiveRequest.ProtoReflect.Descriptor instead.

func (*ReceiveRequest) GetMessageCount 

func (x *ReceiveRequest) GetMessageCount() int32

func (*ReceiveRequest) GetResultsDir 

func (x *ReceiveRequest) GetResultsDir() string

func (*ReceiveRequest) ProtoMessage 

func (*ReceiveRequest) ProtoMessage()

func (*ReceiveRequest) ProtoReflect 

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

func (*ReceiveRequest) Reset 

func (x *ReceiveRequest) Reset()

func (*ReceiveRequest) String 

func (x *ReceiveRequest) String() string

type ReceiveResponse 

type ReceiveResponse struct {
	ReceivedMessages int32 `protobuf:"varint,1,opt,name=received_messages,json=receivedMessages,proto3" json:"received_messages,omitempty"`
	// contains filtered or unexported fields
}

ReceiveResponse defines the output of `skylab_local_state receive`.

func (*ReceiveResponse) Descriptor deprecated 

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

Deprecated: Use ReceiveResponse.ProtoReflect.Descriptor instead.

func (*ReceiveResponse) GetReceivedMessages 

func (x *ReceiveResponse) GetReceivedMessages() int32

func (*ReceiveResponse) ProtoMessage 

func (*ReceiveResponse) ProtoMessage()

func (*ReceiveResponse) ProtoReflect 

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

func (*ReceiveResponse) Reset 

func (x *ReceiveResponse) Reset()

func (*ReceiveResponse) String 

func (x *ReceiveResponse) String() string

type RemoveRequest 

type RemoveRequest struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// Swarming run ID. Used in the results directory name.
	RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

RemoveRequest defines the input of `skylab_local_state remove`.

func (*RemoveRequest) Descriptor deprecated 

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetConfig 

func (x *RemoveRequest) GetConfig() *Config

func (*RemoveRequest) GetRunId 

func (x *RemoveRequest) GetRunId() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect 

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

func (*RemoveRequest) Reset 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (x *RemoveRequest) String() string

type SaveRequest 

type SaveRequest struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// The path to the directory where the host info file is located.
	ResultsDir string `protobuf:"bytes,2,opt,name=results_dir,json=resultsDir,proto3" json:"results_dir,omitempty"`
	// DUT hostname, used in the name of the host info file.
	DutName string `protobuf:"bytes,3,opt,name=dut_name,json=dutName,proto3" json:"dut_name,omitempty"`
	// DUT ID, deprecated in skylab_local_state.
	DutId string `protobuf:"bytes,4,opt,name=dut_id,json=dutId,proto3" json:"dut_id,omitempty"`
	// E.g. "needs_repair", "ready" etc.
	DutState string `protobuf:"bytes,5,opt,name=dut_state,json=dutState,proto3" json:"dut_state,omitempty"`
	// If true, mark results directory as ready for offload.
	SealResultsDir bool `protobuf:"varint,6,opt,name=seal_results_dir,json=sealResultsDir,proto3" json:"seal_results_dir,omitempty"`
	// Hostname of peer DUTs in a multi-DUTs task.
	PeerDuts []string `protobuf:"bytes,7,rep,name=peer_duts,json=peerDuts,proto3" json:"peer_duts,omitempty"`
	// Special repair-requests to enforce repair actions.
	RepairRequests []string `protobuf:"bytes,8,rep,name=repair_requests,json=repairRequests,proto3" json:"repair_requests,omitempty"`
	// contains filtered or unexported fields
}

SaveRequest defines the input of `skylab_local_state save`.

func (*SaveRequest) Descriptor deprecated 

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

Deprecated: Use SaveRequest.ProtoReflect.Descriptor instead.

func (*SaveRequest) GetConfig 

func (x *SaveRequest) GetConfig() *Config

func (*SaveRequest) GetDutId 

func (x *SaveRequest) GetDutId() string

func (*SaveRequest) GetDutName 

func (x *SaveRequest) GetDutName() string

func (*SaveRequest) GetDutState 

func (x *SaveRequest) GetDutState() string

func (*SaveRequest) GetPeerDuts 

func (x *SaveRequest) GetPeerDuts() []string

func (*SaveRequest) GetRepairRequests 

func (x *SaveRequest) GetRepairRequests() []string

func (*SaveRequest) GetResultsDir 

func (x *SaveRequest) GetResultsDir() string

func (*SaveRequest) GetSealResultsDir 

func (x *SaveRequest) GetSealResultsDir() bool

func (*SaveRequest) ProtoMessage 

func (*SaveRequest) ProtoMessage()

func (*SaveRequest) ProtoReflect 

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

func (*SaveRequest) Reset 

func (x *SaveRequest) Reset()

func (*SaveRequest) String 

func (x *SaveRequest) String() string

type SerializeRequest 

type SerializeRequest struct {

	// The name of the DUT whose host info will be serialized
	DutName string `protobuf:"bytes,1,opt,name=dut_name,json=dutName,proto3" json:"dut_name,omitempty"`
	// Path to the directory where host info sits
	ResultsDir string `protobuf:"bytes,2,opt,name=results_dir,json=resultsDir,proto3" json:"results_dir,omitempty"`
	// contains filtered or unexported fields
}

SerializeRequest defines the input of `skylab_local_state serialize`.

func (*SerializeRequest) Descriptor deprecated 

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

Deprecated: Use SerializeRequest.ProtoReflect.Descriptor instead.

func (*SerializeRequest) GetDutName 

func (x *SerializeRequest) GetDutName() string

func (*SerializeRequest) GetResultsDir 

func (x *SerializeRequest) GetResultsDir() string

func (*SerializeRequest) ProtoMessage 

func (*SerializeRequest) ProtoMessage()

func (*SerializeRequest) ProtoReflect 

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

func (*SerializeRequest) Reset 

func (x *SerializeRequest) Reset()

func (*SerializeRequest) String 

func (x *SerializeRequest) String() string

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.