skylab_local_state

package
v0.0.0-...-2cbbe0a Latest Latest
Warning

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

Go to latest
Published: Nov 8, 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

Jump to

Keyboard shortcuts

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