tls

package
v0.0.0-...-b8a1838 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2024 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 11 Imported by: 10

Documentation

Index

Examples

Constants

This section is empty.

Variables

View Source 
var (
	Output_name = map[int32]string{
		0: "OUTPUT_PIPE",
		1: "OUTPUT_STDOUT",
	}
	Output_value = map[string]int32{
		"OUTPUT_PIPE":   0,
		"OUTPUT_STDOUT": 1,
	}
)

Enum value maps for Output.

View Source 
var (
	ProvisionDutResponse_Reason_name = map[int32]string{
		0: "REASON_INVALID_REQUEST",
		1: "REASON_DUT_UNREACHABLE_PRE_PROVISION",
		2: "REASON_DOWNLOADING_IMAGE_FAILED",
		3: "REASON_PROVISIONING_TIMEDOUT",
		4: "REASON_PROVISIONING_FAILED",
		5: "REASON_DUT_UNREACHABLE_POST_PROVISION",
		6: "REASON_UPDATE_FIRMWARE_FAILED",
		7: "REASON_FIRMWARE_MISMATCH_POST_FIRMWARE_UPDATE",
		8: "REASON_DUT_UNREACHABLE_POST_FIRMWARE_UPDATE",
	}
	ProvisionDutResponse_Reason_value = map[string]int32{
		"REASON_INVALID_REQUEST":                        0,
		"REASON_DUT_UNREACHABLE_PRE_PROVISION":          1,
		"REASON_DOWNLOADING_IMAGE_FAILED":               2,
		"REASON_PROVISIONING_TIMEDOUT":                  3,
		"REASON_PROVISIONING_FAILED":                    4,
		"REASON_DUT_UNREACHABLE_POST_PROVISION":         5,
		"REASON_UPDATE_FIRMWARE_FAILED":                 6,
		"REASON_FIRMWARE_MISMATCH_POST_FIRMWARE_UPDATE": 7,
		"REASON_DUT_UNREACHABLE_POST_FIRMWARE_UPDATE":   8,
	}
)

Enum value maps for ProvisionDutResponse_Reason.

View Source 
var (
	ProvisionLacrosResponse_Reason_name = map[int32]string{
		0: "REASON_INVALID_REQUEST",
		1: "REASON_DUT_UNREACHABLE_PRE_PROVISION",
		2: "REASON_DOWNLOADING_IMAGE_FAILED",
		3: "REASON_PROVISIONING_TIMEDOUT",
		4: "REASON_PROVISIONING_FAILED",
	}
	ProvisionLacrosResponse_Reason_value = map[string]int32{
		"REASON_INVALID_REQUEST":               0,
		"REASON_DUT_UNREACHABLE_PRE_PROVISION": 1,
		"REASON_DOWNLOADING_IMAGE_FAILED":      2,
		"REASON_PROVISIONING_TIMEDOUT":         3,
		"REASON_PROVISIONING_FAILED":           4,
	}
)

Enum value maps for ProvisionLacrosResponse_Reason.

View Source 
var (
	ProvisionAshResponse_Reason_name = map[int32]string{
		0: "REASON_INVALID_REQUEST",
		1: "REASON_DUT_UNREACHABLE_PRE_PROVISION",
		2: "REASON_DOWNLOADING_BUNDLE_FAILED",
		3: "REASON_PROVISIONING_TIMEDOUT",
		4: "REASON_PROVISIONING_FAILED",
	}
	ProvisionAshResponse_Reason_value = map[string]int32{
		"REASON_INVALID_REQUEST":               0,
		"REASON_DUT_UNREACHABLE_PRE_PROVISION": 1,
		"REASON_DOWNLOADING_BUNDLE_FAILED":     2,
		"REASON_PROVISIONING_TIMEDOUT":         3,
		"REASON_PROVISIONING_FAILED":           4,
	}
)

Enum value maps for ProvisionAshResponse_Reason.

View Source 
var (
	FakeOmaha_Payload_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "FULL",
		2: "DELTA",
	}
	FakeOmaha_Payload_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"FULL":             1,
		"DELTA":            2,
	}
)

Enum value maps for FakeOmaha_Payload_Type.

View Source 
var (
	License_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "WINDOWS_10_PRO",
		2: "MS_OFFICE_STANDARD",
	}
	License_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":   0,
		"WINDOWS_10_PRO":     1,
		"MS_OFFICE_STANDARD": 2,
	}
)

Enum value maps for License_Type.

View Source 
var (
	SetDutPowerSupplyRequest_State_name = map[int32]string{
		0: "STATE_UNKNOWN",
		1: "STATE_ON",
		2: "STATE_OFF",
	}
	SetDutPowerSupplyRequest_State_value = map[string]int32{
		"STATE_UNKNOWN": 0,
		"STATE_ON":      1,
		"STATE_OFF":     2,
	}
)

Enum value maps for SetDutPowerSupplyRequest_State.

View Source 
var (
	SetDutPowerSupplyResponse_Status_name = map[int32]string{
		0: "STATUS_UNKNOWN",
		1: "STATUS_OK",
		2: "STATUS_BAD_DUT",
		3: "STATUS_BAD_REQUEST",
		4: "STATUS_NO_RPM",
		5: "STATUS_RPM_ERROR",
	}
	SetDutPowerSupplyResponse_Status_value = map[string]int32{
		"STATUS_UNKNOWN":     0,
		"STATUS_OK":          1,
		"STATUS_BAD_DUT":     2,
		"STATUS_BAD_REQUEST": 3,
		"STATUS_NO_RPM":      4,
		"STATUS_RPM_ERROR":   5,
	}
)

Enum value maps for SetDutPowerSupplyResponse_Status.

View Source 
var Common_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chromiumos.config.api.test.tls.Common",
	HandlerType: (*CommonServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProvisionDut",
			Handler:    _Common_ProvisionDut_Handler,
		},
		{
			MethodName: "ProvisionLacros",
			Handler:    _Common_ProvisionLacros_Handler,
		},
		{
			MethodName: "ProvisionAsh",
			Handler:    _Common_ProvisionAsh_Handler,
		},
		{
			MethodName: "CreateFakeOmaha",
			Handler:    _Common_CreateFakeOmaha_Handler,
		},
		{
			MethodName: "DeleteFakeOmaha",
			Handler:    _Common_DeleteFakeOmaha_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecDutCommand",
			Handler:       _Common_ExecDutCommand_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "FetchCrashes",
			Handler:       _Common_FetchCrashes_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "chromiumos/config/api/test/tls/commontls.proto",
}

Common_ServiceDesc is the grpc.ServiceDesc for Common 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_chromiumos_config_api_test_tls_commontls_proto protoreflect.FileDescriptor
View Source 
var File_chromiumos_config_api_test_tls_wiring_proto protoreflect.FileDescriptor
View Source 
var Wiring_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "chromiumos.config.api.test.tls.Wiring",
	HandlerType: (*WiringServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetDut",
			Handler:    _Wiring_GetDut_Handler,
		},
		{
			MethodName: "OpenDutPort",
			Handler:    _Wiring_OpenDutPort_Handler,
		},
		{
			MethodName: "SetDutPowerSupply",
			Handler:    _Wiring_SetDutPowerSupply_Handler,
		},
		{
			MethodName: "CacheForDut",
			Handler:    _Wiring_CacheForDut_Handler,
		},
		{
			MethodName: "CallServo",
			Handler:    _Wiring_CallServo_Handler,
		},
		{
			MethodName: "ExposePortToDut",
			Handler:    _Wiring_ExposePortToDut_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "chromiumos/config/api/test/tls/wiring.proto",
}

Wiring_ServiceDesc is the grpc.ServiceDesc for Wiring service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterCommonServer 

func RegisterCommonServer(s grpc.ServiceRegistrar, srv CommonServer)

func RegisterWiringServer 

func RegisterWiringServer(s grpc.ServiceRegistrar, srv WiringServer)

Types

type CacheForDutMetadata 

type CacheForDutMetadata struct {
	// contains filtered or unexported fields
}

func (*CacheForDutMetadata) Descriptor deprecated 

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

Deprecated: Use CacheForDutMetadata.ProtoReflect.Descriptor instead.

func (*CacheForDutMetadata) ProtoMessage 

func (*CacheForDutMetadata) ProtoMessage()

func (*CacheForDutMetadata) ProtoReflect 

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

func (*CacheForDutMetadata) Reset 

func (x *CacheForDutMetadata) Reset()

func (*CacheForDutMetadata) String 

func (x *CacheForDutMetadata) String() string

type CacheForDutRequest 

type CacheForDutRequest struct {

	// url identifies the resource to cache.
	// Only http, https, and gs schemes are supported. The resource to cache MUST
	// be accessible from the service. The implementation MAY use
	// implementation-specific credentials to attempt to access resources.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// dut_name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	// (-- aip.dev/not-precedent: This preceded the AIP standards.
	//     Ordinarily, this field should be either `name` or `dut`,
	//     depending on whether this is a method on Dut resources. --)
	DutName string `protobuf:"bytes,2,opt,name=dut_name,json=dutName,proto3" json:"dut_name,omitempty"`
	// contains filtered or unexported fields
}
Example 
package main

import (
	"context"
	"fmt"

	"github.com/golang/protobuf/ptypes"
	"github.com/golang/protobuf/ptypes/duration"

	rtd "go.chromium.org/chromiumos/config/go/api/test/rtd/v1"
	"go.chromium.org/chromiumos/config/go/api/test/tls"
	"go.chromium.org/chromiumos/config/go/api/test/tls/dependencies/longrunning"
	"google.golang.org/grpc"
)

func main() {
	var invocation rtd.Invocation

	tlsConfig := invocation.GetTestLabServicesConfig()
	dutName := invocation.GetDuts()[0].GetTlsDutName()
	gsURL := "gs://my-bucket/path/to/file"

	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", tlsConfig.GetTlwAddress(), tlsConfig.GetTlwPort()))
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	c := tls.NewWiringClient(conn)
	opcli := longrunning.NewOperationsClient(conn)
	ctx := context.Background()

	req := tls.CacheForDutRequest{
		Url:     gsURL,
		DutName: dutName,
	}
	op, err := c.CacheForDut(ctx, &req)
	if err != nil {
		panic("RPC error")
	}

	op, err = opcli.WaitOperation(ctx, &longrunning.WaitOperationRequest{
		Name: op.GetName(),
		Timeout: &duration.Duration{
			Seconds: 300,
		},
	})
	if err != nil {
		panic("RPC error")
	}

	if errStatus := op.GetError(); errStatus != nil {
		panic("Operation error")
	}
	resp := &tls.CacheForDutResponse{}
	if err := ptypes.UnmarshalAny(op.GetResponse(), resp); err != nil {
		panic("Unmarshal response error")
	}
	// Handle the response in various ways.
	_ = resp
}

Output:

func (*CacheForDutRequest) Descriptor deprecated 

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

Deprecated: Use CacheForDutRequest.ProtoReflect.Descriptor instead.

func (*CacheForDutRequest) GetDutName 

func (x *CacheForDutRequest) GetDutName() string

func (*CacheForDutRequest) GetUrl 

func (x *CacheForDutRequest) GetUrl() string

func (*CacheForDutRequest) ProtoMessage 

func (*CacheForDutRequest) ProtoMessage()

func (*CacheForDutRequest) ProtoReflect 

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

func (*CacheForDutRequest) Reset 

func (x *CacheForDutRequest) Reset()

func (*CacheForDutRequest) String 

func (x *CacheForDutRequest) String() string

type CacheForDutResponse 

type CacheForDutResponse struct {

	// url is where the resource is cached at.
	// This MUST be accessible to the DUT.
	// If the host part of the url is a name, it MUST be resolvable by the DUT
	// via standard name resolution facilities.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*CacheForDutResponse) Descriptor deprecated 

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

Deprecated: Use CacheForDutResponse.ProtoReflect.Descriptor instead.

func (*CacheForDutResponse) GetUrl 

func (x *CacheForDutResponse) GetUrl() string

func (*CacheForDutResponse) ProtoMessage 

func (*CacheForDutResponse) ProtoMessage()

func (*CacheForDutResponse) ProtoReflect 

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

func (*CacheForDutResponse) Reset 

func (x *CacheForDutResponse) Reset()

func (*CacheForDutResponse) String 

func (x *CacheForDutResponse) String() string

type CallServoRequest 

type CallServoRequest struct {
	Dut    string          `protobuf:"bytes,1,opt,name=dut,proto3" json:"dut,omitempty"`
	Method string          `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Args   []*xmlrpc.Value `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*CallServoRequest) Descriptor deprecated 

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

Deprecated: Use CallServoRequest.ProtoReflect.Descriptor instead.

func (*CallServoRequest) GetArgs 

func (x *CallServoRequest) GetArgs() []*xmlrpc.Value

func (*CallServoRequest) GetDut 

func (x *CallServoRequest) GetDut() string

func (*CallServoRequest) GetMethod 

func (x *CallServoRequest) GetMethod() string

func (*CallServoRequest) ProtoMessage 

func (*CallServoRequest) ProtoMessage()

func (*CallServoRequest) ProtoReflect 

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

func (*CallServoRequest) Reset 

func (x *CallServoRequest) Reset()

func (*CallServoRequest) String 

func (x *CallServoRequest) String() string

type CallServoResponse 

type CallServoResponse struct {
	Value *xmlrpc.Value `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// fault indicates that the servo XML-RPC returned a fault.
	// The fault value is stored in the value field.
	Fault bool `protobuf:"varint,2,opt,name=fault,proto3" json:"fault,omitempty"`
	// contains filtered or unexported fields
}

func (*CallServoResponse) Descriptor deprecated 

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

Deprecated: Use CallServoResponse.ProtoReflect.Descriptor instead.

func (*CallServoResponse) GetFault 

func (x *CallServoResponse) GetFault() bool

func (*CallServoResponse) GetValue 

func (x *CallServoResponse) GetValue() *xmlrpc.Value

func (*CallServoResponse) ProtoMessage 

func (*CallServoResponse) ProtoMessage()

func (*CallServoResponse) ProtoReflect 

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

func (*CallServoResponse) Reset 

func (x *CallServoResponse) Reset()

func (*CallServoResponse) String 

func (x *CallServoResponse) String() string

type ChromeOsImage 

type ChromeOsImage struct {

	// Types that are assignable to PathOneof:
	//	*ChromeOsImage_GsPathPrefix
	PathOneof isChromeOsImage_PathOneof `protobuf_oneof:"path_oneof"`
	// contains filtered or unexported fields
}

func (*ChromeOsImage) Descriptor deprecated 

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

Deprecated: Use ChromeOsImage.ProtoReflect.Descriptor instead.

func (*ChromeOsImage) GetGsPathPrefix 

func (x *ChromeOsImage) GetGsPathPrefix() string

func (*ChromeOsImage) GetPathOneof 

func (m *ChromeOsImage) GetPathOneof() isChromeOsImage_PathOneof

func (*ChromeOsImage) ProtoMessage 

func (*ChromeOsImage) ProtoMessage()

func (*ChromeOsImage) ProtoReflect 

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

func (*ChromeOsImage) Reset 

func (x *ChromeOsImage) Reset()

func (*ChromeOsImage) String 

func (x *ChromeOsImage) String() string

type ChromeOsImage_GsPathPrefix 

type ChromeOsImage_GsPathPrefix struct {
	// gs_path_prefix is the GS path to where the payloads are located. For
	// example the format MAY be:
	// gs://chromeos-image-archive/eve-release/R86-13380.0.0
	GsPathPrefix string `protobuf:"bytes,1,opt,name=gs_path_prefix,json=gsPathPrefix,proto3,oneof"`
}

type CommonClient 

type CommonClient interface {
	// ExecDutCommand runs a command on a DUT.
	//
	// The working directory is /.
	// A tty is not spawned for the command.
	// The user and group is root.
	// All signals have their default dispositions and are not masked.
	// The umask is set to 0.
	//
	// The environment contains:
	//
	//   TERM=dumb
	//   PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/bin
	//   LANG=en_US.UTF-8
	//   USER=root
	//   HOME=/root
	//
	// The environment MAY also contain SSH client variables.
	// The environment SHALL NOT contain variables not mentioned above.
	//
	// If the stream is interrupted, the implementation MAY attempt to
	// stop the command by sending SIGINT, SIGHUP, SIGTERM, or SIGKILL.
	ExecDutCommand(ctx context.Context, in *ExecDutCommandRequest, opts ...grpc.CallOption) (Common_ExecDutCommandClient, error)
	// ProvisionDut installs a specified version of Chrome OS on the DUT, along
	// with any specified DLCs.
	//
	// If the DUT is already on the specified version of Chrome OS, the OS will
	// not be provisioned.
	//
	// If the DUT already has the specified list of DLCs, only the missing DLCs
	// will be provisioned.
	ProvisionDut(ctx context.Context, in *ProvisionDutRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// ProvisionLacros installs a specified version of Lacros on the DUT.
	//
	// If the DUT already has the specified version of Lacros, Lacros will not be
	// provisioned.
	ProvisionLacros(ctx context.Context, in *ProvisionLacrosRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// ProvisionAsh installs a specific version of AshChrome on the DUT.
	//
	ProvisionAsh(ctx context.Context, in *ProvisionAshRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// FetchCrashes gets a stream of all crash reports currently on the DUT.
	//
	// The stream returned may split up a crash over multiple
	// `FetchCrashesResponse` protos. See the definition of that proto for
	// details.
	//
	// This call is read-only: it doesn't delete the crashes that it reads.
	FetchCrashes(ctx context.Context, in *FetchCrashesRequest, opts ...grpc.CallOption) (Common_FetchCrashesClient, error)
	// CreateFakeOmaha starts a fake Omaha service on TLS and exposes the
	// listened port to the DUT.
	CreateFakeOmaha(ctx context.Context, in *CreateFakeOmahaRequest, opts ...grpc.CallOption) (*FakeOmaha, error)
	// DeleteFakeOmaha deletes the specified fake Omaha resource created by
	// CreateFakeOmaha.
	DeleteFakeOmaha(ctx context.Context, in *DeleteFakeOmahaRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

CommonClient is the client API for Common service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCommonClient 

func NewCommonClient(cc grpc.ClientConnInterface) CommonClient

type CommonServer 

type CommonServer interface {
	// ExecDutCommand runs a command on a DUT.
	//
	// The working directory is /.
	// A tty is not spawned for the command.
	// The user and group is root.
	// All signals have their default dispositions and are not masked.
	// The umask is set to 0.
	//
	// The environment contains:
	//
	//   TERM=dumb
	//   PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/bin
	//   LANG=en_US.UTF-8
	//   USER=root
	//   HOME=/root
	//
	// The environment MAY also contain SSH client variables.
	// The environment SHALL NOT contain variables not mentioned above.
	//
	// If the stream is interrupted, the implementation MAY attempt to
	// stop the command by sending SIGINT, SIGHUP, SIGTERM, or SIGKILL.
	ExecDutCommand(*ExecDutCommandRequest, Common_ExecDutCommandServer) error
	// ProvisionDut installs a specified version of Chrome OS on the DUT, along
	// with any specified DLCs.
	//
	// If the DUT is already on the specified version of Chrome OS, the OS will
	// not be provisioned.
	//
	// If the DUT already has the specified list of DLCs, only the missing DLCs
	// will be provisioned.
	ProvisionDut(context.Context, *ProvisionDutRequest) (*longrunning.Operation, error)
	// ProvisionLacros installs a specified version of Lacros on the DUT.
	//
	// If the DUT already has the specified version of Lacros, Lacros will not be
	// provisioned.
	ProvisionLacros(context.Context, *ProvisionLacrosRequest) (*longrunning.Operation, error)
	// ProvisionAsh installs a specific version of AshChrome on the DUT.
	//
	ProvisionAsh(context.Context, *ProvisionAshRequest) (*longrunning.Operation, error)
	// FetchCrashes gets a stream of all crash reports currently on the DUT.
	//
	// The stream returned may split up a crash over multiple
	// `FetchCrashesResponse` protos. See the definition of that proto for
	// details.
	//
	// This call is read-only: it doesn't delete the crashes that it reads.
	FetchCrashes(*FetchCrashesRequest, Common_FetchCrashesServer) error
	// CreateFakeOmaha starts a fake Omaha service on TLS and exposes the
	// listened port to the DUT.
	CreateFakeOmaha(context.Context, *CreateFakeOmahaRequest) (*FakeOmaha, error)
	// DeleteFakeOmaha deletes the specified fake Omaha resource created by
	// CreateFakeOmaha.
	DeleteFakeOmaha(context.Context, *DeleteFakeOmahaRequest) (*emptypb.Empty, error)
}

CommonServer is the server API for Common service. All implementations should embed UnimplementedCommonServer for forward compatibility

type Common_ExecDutCommandClient 

type Common_ExecDutCommandClient interface {
	Recv() (*ExecDutCommandResponse, error)
	grpc.ClientStream
}

type Common_ExecDutCommandServer 

type Common_ExecDutCommandServer interface {
	Send(*ExecDutCommandResponse) error
	grpc.ServerStream
}

type Common_FetchCrashesClient 

type Common_FetchCrashesClient interface {
	Recv() (*FetchCrashesResponse, error)
	grpc.ClientStream
}

type Common_FetchCrashesServer 

type Common_FetchCrashesServer interface {
	Send(*FetchCrashesResponse) error
	grpc.ServerStream
}

type CrashBlob 

type CrashBlob struct {

	// This value is a UTF8, human-readable, description of the data.
	// This should be passed as the 'name' to the crash server.
	// For instance, upload_file_fake_payload
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value is a blob (e.g. a file from sysfs or a minidump), which need
	// not be valid UTF-8, and may be large.
	Blob []byte `protobuf:"bytes,2,opt,name=blob,proto3" json:"blob,omitempty"`
	// The basename of the file. Must be specified as the filename in data
	// uploaded to the crash server.
	// e.g. foo_binary.20201027.102345.0.dmp
	Filename string `protobuf:"bytes,3,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

Arbitrary non-UTF8 key-value pair from crash report metadata files.

func (*CrashBlob) Descriptor deprecated 

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

Deprecated: Use CrashBlob.ProtoReflect.Descriptor instead.

func (*CrashBlob) GetBlob 

func (x *CrashBlob) GetBlob() []byte

func (*CrashBlob) GetFilename 

func (x *CrashBlob) GetFilename() string

func (*CrashBlob) GetKey 

func (x *CrashBlob) GetKey() string

func (*CrashBlob) ProtoMessage 

func (*CrashBlob) ProtoMessage()

func (*CrashBlob) ProtoReflect 

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

func (*CrashBlob) Reset 

func (x *CrashBlob) Reset()

func (*CrashBlob) String 

func (x *CrashBlob) String() string

type CrashInfo 

type CrashInfo struct {

	// Name of executable that crashed (e.g. "chrome")
	ExecName string `protobuf:"bytes,1,opt,name=exec_name,json=execName,proto3" json:"exec_name,omitempty"`
	// Product name (e.g. "Chrome_ChromeOS" or "ChromeOS")
	Prod string `protobuf:"bytes,2,opt,name=prod,proto3" json:"prod,omitempty"`
	// Product version (e.g. "12345.0.0")
	Ver string `protobuf:"bytes,3,opt,name=ver,proto3" json:"ver,omitempty"`
	// Crash signature (may not be populated for all crashes)
	Sig string `protobuf:"bytes,4,opt,name=sig,proto3" json:"sig,omitempty"`
	// The name of the integration test that was running when this crash
	// happened, if any.
	InProgressIntegrationTest string `` /* 140-byte string literal not displayed */
	// The name of the collector (e.g. chrome_collector, arc_collector)
	Collector string `protobuf:"bytes,6,opt,name=collector,proto3" json:"collector,omitempty"`
	// Additional key-value pairs of metadata (e.g. "crash_loop_mode = true").
	// These should be included in any POSTs to the crash server in a standard
	// POST form, as seen in CreateCrashFormData.
	// (despite the fact that this message is a subfield, it should be a flat
	// structure in any POSTs).
	Fields []*CrashMetadata `protobuf:"bytes,7,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

The data in this proto matches the metadata from crash-reporter's meta files. Sender::CreateCrashFormData puts this data into crash upload POST requests. (See src/platform2/crash-reporter/crash_sender_util.cc.) The names in this proto MUST match the names that crash-reporter uses so that, when crashes are uploaded to the crash server, they are interpreted as they are when crash-reporter uploads them. Similarly, when this proto is converted into a POST request to send to the crash server, the names must not be altered.

func (*CrashInfo) Descriptor deprecated 

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

Deprecated: Use CrashInfo.ProtoReflect.Descriptor instead.

func (*CrashInfo) GetCollector 

func (x *CrashInfo) GetCollector() string

func (*CrashInfo) GetExecName 

func (x *CrashInfo) GetExecName() string

func (*CrashInfo) GetFields 

func (x *CrashInfo) GetFields() []*CrashMetadata

func (*CrashInfo) GetInProgressIntegrationTest 

func (x *CrashInfo) GetInProgressIntegrationTest() string

func (*CrashInfo) GetProd 

func (x *CrashInfo) GetProd() string

func (*CrashInfo) GetSig 

func (x *CrashInfo) GetSig() string

func (*CrashInfo) GetVer 

func (x *CrashInfo) GetVer() string

func (*CrashInfo) ProtoMessage 

func (*CrashInfo) ProtoMessage()

func (*CrashInfo) ProtoReflect 

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

func (*CrashInfo) Reset 

func (x *CrashInfo) Reset()

func (*CrashInfo) String 

func (x *CrashInfo) String() string

type CrashMetadata 

type CrashMetadata struct {

	// This value is a UTF8, human-readable, description of the data.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value will be a human-readable string (e.g. "12345.0.0"), which must
	// be valid UTF-8.
	Text string `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	// contains filtered or unexported fields
}

Arbitrary text-only key-value pair corresponding to the key-value pairs in crash report metadata files.

func (*CrashMetadata) Descriptor deprecated 

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

Deprecated: Use CrashMetadata.ProtoReflect.Descriptor instead.

func (*CrashMetadata) GetKey 

func (x *CrashMetadata) GetKey() string

func (*CrashMetadata) GetText 

func (x *CrashMetadata) GetText() string

func (*CrashMetadata) ProtoMessage 

func (*CrashMetadata) ProtoMessage()

func (*CrashMetadata) ProtoReflect 

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

func (*CrashMetadata) Reset 

func (x *CrashMetadata) Reset()

func (*CrashMetadata) String 

func (x *CrashMetadata) String() string

type CreateFakeOmahaRequest 

type CreateFakeOmahaRequest struct {

	// fake_omaha is the fake omaha service to be created.
	FakeOmaha *FakeOmaha `protobuf:"bytes,1,opt,name=fake_omaha,json=fakeOmaha,proto3" json:"fake_omaha,omitempty"`
	// contains filtered or unexported fields
}
Example 
package main

import (
	"context"
	"fmt"

	rtd "go.chromium.org/chromiumos/config/go/api/test/rtd/v1"
	"go.chromium.org/chromiumos/config/go/api/test/tls"
	"google.golang.org/grpc"
)

func main() {
	var invocation rtd.Invocation

	tlsConfig := invocation.GetTestLabServicesConfig()
	dutName := invocation.GetDuts()[0].GetTlsDutName()

	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", tlsConfig.GetTlsAddress(), tlsConfig.GetTlsPort()), grpc.WithInsecure())
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	c := tls.NewCommonClient(conn)

	req := tls.CreateFakeOmahaRequest{
		FakeOmaha: &tls.FakeOmaha{
			Dut: dutName,
			TargetBuild: &tls.ChromeOsImage{
				PathOneof: &tls.ChromeOsImage_GsPathPrefix{
					GsPathPrefix: "gs://chromeos-image-archive/eve-release/R87-13457.0.0",
				},
			},
			Payloads: []*tls.FakeOmaha_Payload{
				&tls.FakeOmaha_Payload{
					Id:   "ROOTFS",
					Type: tls.FakeOmaha_Payload_FULL,
				},
			},
		},
	}

	ctx := context.Background()
	omaha, err := c.CreateFakeOmaha(ctx, &req)
	if err != nil {
		panic("RPC CreateFakeOmaha error")
	}
	defer c.DeleteFakeOmaha(ctx, &tls.DeleteFakeOmahaRequest{Name: omaha.GetName()})

	result, err := c.ExecDutCommand(ctx, &tls.ExecDutCommandRequest{
		Name:    dutName,
		Command: "update_engine_client",
		Args:    []string{"--update_url", omaha.GetOmahaUrl(), "--update"},
	})
	if err != nil {
		panic("RPC ExecDutCommand error")
	}

	// Check the return code of ExecDutCommand.
	_ = result
}

Output:

func (*CreateFakeOmahaRequest) Descriptor deprecated 

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

Deprecated: Use CreateFakeOmahaRequest.ProtoReflect.Descriptor instead.

func (*CreateFakeOmahaRequest) GetFakeOmaha 

func (x *CreateFakeOmahaRequest) GetFakeOmaha() *FakeOmaha

func (*CreateFakeOmahaRequest) ProtoMessage 

func (*CreateFakeOmahaRequest) ProtoMessage()

func (*CreateFakeOmahaRequest) ProtoReflect 

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

func (*CreateFakeOmahaRequest) Reset 

func (x *CreateFakeOmahaRequest) Reset()

func (*CreateFakeOmahaRequest) String 

func (x *CreateFakeOmahaRequest) String() string

type DeleteFakeOmahaRequest 

type DeleteFakeOmahaRequest struct {

	// The resource name of the fake Omaha service to stop.
	// Format: fakeOmahaServices/{fake-omaha-id}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteFakeOmahaRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFakeOmahaRequest.ProtoReflect.Descriptor instead.

func (*DeleteFakeOmahaRequest) GetName 

func (x *DeleteFakeOmahaRequest) GetName() string

func (*DeleteFakeOmahaRequest) ProtoMessage 

func (*DeleteFakeOmahaRequest) ProtoMessage()

func (*DeleteFakeOmahaRequest) ProtoReflect 

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

func (*DeleteFakeOmahaRequest) Reset 

func (x *DeleteFakeOmahaRequest) Reset()

func (*DeleteFakeOmahaRequest) String 

func (x *DeleteFakeOmahaRequest) String() string

type Dut 

type Dut struct {

	// name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// licenses are the licenses assigned to the DUT, e.g. Windows
	// licenses.
	Licenses []*License `protobuf:"bytes,2,rep,name=licenses,proto3" json:"licenses,omitempty"`
	// contains filtered or unexported fields
}

func (*Dut) Descriptor deprecated 

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

Deprecated: Use Dut.ProtoReflect.Descriptor instead.

func (*Dut) GetLicenses 

func (x *Dut) GetLicenses() []*License

func (*Dut) GetName 

func (x *Dut) GetName() 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 ExecDutCommandRequest 

type ExecDutCommandRequest struct {

	// name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// command is the command to run.
	// If this contains no slashes, it is resolved using PATH.
	// If this starts with /, it is used as an absolute path to the
	// program to run.
	// Otherwise, this is treated as a path relative to the working
	// directory.
	Command string `protobuf:"bytes,2,opt,name=command,proto3" json:"command,omitempty"`
	// args are the arguments to pass to the command.
	Args []string `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	// stdin is passed to the command as the program's stdin.
	// The stream does not support seeking.
	// An empty bytes is not treated specially; if the command reads
	// from stdin, it will receive zero bytes.
	Stdin []byte `protobuf:"bytes,4,opt,name=stdin,proto3" json:"stdin,omitempty"`
	// stdout indicates how to handle the command's stdout.
	Stdout Output `protobuf:"varint,5,opt,name=stdout,proto3,enum=chromiumos.config.api.test.tls.Output" json:"stdout,omitempty"`
	// stderr indicates how to handle the command's stderr.
	Stderr Output `protobuf:"varint,6,opt,name=stderr,proto3,enum=chromiumos.config.api.test.tls.Output" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}
Example 
package main

import (
	"context"

	"go.chromium.org/chromiumos/config/go/api/test/tls"
	"google.golang.org/grpc"
)

func main() {
	// The RTD will receive this in its invocation spec.
	var (
		addr    string
		dutName string
	)
	conn, err := grpc.Dial(addr)
	if err != nil {
		panic(err)
	}
	defer conn.Close()
	c := tls.NewCommonClient(conn)
	ctx := context.Background()
	req := tls.ExecDutCommandRequest{
		Name:    dutName,
		Command: "echo",
		Args:    []string{"hello world"},
	}
	stream, err := c.ExecDutCommand(ctx, &req)
	if err != nil {
		panic("RPC error")
	}
	// Handle stream in various ways.
	_ = stream
}

Output:

func (*ExecDutCommandRequest) Descriptor deprecated 

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

Deprecated: Use ExecDutCommandRequest.ProtoReflect.Descriptor instead.

func (*ExecDutCommandRequest) GetArgs 

func (x *ExecDutCommandRequest) GetArgs() []string

func (*ExecDutCommandRequest) GetCommand 

func (x *ExecDutCommandRequest) GetCommand() string

func (*ExecDutCommandRequest) GetName 

func (x *ExecDutCommandRequest) GetName() string

func (*ExecDutCommandRequest) GetStderr 

func (x *ExecDutCommandRequest) GetStderr() Output

func (*ExecDutCommandRequest) GetStdin 

func (x *ExecDutCommandRequest) GetStdin() []byte

func (*ExecDutCommandRequest) GetStdout 

func (x *ExecDutCommandRequest) GetStdout() Output

func (*ExecDutCommandRequest) ProtoMessage 

func (*ExecDutCommandRequest) ProtoMessage()

func (*ExecDutCommandRequest) ProtoReflect 

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

func (*ExecDutCommandRequest) Reset 

func (x *ExecDutCommandRequest) Reset()

func (*ExecDutCommandRequest) String 

func (x *ExecDutCommandRequest) String() string

type ExecDutCommandResponse 

type ExecDutCommandResponse struct {

	// exit_info contains exit information.
	// This is set when the command has exited or failed to start.
	// This is set on the last message in the response stream.
	ExitInfo *ExecDutCommandResponse_ExitInfo `protobuf:"bytes,1,opt,name=exit_info,json=exitInfo,proto3" json:"exit_info,omitempty"`
	// stdout contains the shell command's stdout output since the last
	// response in the stream.
	// The implementation MAY batch or delay output to later
	// responses in the stream.
	Stdout []byte `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	// stderr contains the shell command's stderr output since the last
	// response in the stream.
	// The implementation MAY batch or delay output to later
	// responses in the stream.
	Stderr []byte `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecDutCommandResponse) Descriptor deprecated 

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

Deprecated: Use ExecDutCommandResponse.ProtoReflect.Descriptor instead.

func (*ExecDutCommandResponse) GetExitInfo 

func (x *ExecDutCommandResponse) GetExitInfo() *ExecDutCommandResponse_ExitInfo

func (*ExecDutCommandResponse) GetStderr 

func (x *ExecDutCommandResponse) GetStderr() []byte

func (*ExecDutCommandResponse) GetStdout 

func (x *ExecDutCommandResponse) GetStdout() []byte

func (*ExecDutCommandResponse) ProtoMessage 

func (*ExecDutCommandResponse) ProtoMessage()

func (*ExecDutCommandResponse) ProtoReflect 

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

func (*ExecDutCommandResponse) Reset 

func (x *ExecDutCommandResponse) Reset()

func (*ExecDutCommandResponse) String 

func (x *ExecDutCommandResponse) String() string

type ExecDutCommandResponse_ExitInfo 

type ExecDutCommandResponse_ExitInfo struct {

	// status provides information about how the command process
	// terminated.
	//
	// If the command failed to start, status is set to an arbitrary
	// non-zero value.
	//
	// If signaled is set, status is set to the signal that caused
	// the command to terminate.
	//
	// Otherwise, status is set to the exit status of the process.
	// Exit statuses outside of 0 to 255 inclusive are not supported;
	// they will be mapped to an arbitrary non-zero value.
	//
	// status is zero if and only if the process was successfully
	// started and exited with a zero status.
	Status int32 `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// signaled indicates whether the command exited due to a signal.
	// If set, status contains the signal.
	Signaled bool `protobuf:"varint,2,opt,name=signaled,proto3" json:"signaled,omitempty"`
	// started indicates whether the command was started.
	Started bool `protobuf:"varint,3,opt,name=started,proto3" json:"started,omitempty"`
	// error_message provides a human readable explanation for some errors.
	// This MUST NOT be inspected by programs.
	ErrorMessage string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecDutCommandResponse_ExitInfo) Descriptor deprecated 

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

Deprecated: Use ExecDutCommandResponse_ExitInfo.ProtoReflect.Descriptor instead.

func (*ExecDutCommandResponse_ExitInfo) GetErrorMessage 

func (x *ExecDutCommandResponse_ExitInfo) GetErrorMessage() string

func (*ExecDutCommandResponse_ExitInfo) GetSignaled 

func (x *ExecDutCommandResponse_ExitInfo) GetSignaled() bool

func (*ExecDutCommandResponse_ExitInfo) GetStarted 

func (x *ExecDutCommandResponse_ExitInfo) GetStarted() bool

func (*ExecDutCommandResponse_ExitInfo) GetStatus 

func (x *ExecDutCommandResponse_ExitInfo) GetStatus() int32

func (*ExecDutCommandResponse_ExitInfo) ProtoMessage 

func (*ExecDutCommandResponse_ExitInfo) ProtoMessage()

func (*ExecDutCommandResponse_ExitInfo) ProtoReflect 

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

func (*ExecDutCommandResponse_ExitInfo) Reset 

func (x *ExecDutCommandResponse_ExitInfo) Reset()

func (*ExecDutCommandResponse_ExitInfo) String 

func (x *ExecDutCommandResponse_ExitInfo) String() string

type ExposePortToDutRequest 

type ExposePortToDutRequest struct {

	// dut_name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	// (-- aip.dev/not-precedent: This preceded the AIP standards.
	//     Ordinarily, this field should be either `name` or `dut`,
	//     depending on whether this is a method on Dut resources. --)
	DutName string `protobuf:"bytes,1,opt,name=dut_name,json=dutName,proto3" json:"dut_name,omitempty"`
	// local_port is the port of a service running inside the RTD container to
	// expose. It MUST be in the range of [1, 65535] as defined in RFC 1700
	// (http://https://tools.ietf.org/html/rfc1700).
	// A client MAY bind to the special port number "0" from inside an RTD to get
	// an OS assigned free port number without race condition. Then the client
	// MUST get the real port number assigned and pass it to "local_port" here.
	LocalPort int32 `protobuf:"varint,2,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
	// require_remote_proxy indicates if the implementation SHOULD use a DUT
	// reachable server as a proxy and return the address and port of the proxy
	// server.
	// If require_remote_proxy is set, the exposed port SHOULD persist across DUT
	// reboots.
	// If require_remote_proxy is set but an implementation cannot provide a
	// remote proxy, the implementation SHOULD return FAILED_PRECONDITION.
	// If require_remote_proxy is not set, the implementation MAY expose a port
	// that cannot persist across DUT reboots.
	// If require_remote_proxy is not set, the implementation MAY use 'localhost'
	// as the exposed address.
	RequireRemoteProxy bool `protobuf:"varint,3,opt,name=require_remote_proxy,json=requireRemoteProxy,proto3" json:"require_remote_proxy,omitempty"`
	// contains filtered or unexported fields
}
Example 
package main

import (
	"context"
	"fmt"
	"net"
	"net/http"

	rtd "go.chromium.org/chromiumos/config/go/api/test/rtd/v1"
	"go.chromium.org/chromiumos/config/go/api/test/tls"
	"google.golang.org/grpc"
)

func main() {
	var invocation rtd.Invocation

	tlsConfig := invocation.GetTestLabServicesConfig()
	dutName := invocation.GetDuts()[0].GetTlsDutName()

	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", tlsConfig.GetTlwAddress(), tlsConfig.GetTlwPort()))
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	c := tls.NewWiringClient(conn)
	ctx := context.Background()

	// Start a service inside RTD to bind to a local port.
	s := http.Server{}
	http.HandleFunc("/foo", func(w http.ResponseWriter, _ *http.Request) {
		fmt.Fprint(w, "Hello world!\n")
	})
	// Use port "0" to request OS to assign an unused port number.
	ln, _ := net.Listen("tcp", ":0")
	go func() {
		s.Serve(ln)
	}()
	defer s.Shutdown(context.Background())

	req := tls.ExposePortToDutRequest{
		DutName:   dutName,
		LocalPort: int32(ln.Addr().(*net.TCPAddr).Port),
	}
	resp, err := c.ExposePortToDut(ctx, &req)
	if err != nil {
		panic("RPC error")
	}

	// Handle the response in various ways. For example:
	// Run a client command to access the service started.
	// Trivial example, see ExecDutCommandRequest for a possible implementation.
	runCommandOnDut := func(args []string) {}
	runCommandOnDut([]string{"curl", fmt.Sprintf("%s:%d/foo", resp.ExposedAddress, resp.ExposedPort)})
}

Output:

func (*ExposePortToDutRequest) Descriptor deprecated 

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

Deprecated: Use ExposePortToDutRequest.ProtoReflect.Descriptor instead.

func (*ExposePortToDutRequest) GetDutName 

func (x *ExposePortToDutRequest) GetDutName() string

func (*ExposePortToDutRequest) GetLocalPort 

func (x *ExposePortToDutRequest) GetLocalPort() int32

func (*ExposePortToDutRequest) GetRequireRemoteProxy 

func (x *ExposePortToDutRequest) GetRequireRemoteProxy() bool

func (*ExposePortToDutRequest) ProtoMessage 

func (*ExposePortToDutRequest) ProtoMessage()

func (*ExposePortToDutRequest) ProtoReflect 

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

func (*ExposePortToDutRequest) Reset 

func (x *ExposePortToDutRequest) Reset()

func (*ExposePortToDutRequest) String 

func (x *ExposePortToDutRequest) String() string

type ExposePortToDutResponse 

type ExposePortToDutResponse struct {

	// exposed_address is the address reachable by the requesting DUT.
	// TLEs SHOULD return an IPv4 or IPv6 address to avoid name resolution
	// issues.
	// IPv4 addresses MUST be in standard dotted decimal notation.
	// IPv6 addresses MUST be formatted according to RFC4291, Section 2.2. The
	// mixed IPv4 and IPv6 form MUST NOT be used.
	// If TLEs return a hostname, they SHOULD ensure that the hostname can be
	// resolved by the DUT via standard name resolution facilities.
	ExposedAddress string `protobuf:"bytes,1,opt,name=exposed_address,json=exposedAddress,proto3" json:"exposed_address,omitempty"`
	// exposed_port is the port on the exposed_address which is reachable from
	// the DUT.
	ExposedPort int32 `protobuf:"varint,2,opt,name=exposed_port,json=exposedPort,proto3" json:"exposed_port,omitempty"`
	// contains filtered or unexported fields
}

func (*ExposePortToDutResponse) Descriptor deprecated 

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

Deprecated: Use ExposePortToDutResponse.ProtoReflect.Descriptor instead.

func (*ExposePortToDutResponse) GetExposedAddress 

func (x *ExposePortToDutResponse) GetExposedAddress() string

func (*ExposePortToDutResponse) GetExposedPort 

func (x *ExposePortToDutResponse) GetExposedPort() int32

func (*ExposePortToDutResponse) ProtoMessage 

func (*ExposePortToDutResponse) ProtoMessage()

func (*ExposePortToDutResponse) ProtoReflect 

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

func (*ExposePortToDutResponse) Reset 

func (x *ExposePortToDutResponse) Reset()

func (*ExposePortToDutResponse) String 

func (x *ExposePortToDutResponse) String() string

type FakeOmaha 

type FakeOmaha struct {

	// name is the resource name of the fake Omaha service.
	// Format: fakeOmaha/{fake-omaha-id}
	// The implementation MUST set it after creating the fake Omaha service.
	// Clients SHOULD NOT set it.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// dut is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Dut string `protobuf:"bytes,2,opt,name=dut,proto3" json:"dut,omitempty"`
	// target_build is the ChromeOS build that the fake Omaha service will serve
	// payloads for.
	TargetBuild *ChromeOsImage `protobuf:"bytes,3,opt,name=target_build,json=targetBuild,proto3" json:"target_build,omitempty"`
	// payloads is the payloads can be served by the fake Omaha service.
	Payloads []*FakeOmaha_Payload `protobuf:"bytes,4,rep,name=payloads,proto3" json:"payloads,omitempty"`
	// exposed_via_proxy indicates that the fake Omaha service is exposed to a
	// DUT via a proxy server, instead of exposing to the DUT directly. So the
	// service exposing won't be impacted by rebooting the DUT, disconnecting the
	// DUT network, etc.
	ExposedViaProxy bool `protobuf:"varint,5,opt,name=exposed_via_proxy,json=exposedViaProxy,proto3" json:"exposed_via_proxy,omitempty"`
	// critical_update instructs the fake Omaha created that the update is
	// critical if set.
	CriticalUpdate bool `protobuf:"varint,6,opt,name=critical_update,json=criticalUpdate,proto3" json:"critical_update,omitempty"`
	// return_noupdate_starting indicates from which update check to start returning noupdate.
	// It MUST be 0 or greater.
	// When set to 0 (the default value), disables returning noupdate.
	// If set to positive N, returns noupdate for the Nth check and for every
	// check thereafter.
	// For example, if set to 1, returns noupdate starting from the first check,
	// i.e., always returns noupdate.
	ReturnNoupdateStarting int32 `` /* 130-byte string literal not displayed */
	// omaha_url is the current fake Omaha service URL which is reachable from
	// the specified DUT.
	// The URL can be used as input of the update engine client of the DUT.
	// The implementation MUST set it after creating the fake Omaha service.
	// Clients SHOULD NOT set it.
	OmahaUrl string `protobuf:"bytes,8,opt,name=omaha_url,json=omahaUrl,proto3" json:"omaha_url,omitempty"`
	// contains filtered or unexported fields
}

func (*FakeOmaha) Descriptor deprecated 

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

Deprecated: Use FakeOmaha.ProtoReflect.Descriptor instead.

func (*FakeOmaha) GetCriticalUpdate 

func (x *FakeOmaha) GetCriticalUpdate() bool

func (*FakeOmaha) GetDut 

func (x *FakeOmaha) GetDut() string

func (*FakeOmaha) GetExposedViaProxy 

func (x *FakeOmaha) GetExposedViaProxy() bool

func (*FakeOmaha) GetName 

func (x *FakeOmaha) GetName() string

func (*FakeOmaha) GetOmahaUrl 

func (x *FakeOmaha) GetOmahaUrl() string

func (*FakeOmaha) GetPayloads 

func (x *FakeOmaha) GetPayloads() []*FakeOmaha_Payload

func (*FakeOmaha) GetReturnNoupdateStarting 

func (x *FakeOmaha) GetReturnNoupdateStarting() int32

func (*FakeOmaha) GetTargetBuild 

func (x *FakeOmaha) GetTargetBuild() *ChromeOsImage

func (*FakeOmaha) ProtoMessage 

func (*FakeOmaha) ProtoMessage()

func (*FakeOmaha) ProtoReflect 

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

func (*FakeOmaha) Reset 

func (x *FakeOmaha) Reset()

func (*FakeOmaha) String 

func (x *FakeOmaha) String() string

type FakeOmaha_Payload 

type FakeOmaha_Payload struct {

	// id is the id of the payload. It MAY be "ROOTFS" or a DLC id, etc.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// type is the payload type, e.g. TYPE_FULL or TYPE_DELTA.
	Type FakeOmaha_Payload_Type `protobuf:"varint,2,opt,name=type,proto3,enum=chromiumos.config.api.test.tls.FakeOmaha_Payload_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*FakeOmaha_Payload) Descriptor deprecated 

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

Deprecated: Use FakeOmaha_Payload.ProtoReflect.Descriptor instead.

func (*FakeOmaha_Payload) GetId 

func (x *FakeOmaha_Payload) GetId() string

func (*FakeOmaha_Payload) GetType 

func (x *FakeOmaha_Payload) GetType() FakeOmaha_Payload_Type

func (*FakeOmaha_Payload) ProtoMessage 

func (*FakeOmaha_Payload) ProtoMessage()

func (*FakeOmaha_Payload) ProtoReflect 

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

func (*FakeOmaha_Payload) Reset 

func (x *FakeOmaha_Payload) Reset()

func (*FakeOmaha_Payload) String 

func (x *FakeOmaha_Payload) String() string

type FakeOmaha_Payload_Type 

type FakeOmaha_Payload_Type int32
const (
	FakeOmaha_Payload_TYPE_UNSPECIFIED FakeOmaha_Payload_Type = 0
	FakeOmaha_Payload_FULL             FakeOmaha_Payload_Type = 1
	FakeOmaha_Payload_DELTA            FakeOmaha_Payload_Type = 2
)

func (FakeOmaha_Payload_Type) Descriptor 

func (FakeOmaha_Payload_Type) Descriptor() protoreflect.EnumDescriptor

func (FakeOmaha_Payload_Type) Enum 

func (x FakeOmaha_Payload_Type) Enum() *FakeOmaha_Payload_Type

func (FakeOmaha_Payload_Type) EnumDescriptor deprecated 

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

Deprecated: Use FakeOmaha_Payload_Type.Descriptor instead.

func (FakeOmaha_Payload_Type) Number 

func (x FakeOmaha_Payload_Type) Number() protoreflect.EnumNumber

func (FakeOmaha_Payload_Type) String 

func (x FakeOmaha_Payload_Type) String() string

func (FakeOmaha_Payload_Type) Type 

func (FakeOmaha_Payload_Type) Type() protoreflect.EnumType

type FetchCrashesRequest 

type FetchCrashesRequest struct {

	// dut is the resource name for the DUT from which to fetch crashes.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Dut string `protobuf:"bytes,1,opt,name=dut,proto3" json:"dut,omitempty"`
	// If true, fetch the core file.
	// For uploads to the crash server, that should generally be false.
	// If the crash file is likely to be used for manual debugging (e.g. on
	// a manually-invoked test suite run), this might be true.
	// Coredumps can be extremely large (even gigabytes), so if resource usage
	// is a concern, this should probably be false.
	FetchCore bool `protobuf:"varint,2,opt,name=fetch_core,json=fetchCore,proto3" json:"fetch_core,omitempty"`
	// contains filtered or unexported fields
}
Example 
package main

import (
	"context"
	"fmt"
	"io"

	rtd "go.chromium.org/chromiumos/config/go/api/test/rtd/v1"
	"go.chromium.org/chromiumos/config/go/api/test/tls"
	"google.golang.org/grpc"
)

func main() {
	var invocation rtd.Invocation

	tlsConfig := invocation.GetTestLabServicesConfig()
	dutName := invocation.GetDuts()[0].GetTlsDutName()

	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", tlsConfig.GetTlwAddress(), tlsConfig.GetTlwPort()), grpc.WithInsecure())
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	c := tls.NewCommonClient(conn)

	req := tls.FetchCrashesRequest{
		Dut:       dutName,
		FetchCore: true,
	}

	ctx := context.Background()
	stream, err := c.FetchCrashes(ctx, &req)
	if err != nil {
		panic(err)
	}

	crashes := make(map[int64]*tls.CrashInfo)
	cores := make(map[int64][]byte)
	blobs := make(map[int64]map[string][]byte)

readStream:
	for {
		resp, err := stream.Recv()
		if err != nil {
			if err == io.EOF {
				break readStream
			}
			panic(fmt.Sprintf("RPC error: %v", err))
		}

		id := resp.CrashId
		switch x := resp.Data.(type) {
		case *tls.FetchCrashesResponse_Crash:
			crashes[id] = x.Crash
			// Start on next crash -- assume we get CrashInfo before
			// any blobs.
			blobs[id] = make(map[string][]byte)
		case *tls.FetchCrashesResponse_Blob:
			b := x.Blob
			blobs[id][b.Key] = append(blobs[id][b.Key], b.Blob...)
		case *tls.FetchCrashesResponse_Core:
			cores[id] = append(cores[id], x.Core...)
		default:
			panic(fmt.Sprintf("invalid type %T", x))
		}
	}
}

Output:

func (*FetchCrashesRequest) Descriptor deprecated 

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

Deprecated: Use FetchCrashesRequest.ProtoReflect.Descriptor instead.

func (*FetchCrashesRequest) GetDut 

func (x *FetchCrashesRequest) GetDut() string

func (*FetchCrashesRequest) GetFetchCore 

func (x *FetchCrashesRequest) GetFetchCore() bool

func (*FetchCrashesRequest) ProtoMessage 

func (*FetchCrashesRequest) ProtoMessage()

func (*FetchCrashesRequest) ProtoReflect 

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

func (*FetchCrashesRequest) Reset 

func (x *FetchCrashesRequest) Reset()

func (*FetchCrashesRequest) String 

func (x *FetchCrashesRequest) String() string

type FetchCrashesResponse 

type FetchCrashesResponse struct {

	// Crash id. unique only within responses to a single FetchCrashes request.
	// Used to assemble multiple streamed |FetchCrashesResponse| protos into a
	// single crash report.
	CrashId int64 `protobuf:"varint,1,opt,name=crash_id,json=crashId,proto3" json:"crash_id,omitempty"`
	// Types that are assignable to Data:
	//	*FetchCrashesResponse_Crash
	//	*FetchCrashesResponse_Blob
	//	*FetchCrashesResponse_Core
	Data isFetchCrashesResponse_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

When this response is streamed, the first proto with a given crash ID will always contain the CrashInfo. Files and core dumps (if present) may be streamed. If they are, subsequent protos with the same crash ID will follow, each containing a chunk of file/coredump. To reassemble these, concatenate the bytes received from each subsequent proto with a matching crash_id (concatenate blobs that have matching crash_ids and keys). Additional crashes may be reported in the same stream with a new crash ID.

func (*FetchCrashesResponse) Descriptor deprecated 

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

Deprecated: Use FetchCrashesResponse.ProtoReflect.Descriptor instead.

func (*FetchCrashesResponse) GetBlob 

func (x *FetchCrashesResponse) GetBlob() *CrashBlob

func (*FetchCrashesResponse) GetCore 

func (x *FetchCrashesResponse) GetCore() []byte

func (*FetchCrashesResponse) GetCrash 

func (x *FetchCrashesResponse) GetCrash() *CrashInfo

func (*FetchCrashesResponse) GetCrashId 

func (x *FetchCrashesResponse) GetCrashId() int64

func (*FetchCrashesResponse) GetData 

func (m *FetchCrashesResponse) GetData() isFetchCrashesResponse_Data

func (*FetchCrashesResponse) ProtoMessage 

func (*FetchCrashesResponse) ProtoMessage()

func (*FetchCrashesResponse) ProtoReflect 

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

func (*FetchCrashesResponse) Reset 

func (x *FetchCrashesResponse) Reset()

func (*FetchCrashesResponse) String 

func (x *FetchCrashesResponse) String() string

type FetchCrashesResponse_Blob 

type FetchCrashesResponse_Blob struct {
	// Misc file (e.g. minidump, large binary log, etc)
	Blob *CrashBlob `protobuf:"bytes,3,opt,name=blob,proto3,oneof"`
}

type FetchCrashesResponse_Core 

type FetchCrashesResponse_Core struct {
	// Coredump. Present iff fetch_core was true in FetchCrashesRequest and
	// the crash has a coredump. (kernel warnings, for example, do not have
	// one).
	Core []byte `protobuf:"bytes,4,opt,name=core,proto3,oneof"`
}

type FetchCrashesResponse_Crash 

type FetchCrashesResponse_Crash struct {
	// Full details of crash report.
	Crash *CrashInfo `protobuf:"bytes,2,opt,name=crash,proto3,oneof"`
}

type GetDutRequest 

type GetDutRequest struct {

	// name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDutRequest) Descriptor deprecated 

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

Deprecated: Use GetDutRequest.ProtoReflect.Descriptor instead.

func (*GetDutRequest) GetName 

func (x *GetDutRequest) GetName() string

func (*GetDutRequest) ProtoMessage 

func (*GetDutRequest) ProtoMessage()

func (*GetDutRequest) ProtoReflect 

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

func (*GetDutRequest) Reset 

func (x *GetDutRequest) Reset()

func (*GetDutRequest) String 

func (x *GetDutRequest) String() string

type License 

type License struct {

	// name is the resource name for the license.
	// This is used for tracking licenses.
	// Clients MUST NOT use the name to identify the type of license,
	// even if the implementation names the resources after the license
	// type.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// type is the type of the license.
	Type License_Type `protobuf:"varint,2,opt,name=type,proto3,enum=chromiumos.config.api.test.tls.License_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*License) Descriptor deprecated 

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

Deprecated: Use License.ProtoReflect.Descriptor instead.

func (*License) GetName 

func (x *License) GetName() string

func (*License) GetType 

func (x *License) GetType() License_Type

func (*License) ProtoMessage 

func (*License) ProtoMessage()

func (*License) ProtoReflect 

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

func (*License) Reset 

func (x *License) Reset()

func (*License) String 

func (x *License) String() string

type License_Type 

type License_Type int32
const (
	License_TYPE_UNSPECIFIED License_Type = 0
	// Microsoft Windows 10 Professional Desktop Operating System.
	// Contact the Chrome OS Parallels team for license specifics.
	License_WINDOWS_10_PRO License_Type = 1
	// Microsoft Office Standard.
	// Contact the Chrome OS Parallels team for version and license specifics.
	License_MS_OFFICE_STANDARD License_Type = 2
)

func (License_Type) Descriptor 

func (License_Type) Descriptor() protoreflect.EnumDescriptor

func (License_Type) Enum 

func (x License_Type) Enum() *License_Type

func (License_Type) EnumDescriptor deprecated 

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

Deprecated: Use License_Type.Descriptor instead.

func (License_Type) Number 

func (x License_Type) Number() protoreflect.EnumNumber

func (License_Type) String 

func (x License_Type) String() string

func (License_Type) Type 

func (License_Type) Type() protoreflect.EnumType

type OpenDutPortRequest 

type OpenDutPortRequest struct {

	// name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// port is the port to open on the DUT.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenDutPortRequest) Descriptor deprecated 

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

Deprecated: Use OpenDutPortRequest.ProtoReflect.Descriptor instead.

func (*OpenDutPortRequest) GetName 

func (x *OpenDutPortRequest) GetName() string

func (*OpenDutPortRequest) GetPort 

func (x *OpenDutPortRequest) GetPort() int32

func (*OpenDutPortRequest) ProtoMessage 

func (*OpenDutPortRequest) ProtoMessage()

func (*OpenDutPortRequest) ProtoReflect 

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

func (*OpenDutPortRequest) Reset 

func (x *OpenDutPortRequest) Reset()

func (*OpenDutPortRequest) String 

func (x *OpenDutPortRequest) String() string

type OpenDutPortResponse 

type OpenDutPortResponse struct {

	// address for which a port is forwarded to the DUT.
	// TLEs SHOULD return an IPv4 or IPv6 address to avoid name
	// resolution issues.
	// IPv4 addresses MUST be in standard dotted decimal notation.
	// IPv6 addresses MUST be formatted according to RFC4291, Section
	// 2.2.  The mixed IPv4 and IPv6 form MUST NOT be used.
	// If TLEs return a hostname, they SHOULD ensure that the hostname
	// can be resolved by the RTD via standard name resolution
	// facilities.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// port on the address which is forwarded to the DUT.
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenDutPortResponse) Descriptor deprecated 

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

Deprecated: Use OpenDutPortResponse.ProtoReflect.Descriptor instead.

func (*OpenDutPortResponse) GetAddress 

func (x *OpenDutPortResponse) GetAddress() string

func (*OpenDutPortResponse) GetPort 

func (x *OpenDutPortResponse) GetPort() int32

func (*OpenDutPortResponse) ProtoMessage 

func (*OpenDutPortResponse) ProtoMessage()

func (*OpenDutPortResponse) ProtoReflect 

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

func (*OpenDutPortResponse) Reset 

func (x *OpenDutPortResponse) Reset()

func (*OpenDutPortResponse) String 

func (x *OpenDutPortResponse) String() string

type Output 

type Output int32

Output enumeration for ExecDutCommandRequest. 

const (
	// OUTPUT_PIPE means to collect output and return it.
	Output_OUTPUT_PIPE Output = 0
	// OUTPUT_STDOUT is a special value for stderr which means to merge stderr
	// into stdout.
	Output_OUTPUT_STDOUT Output = 1
)

func (Output) Descriptor 

func (Output) Descriptor() protoreflect.EnumDescriptor

func (Output) Enum 

func (x Output) Enum() *Output

func (Output) EnumDescriptor deprecated 

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

Deprecated: Use Output.Descriptor instead.

func (Output) Number 

func (x Output) Number() protoreflect.EnumNumber

func (Output) String 

func (x Output) String() string

func (Output) Type 

func (Output) Type() protoreflect.EnumType

type ProvisionAshMetadata 

type ProvisionAshMetadata struct {
	// contains filtered or unexported fields
}

func (*ProvisionAshMetadata) Descriptor deprecated 

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

Deprecated: Use ProvisionAshMetadata.ProtoReflect.Descriptor instead.

func (*ProvisionAshMetadata) ProtoMessage 

func (*ProvisionAshMetadata) ProtoMessage()

func (*ProvisionAshMetadata) ProtoReflect 

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

func (*ProvisionAshMetadata) Reset 

func (x *ProvisionAshMetadata) Reset()

func (*ProvisionAshMetadata) String 

func (x *ProvisionAshMetadata) String() string

type ProvisionAshRequest 

type ProvisionAshRequest struct {

	// name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// image specifies the Lacros image with which to provision the DUT.
	Bundle *ProvisionAshRequest_AshBundle `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	// contains filtered or unexported fields
}

func (*ProvisionAshRequest) Descriptor deprecated 

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

Deprecated: Use ProvisionAshRequest.ProtoReflect.Descriptor instead.

func (*ProvisionAshRequest) GetBundle 

func (x *ProvisionAshRequest) GetBundle() *ProvisionAshRequest_AshBundle

func (*ProvisionAshRequest) GetName 

func (x *ProvisionAshRequest) GetName() string

func (*ProvisionAshRequest) ProtoMessage 

func (*ProvisionAshRequest) ProtoMessage()

func (*ProvisionAshRequest) ProtoReflect 

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

func (*ProvisionAshRequest) Reset 

func (x *ProvisionAshRequest) Reset()

func (*ProvisionAshRequest) String 

func (x *ProvisionAshRequest) String() string

type ProvisionAshRequest_AshBundle 

type ProvisionAshRequest_AshBundle struct {

	// Types that are assignable to PathOneof:
	//	*ProvisionAshRequest_AshBundle_GsBundlePath
	PathOneof isProvisionAshRequest_AshBundle_PathOneof `protobuf_oneof:"path_oneof"`
	// contains filtered or unexported fields
}

func (*ProvisionAshRequest_AshBundle) Descriptor deprecated 

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

Deprecated: Use ProvisionAshRequest_AshBundle.ProtoReflect.Descriptor instead.

func (*ProvisionAshRequest_AshBundle) GetGsBundlePath 

func (x *ProvisionAshRequest_AshBundle) GetGsBundlePath() string

func (*ProvisionAshRequest_AshBundle) GetPathOneof 

func (m *ProvisionAshRequest_AshBundle) GetPathOneof() isProvisionAshRequest_AshBundle_PathOneof

func (*ProvisionAshRequest_AshBundle) ProtoMessage 

func (*ProvisionAshRequest_AshBundle) ProtoMessage()

func (*ProvisionAshRequest_AshBundle) ProtoReflect 

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

func (*ProvisionAshRequest_AshBundle) Reset 

func (x *ProvisionAshRequest_AshBundle) Reset()

func (*ProvisionAshRequest_AshBundle) String 

func (x *ProvisionAshRequest_AshBundle) String() string

type ProvisionAshRequest_AshBundle_GsBundlePath 

type ProvisionAshRequest_AshBundle_GsBundlePath struct {
	// gs_bundle_path is the GS path to where AshChrome bundle is located.
	GsBundlePath string `protobuf:"bytes,1,opt,name=gs_bundle_path,json=gsBundlePath,proto3,oneof"`
}

type ProvisionAshResponse 

type ProvisionAshResponse struct {
	// contains filtered or unexported fields
}

func (*ProvisionAshResponse) Descriptor deprecated 

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

Deprecated: Use ProvisionAshResponse.ProtoReflect.Descriptor instead.

func (*ProvisionAshResponse) ProtoMessage 

func (*ProvisionAshResponse) ProtoMessage()

func (*ProvisionAshResponse) ProtoReflect 

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

func (*ProvisionAshResponse) Reset 

func (x *ProvisionAshResponse) Reset()

func (*ProvisionAshResponse) String 

func (x *ProvisionAshResponse) String() string

type ProvisionAshResponse_Reason 

type ProvisionAshResponse_Reason int32

When the status code is other than OK, details in Status message should be parsed for ErrorInfo message with the following Reasons as the reason. 

const (
	// Failed as the ProvisionAsh request is invalid.
	ProvisionAshResponse_REASON_INVALID_REQUEST ProvisionAshResponse_Reason = 0
	// Failed to connect to the DUT prior to provisioning Ash.
	ProvisionAshResponse_REASON_DUT_UNREACHABLE_PRE_PROVISION ProvisionAshResponse_Reason = 1
	// Failed to download the Ash bundle or a timeout during download.
	ProvisionAshResponse_REASON_DOWNLOADING_BUNDLE_FAILED ProvisionAshResponse_Reason = 2
	// Failed due to a timeout during the main Ash provisioning.
	// Excludes timeout during other steps.
	ProvisionAshResponse_REASON_PROVISIONING_TIMEDOUT ProvisionAshResponse_Reason = 3
	// General failure in Ash provisioning.
	ProvisionAshResponse_REASON_PROVISIONING_FAILED ProvisionAshResponse_Reason = 4
)

func (ProvisionAshResponse_Reason) Descriptor 

func (ProvisionAshResponse_Reason) Descriptor() protoreflect.EnumDescriptor

func (ProvisionAshResponse_Reason) Enum 

func (x ProvisionAshResponse_Reason) Enum() *ProvisionAshResponse_Reason

func (ProvisionAshResponse_Reason) EnumDescriptor deprecated 

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

Deprecated: Use ProvisionAshResponse_Reason.Descriptor instead.

func (ProvisionAshResponse_Reason) Number 

func (x ProvisionAshResponse_Reason) Number() protoreflect.EnumNumber

func (ProvisionAshResponse_Reason) String 

func (x ProvisionAshResponse_Reason) String() string

func (ProvisionAshResponse_Reason) Type 

func (ProvisionAshResponse_Reason) Type() protoreflect.EnumType

type ProvisionDutMetadata 

type ProvisionDutMetadata struct {
	// contains filtered or unexported fields
}

func (*ProvisionDutMetadata) Descriptor deprecated 

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

Deprecated: Use ProvisionDutMetadata.ProtoReflect.Descriptor instead.

func (*ProvisionDutMetadata) ProtoMessage 

func (*ProvisionDutMetadata) ProtoMessage()

func (*ProvisionDutMetadata) ProtoReflect 

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

func (*ProvisionDutMetadata) Reset 

func (x *ProvisionDutMetadata) Reset()

func (*ProvisionDutMetadata) String 

func (x *ProvisionDutMetadata) String() string

type ProvisionDutRequest 

type ProvisionDutRequest struct {

	// name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// image specifies the Chrome OS image with which to provision the DUT.
	//
	// Deprecated: Do not use.
	Image *ProvisionDutRequest_ChromeOSImage `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// dlc_specs specifies which DLCs to install on the DUT after provisioning.
	DlcSpecs []*ProvisionDutRequest_DLCSpec `protobuf:"bytes,3,rep,name=dlc_specs,json=dlcSpecs,proto3" json:"dlc_specs,omitempty"`
	// preserve_stateful specifies whether the stateful partition should be preserved during
	// provisioning. If preserve_stateful is not set to true, the stateful partition is
	// block-level wiped and reset during provisioning.
	PreserveStateful bool `protobuf:"varint,4,opt,name=preserve_stateful,json=preserveStateful,proto3" json:"preserve_stateful,omitempty"`
	// target_build is the ChromeOS build to provision to.
	TargetBuild *ChromeOsImage `protobuf:"bytes,5,opt,name=target_build,json=targetBuild,proto3" json:"target_build,omitempty"`
	// force_provision_os will always provision the OS.
	ForceProvisionOs bool `protobuf:"varint,6,opt,name=force_provision_os,json=forceProvisionOs,proto3" json:"force_provision_os,omitempty"`
	// prevent_reboot will skip all attempts to reboot during provision the OS.
	PreventReboot bool `protobuf:"varint,7,opt,name=prevent_reboot,json=preventReboot,proto3" json:"prevent_reboot,omitempty"`
	// update_firmware will update OS bundled firmware during the provision.
	// Please note this firmware update only update firmware that built in
	// the target_build OS image and it is different from firmware provision
	// which download and update a separate firmware image based on request.
	UpdateFirmware bool `protobuf:"varint,8,opt,name=update_firmware,json=updateFirmware,proto3" json:"update_firmware,omitempty"`
	// only_googler_ssh_keys controls if we provision googler ssh key only.
	// If true, provision will only enable googler ssh key on the DUT.
	// If false, provision will enable external & googler ssh key on the DUT.
	OnlyGooglerSshKeys bool `protobuf:"varint,9,opt,name=only_googler_ssh_keys,json=onlyGooglerSshKeys,proto3" json:"only_googler_ssh_keys,omitempty"`
	// contains filtered or unexported fields
}
Example 
package main

import (
	"context"
	"fmt"

	"github.com/golang/protobuf/ptypes/duration"
	rtd "go.chromium.org/chromiumos/config/go/api/test/rtd/v1"
	"go.chromium.org/chromiumos/config/go/api/test/tls"
	"go.chromium.org/chromiumos/config/go/api/test/tls/dependencies/longrunning"
	"google.golang.org/grpc"
)

func main() {
	var invocation rtd.Invocation

	tlsConfig := invocation.GetTestLabServicesConfig()
	dutName := invocation.GetDuts()[0].GetTlsDutName()

	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", tlsConfig.GetTlwAddress(), tlsConfig.GetTlwPort()), grpc.WithInsecure())
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	c := tls.NewCommonClient(conn)

	req := tls.ProvisionDutRequest{
		Name: dutName,
		TargetBuild: &tls.ChromeOsImage{
			PathOneof: &tls.ChromeOsImage_GsPathPrefix{
				GsPathPrefix: "gs://chromeos-image-archive/eve-release/R87-13457.0.0",
			},
		},
		DlcSpecs: []*tls.ProvisionDutRequest_DLCSpec{
			&tls.ProvisionDutRequest_DLCSpec{
				Id: "sample-dlc",
			},
		},
	}

	ctx := context.Background()
	op, err := c.ProvisionDut(ctx, &req)
	if err != nil {
		panic(err)
	}

	opcli := longrunning.NewOperationsClient(conn)
	op, err = opcli.WaitOperation(ctx, &longrunning.WaitOperationRequest{
		Name: op.GetName(),
		Timeout: &duration.Duration{
			Seconds: 3600,
		},
	})
	if err != nil {
		panic("RPC error")
	}

	if errStatus := op.GetError(); errStatus != nil {
		panic(fmt.Sprintf("Operation error details: %v", errStatus.GetDetails()))
	}

	// Provisioned OS + DLC.
}

Output:

func (*ProvisionDutRequest) Descriptor deprecated 

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

Deprecated: Use ProvisionDutRequest.ProtoReflect.Descriptor instead.

func (*ProvisionDutRequest) GetDlcSpecs 

func (x *ProvisionDutRequest) GetDlcSpecs() []*ProvisionDutRequest_DLCSpec

func (*ProvisionDutRequest) GetForceProvisionOs 

func (x *ProvisionDutRequest) GetForceProvisionOs() bool

func (*ProvisionDutRequest) GetImage deprecated 

func (x *ProvisionDutRequest) GetImage() *ProvisionDutRequest_ChromeOSImage

Deprecated: Do not use.

func (*ProvisionDutRequest) GetName 

func (x *ProvisionDutRequest) GetName() string

func (*ProvisionDutRequest) GetOnlyGooglerSshKeys 

func (x *ProvisionDutRequest) GetOnlyGooglerSshKeys() bool

func (*ProvisionDutRequest) GetPreserveStateful 

func (x *ProvisionDutRequest) GetPreserveStateful() bool

func (*ProvisionDutRequest) GetPreventReboot 

func (x *ProvisionDutRequest) GetPreventReboot() bool

func (*ProvisionDutRequest) GetTargetBuild 

func (x *ProvisionDutRequest) GetTargetBuild() *ChromeOsImage

func (*ProvisionDutRequest) GetUpdateFirmware 

func (x *ProvisionDutRequest) GetUpdateFirmware() bool

func (*ProvisionDutRequest) ProtoMessage 

func (*ProvisionDutRequest) ProtoMessage()

func (*ProvisionDutRequest) ProtoReflect 

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

func (*ProvisionDutRequest) Reset 

func (x *ProvisionDutRequest) Reset()

func (*ProvisionDutRequest) String 

func (x *ProvisionDutRequest) String() string

type ProvisionDutRequest_ChromeOSImage deprecated 

type ProvisionDutRequest_ChromeOSImage struct {

	// Types that are assignable to PathOneof:
	//	*ProvisionDutRequest_ChromeOSImage_GsPathPrefix
	PathOneof isProvisionDutRequest_ChromeOSImage_PathOneof `protobuf_oneof:"path_oneof"`
	// contains filtered or unexported fields
}

TODO(crbug.com/1155247) Deprecate this nested message and replace with top level ChromeOsImage.

Deprecated: Do not use.

func (*ProvisionDutRequest_ChromeOSImage) Descriptor deprecated 

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

Deprecated: Use ProvisionDutRequest_ChromeOSImage.ProtoReflect.Descriptor instead.

func (*ProvisionDutRequest_ChromeOSImage) GetGsPathPrefix 

func (x *ProvisionDutRequest_ChromeOSImage) GetGsPathPrefix() string

func (*ProvisionDutRequest_ChromeOSImage) GetPathOneof 

func (m *ProvisionDutRequest_ChromeOSImage) GetPathOneof() isProvisionDutRequest_ChromeOSImage_PathOneof

func (*ProvisionDutRequest_ChromeOSImage) ProtoMessage 

func (*ProvisionDutRequest_ChromeOSImage) ProtoMessage()

func (*ProvisionDutRequest_ChromeOSImage) ProtoReflect 

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

func (*ProvisionDutRequest_ChromeOSImage) Reset 

func (x *ProvisionDutRequest_ChromeOSImage) Reset()

func (*ProvisionDutRequest_ChromeOSImage) String 

func (x *ProvisionDutRequest_ChromeOSImage) String() string

type ProvisionDutRequest_ChromeOSImage_GsPathPrefix 

type ProvisionDutRequest_ChromeOSImage_GsPathPrefix struct {
	// gs_path_prefix is the GS path to where kernel, rootfs, and stateful
	// images are located. If DLCs are to be provisioned, it must be a GS path
	// that also has the dlc directory.
	// Only gs://chromeos-image-archive bucket is supported.
	// For example the format should be:
	// - gs://chromeos-image-archive/eve-release/R86-13380.0.0
	GsPathPrefix string `protobuf:"bytes,1,opt,name=gs_path_prefix,json=gsPathPrefix,proto3,oneof"`
}

type ProvisionDutRequest_DLCSpec 

type ProvisionDutRequest_DLCSpec struct {

	// id is the DLC ID which is a unique identifier.
	// The DLC ID must follow a specific format that can be found in the DLC
	// developer doc below.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Reference DLCs developer documentation: https://source.corp.google.com/chromeos_public/src/platform2/dlcservice/docs/developer.md

func (*ProvisionDutRequest_DLCSpec) Descriptor deprecated 

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

Deprecated: Use ProvisionDutRequest_DLCSpec.ProtoReflect.Descriptor instead.

func (*ProvisionDutRequest_DLCSpec) GetId 

func (x *ProvisionDutRequest_DLCSpec) GetId() string

func (*ProvisionDutRequest_DLCSpec) ProtoMessage 

func (*ProvisionDutRequest_DLCSpec) ProtoMessage()

func (*ProvisionDutRequest_DLCSpec) ProtoReflect 

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

func (*ProvisionDutRequest_DLCSpec) Reset 

func (x *ProvisionDutRequest_DLCSpec) Reset()

func (*ProvisionDutRequest_DLCSpec) String 

func (x *ProvisionDutRequest_DLCSpec) String() string

type ProvisionDutResponse 

type ProvisionDutResponse struct {
	// contains filtered or unexported fields
}

func (*ProvisionDutResponse) Descriptor deprecated 

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

Deprecated: Use ProvisionDutResponse.ProtoReflect.Descriptor instead.

func (*ProvisionDutResponse) ProtoMessage 

func (*ProvisionDutResponse) ProtoMessage()

func (*ProvisionDutResponse) ProtoReflect 

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

func (*ProvisionDutResponse) Reset 

func (x *ProvisionDutResponse) Reset()

func (*ProvisionDutResponse) String 

func (x *ProvisionDutResponse) String() string

type ProvisionDutResponse_Reason 

type ProvisionDutResponse_Reason int32

When the status code is other than OK, details in Status message should be parsed for ErrorInfo message with the following Reasons as the reason. 

const (
	// status code: INVALID_ARGUMENT
	ProvisionDutResponse_REASON_INVALID_REQUEST ProvisionDutResponse_Reason = 0
	// status code: FAILED_PRECONDITION
	ProvisionDutResponse_REASON_DUT_UNREACHABLE_PRE_PROVISION ProvisionDutResponse_Reason = 1
	// status code: FAILED_PRECONDITION
	ProvisionDutResponse_REASON_DOWNLOADING_IMAGE_FAILED ProvisionDutResponse_Reason = 2
	// status code: DEADLINE_EXCEEDED
	ProvisionDutResponse_REASON_PROVISIONING_TIMEDOUT ProvisionDutResponse_Reason = 3
	// status code: ABORTED
	ProvisionDutResponse_REASON_PROVISIONING_FAILED ProvisionDutResponse_Reason = 4
	// status code: ABORTED
	ProvisionDutResponse_REASON_DUT_UNREACHABLE_POST_PROVISION ProvisionDutResponse_Reason = 5
	// status code: ABORTED
	ProvisionDutResponse_REASON_UPDATE_FIRMWARE_FAILED ProvisionDutResponse_Reason = 6
	// status code: ABORTED
	ProvisionDutResponse_REASON_FIRMWARE_MISMATCH_POST_FIRMWARE_UPDATE ProvisionDutResponse_Reason = 7
	// status code: ABORTED
	ProvisionDutResponse_REASON_DUT_UNREACHABLE_POST_FIRMWARE_UPDATE ProvisionDutResponse_Reason = 8
)

func (ProvisionDutResponse_Reason) Descriptor 

func (ProvisionDutResponse_Reason) Descriptor() protoreflect.EnumDescriptor

func (ProvisionDutResponse_Reason) Enum 

func (x ProvisionDutResponse_Reason) Enum() *ProvisionDutResponse_Reason

func (ProvisionDutResponse_Reason) EnumDescriptor deprecated 

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

Deprecated: Use ProvisionDutResponse_Reason.Descriptor instead.

func (ProvisionDutResponse_Reason) Number 

func (x ProvisionDutResponse_Reason) Number() protoreflect.EnumNumber

func (ProvisionDutResponse_Reason) String 

func (x ProvisionDutResponse_Reason) String() string

func (ProvisionDutResponse_Reason) Type 

func (ProvisionDutResponse_Reason) Type() protoreflect.EnumType

type ProvisionLacrosMetadata 

type ProvisionLacrosMetadata struct {
	// contains filtered or unexported fields
}

func (*ProvisionLacrosMetadata) Descriptor deprecated 

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

Deprecated: Use ProvisionLacrosMetadata.ProtoReflect.Descriptor instead.

func (*ProvisionLacrosMetadata) ProtoMessage 

func (*ProvisionLacrosMetadata) ProtoMessage()

func (*ProvisionLacrosMetadata) ProtoReflect 

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

func (*ProvisionLacrosMetadata) Reset 

func (x *ProvisionLacrosMetadata) Reset()

func (*ProvisionLacrosMetadata) String 

func (x *ProvisionLacrosMetadata) String() string

type ProvisionLacrosRequest 

type ProvisionLacrosRequest struct {

	// name is the resource name for the DUT.
	// The DUT name is passed to the RTD when the RTD is started.
	// It is not specified whether the name is the DUT hostname.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// image specifies the Lacros image with which to provision the DUT.
	Image *ProvisionLacrosRequest_LacrosImage `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// override_version is the Lacros version string used to override when Lacros
	// is provisioned from the image source in the |LacrosImage| to the component
	// path. This is useful for simulating any desired version of Lacros for
	// autoupdate testing.
	// By default, if not specified, the actual version in the |LacrosImage| is
	// used.
	OverrideVersion string `protobuf:"bytes,3,opt,name=override_version,json=overrideVersion,proto3" json:"override_version,omitempty"`
	// override_install_path changes the install location from the default
	// imageloader component path.
	// If not specified, it defaults to the imageloader component path.
	OverrideInstallPath string `protobuf:"bytes,4,opt,name=override_install_path,json=overrideInstallPath,proto3" json:"override_install_path,omitempty"`
	// contains filtered or unexported fields
}
Example 
package main

import (
	"context"
	"fmt"

	"github.com/golang/protobuf/ptypes/duration"
	rtd "go.chromium.org/chromiumos/config/go/api/test/rtd/v1"
	"go.chromium.org/chromiumos/config/go/api/test/tls"
	"go.chromium.org/chromiumos/config/go/api/test/tls/dependencies/longrunning"
	"google.golang.org/grpc"
)

func main() {
	var invocation rtd.Invocation

	tlsConfig := invocation.GetTestLabServicesConfig()
	dutName := invocation.GetDuts()[0].GetTlsDutName()

	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", tlsConfig.GetTlwAddress(), tlsConfig.GetTlwPort()), grpc.WithInsecure())
	if err != nil {
		panic(err)
	}
	defer conn.Close()

	c := tls.NewCommonClient(conn)

	req := tls.ProvisionLacrosRequest{
		Name: dutName,
		Image: &tls.ProvisionLacrosRequest_LacrosImage{
			PathOneof: &tls.ProvisionLacrosRequest_LacrosImage_GsPathPrefix{
				GsPathPrefix: "gs://some/path",
			},
		},
	}

	ctx := context.Background()
	op, err := c.ProvisionLacros(ctx, &req)
	if err != nil {
		panic(err)
	}

	opcli := longrunning.NewOperationsClient(conn)
	op, err = opcli.WaitOperation(ctx, &longrunning.WaitOperationRequest{
		Name: op.GetName(),
		Timeout: &duration.Duration{
			Seconds: 3600,
		},
	})
	if err != nil {
		panic("RPC error")
	}

	if errStatus := op.GetError(); errStatus != nil {
		panic(fmt.Sprintf("Operation error details: %v", errStatus.GetDetails()))
	}

	// Provisioned Lacros.
}

Output:

func (*ProvisionLacrosRequest) Descriptor deprecated 

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

Deprecated: Use ProvisionLacrosRequest.ProtoReflect.Descriptor instead.

func (*ProvisionLacrosRequest) GetImage 

func (x *ProvisionLacrosRequest) GetImage() *ProvisionLacrosRequest_LacrosImage

func (*ProvisionLacrosRequest) GetName 

func (x *ProvisionLacrosRequest) GetName() string

func (*ProvisionLacrosRequest) GetOverrideInstallPath 

func (x *ProvisionLacrosRequest) GetOverrideInstallPath() string

func (*ProvisionLacrosRequest) GetOverrideVersion 

func (x *ProvisionLacrosRequest) GetOverrideVersion() string

func (*ProvisionLacrosRequest) ProtoMessage 

func (*ProvisionLacrosRequest) ProtoMessage()

func (*ProvisionLacrosRequest) ProtoReflect 

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

func (*ProvisionLacrosRequest) Reset 

func (x *ProvisionLacrosRequest) Reset()

func (*ProvisionLacrosRequest) String 

func (x *ProvisionLacrosRequest) String() string

type ProvisionLacrosRequest_LacrosImage 

type ProvisionLacrosRequest_LacrosImage struct {

	// Types that are assignable to PathOneof:
	//	*ProvisionLacrosRequest_LacrosImage_GsPathPrefix
	//	*ProvisionLacrosRequest_LacrosImage_DeviceFilePrefix
	PathOneof isProvisionLacrosRequest_LacrosImage_PathOneof `protobuf_oneof:"path_oneof"`
	// contains filtered or unexported fields
}

func (*ProvisionLacrosRequest_LacrosImage) Descriptor deprecated 

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

Deprecated: Use ProvisionLacrosRequest_LacrosImage.ProtoReflect.Descriptor instead.

func (*ProvisionLacrosRequest_LacrosImage) GetDeviceFilePrefix 

func (x *ProvisionLacrosRequest_LacrosImage) GetDeviceFilePrefix() string

func (*ProvisionLacrosRequest_LacrosImage) GetGsPathPrefix 

func (x *ProvisionLacrosRequest_LacrosImage) GetGsPathPrefix() string

func (*ProvisionLacrosRequest_LacrosImage) GetPathOneof 

func (m *ProvisionLacrosRequest_LacrosImage) GetPathOneof() isProvisionLacrosRequest_LacrosImage_PathOneof

func (*ProvisionLacrosRequest_LacrosImage) ProtoMessage 

func (*ProvisionLacrosRequest_LacrosImage) ProtoMessage()

func (*ProvisionLacrosRequest_LacrosImage) ProtoReflect 

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

func (*ProvisionLacrosRequest_LacrosImage) Reset 

func (x *ProvisionLacrosRequest_LacrosImage) Reset()

func (*ProvisionLacrosRequest_LacrosImage) String 

func (x *ProvisionLacrosRequest_LacrosImage) String() string

type ProvisionLacrosRequest_LacrosImage_DeviceFilePrefix 

type ProvisionLacrosRequest_LacrosImage_DeviceFilePrefix struct {
	// device_file_prefix is the file URL in which Lacros is located on the
	// DUT. This can refer to a local file for Lacros autoupdate testing.
	DeviceFilePrefix string `protobuf:"bytes,2,opt,name=device_file_prefix,json=deviceFilePrefix,proto3,oneof"`
}

type ProvisionLacrosRequest_LacrosImage_GsPathPrefix 

type ProvisionLacrosRequest_LacrosImage_GsPathPrefix struct {
	// gs_path_prefix is the GS path prefix to where Lacros is located.
	GsPathPrefix string `protobuf:"bytes,1,opt,name=gs_path_prefix,json=gsPathPrefix,proto3,oneof"`
}

type ProvisionLacrosResponse 

type ProvisionLacrosResponse struct {
	// contains filtered or unexported fields
}

func (*ProvisionLacrosResponse) Descriptor deprecated 

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

Deprecated: Use ProvisionLacrosResponse.ProtoReflect.Descriptor instead.

func (*ProvisionLacrosResponse) ProtoMessage 

func (*ProvisionLacrosResponse) ProtoMessage()

func (*ProvisionLacrosResponse) ProtoReflect 

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

func (*ProvisionLacrosResponse) Reset 

func (x *ProvisionLacrosResponse) Reset()

func (*ProvisionLacrosResponse) String 

func (x *ProvisionLacrosResponse) String() string

type ProvisionLacrosResponse_Reason 

type ProvisionLacrosResponse_Reason int32

When the status code is other than OK, details in Status message should be parsed for ErrorInfo message with the following Reasons as the reason. 

const (
	// Failed as the ProvisionLacros request is invalid.
	ProvisionLacrosResponse_REASON_INVALID_REQUEST ProvisionLacrosResponse_Reason = 0
	// Failed to connect to the DUT prior to provisioning Lacros.
	ProvisionLacrosResponse_REASON_DUT_UNREACHABLE_PRE_PROVISION ProvisionLacrosResponse_Reason = 1
	// Failed to download the Lacros image or a timeout during download.
	ProvisionLacrosResponse_REASON_DOWNLOADING_IMAGE_FAILED ProvisionLacrosResponse_Reason = 2
	// Failed due to a timeout during the main Lacros provisioning.
	// Excludes timeout during other steps.
	ProvisionLacrosResponse_REASON_PROVISIONING_TIMEDOUT ProvisionLacrosResponse_Reason = 3
	// General failure in Lacros provisioning.
	ProvisionLacrosResponse_REASON_PROVISIONING_FAILED ProvisionLacrosResponse_Reason = 4
)

func (ProvisionLacrosResponse_Reason) Descriptor 

func (ProvisionLacrosResponse_Reason) Descriptor() protoreflect.EnumDescriptor

func (ProvisionLacrosResponse_Reason) Enum 

func (x ProvisionLacrosResponse_Reason) Enum() *ProvisionLacrosResponse_Reason

func (ProvisionLacrosResponse_Reason) EnumDescriptor deprecated 

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

Deprecated: Use ProvisionLacrosResponse_Reason.Descriptor instead.

func (ProvisionLacrosResponse_Reason) Number 

func (x ProvisionLacrosResponse_Reason) Number() protoreflect.EnumNumber

func (ProvisionLacrosResponse_Reason) String 

func (x ProvisionLacrosResponse_Reason) String() string

func (ProvisionLacrosResponse_Reason) Type 

func (ProvisionLacrosResponse_Reason) Type() protoreflect.EnumType

type SetDutPowerSupplyRequest 

type SetDutPowerSupplyRequest struct {
	Dut   string                         `protobuf:"bytes,1,opt,name=dut,proto3" json:"dut,omitempty"`
	State SetDutPowerSupplyRequest_State `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SetDutPowerSupplyRequest) Descriptor deprecated 

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

Deprecated: Use SetDutPowerSupplyRequest.ProtoReflect.Descriptor instead.

func (*SetDutPowerSupplyRequest) GetDut 

func (x *SetDutPowerSupplyRequest) GetDut() string

func (*SetDutPowerSupplyRequest) GetState 

func (x *SetDutPowerSupplyRequest) GetState() SetDutPowerSupplyRequest_State

func (*SetDutPowerSupplyRequest) ProtoMessage 

func (*SetDutPowerSupplyRequest) ProtoMessage()

func (*SetDutPowerSupplyRequest) ProtoReflect 

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

func (*SetDutPowerSupplyRequest) Reset 

func (x *SetDutPowerSupplyRequest) Reset()

func (*SetDutPowerSupplyRequest) String 

func (x *SetDutPowerSupplyRequest) String() string

type SetDutPowerSupplyRequest_State 

type SetDutPowerSupplyRequest_State int32
const (
	SetDutPowerSupplyRequest_STATE_UNKNOWN SetDutPowerSupplyRequest_State = 0
	SetDutPowerSupplyRequest_STATE_ON      SetDutPowerSupplyRequest_State = 1
	SetDutPowerSupplyRequest_STATE_OFF     SetDutPowerSupplyRequest_State = 2
)

func (SetDutPowerSupplyRequest_State) Descriptor 

func (SetDutPowerSupplyRequest_State) Descriptor() protoreflect.EnumDescriptor

func (SetDutPowerSupplyRequest_State) Enum 

func (x SetDutPowerSupplyRequest_State) Enum() *SetDutPowerSupplyRequest_State

func (SetDutPowerSupplyRequest_State) EnumDescriptor deprecated 

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

Deprecated: Use SetDutPowerSupplyRequest_State.Descriptor instead.

func (SetDutPowerSupplyRequest_State) Number 

func (x SetDutPowerSupplyRequest_State) Number() protoreflect.EnumNumber

func (SetDutPowerSupplyRequest_State) String 

func (x SetDutPowerSupplyRequest_State) String() string

func (SetDutPowerSupplyRequest_State) Type 

func (SetDutPowerSupplyRequest_State) Type() protoreflect.EnumType

type SetDutPowerSupplyResponse 

type SetDutPowerSupplyResponse struct {
	Status SetDutPowerSupplyResponse_Status `` /* 135-byte string literal not displayed */
	// reason provides human friendly context for any error status.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*SetDutPowerSupplyResponse) Descriptor deprecated 

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

Deprecated: Use SetDutPowerSupplyResponse.ProtoReflect.Descriptor instead.

func (*SetDutPowerSupplyResponse) GetReason 

func (x *SetDutPowerSupplyResponse) GetReason() string

func (*SetDutPowerSupplyResponse) GetStatus 

func (x *SetDutPowerSupplyResponse) GetStatus() SetDutPowerSupplyResponse_Status

func (*SetDutPowerSupplyResponse) ProtoMessage 

func (*SetDutPowerSupplyResponse) ProtoMessage()

func (*SetDutPowerSupplyResponse) ProtoReflect 

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

func (*SetDutPowerSupplyResponse) Reset 

func (x *SetDutPowerSupplyResponse) Reset()

func (*SetDutPowerSupplyResponse) String 

func (x *SetDutPowerSupplyResponse) String() string

type SetDutPowerSupplyResponse_Status 

type SetDutPowerSupplyResponse_Status int32
const (
	SetDutPowerSupplyResponse_STATUS_UNKNOWN SetDutPowerSupplyResponse_Status = 0
	SetDutPowerSupplyResponse_STATUS_OK      SetDutPowerSupplyResponse_Status = 1
	// STATUS_BAD_DUT indicates that the DUT is not known,
	// or the caller does not have access to it.
	SetDutPowerSupplyResponse_STATUS_BAD_DUT SetDutPowerSupplyResponse_Status = 2
	// STATUS_BAD_REQUEST indicates that the request was invalid,
	// e.g., passing an invalid state.
	SetDutPowerSupplyResponse_STATUS_BAD_REQUEST SetDutPowerSupplyResponse_Status = 3
	SetDutPowerSupplyResponse_STATUS_NO_RPM      SetDutPowerSupplyResponse_Status = 4
	SetDutPowerSupplyResponse_STATUS_RPM_ERROR   SetDutPowerSupplyResponse_Status = 5
)

func (SetDutPowerSupplyResponse_Status) Descriptor 

func (SetDutPowerSupplyResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (SetDutPowerSupplyResponse_Status) Enum 

func (x SetDutPowerSupplyResponse_Status) Enum() *SetDutPowerSupplyResponse_Status

func (SetDutPowerSupplyResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use SetDutPowerSupplyResponse_Status.Descriptor instead.

func (SetDutPowerSupplyResponse_Status) Number 

func (x SetDutPowerSupplyResponse_Status) Number() protoreflect.EnumNumber

func (SetDutPowerSupplyResponse_Status) String 

func (x SetDutPowerSupplyResponse_Status) String() string

func (SetDutPowerSupplyResponse_Status) Type 

func (SetDutPowerSupplyResponse_Status) Type() protoreflect.EnumType

type UnimplementedCommonServer 

type UnimplementedCommonServer struct {
}

UnimplementedCommonServer should be embedded to have forward compatible implementations.

func (UnimplementedCommonServer) CreateFakeOmaha 

func (UnimplementedCommonServer) CreateFakeOmaha(context.Context, *CreateFakeOmahaRequest) (*FakeOmaha, error)

func (UnimplementedCommonServer) DeleteFakeOmaha 

func (UnimplementedCommonServer) DeleteFakeOmaha(context.Context, *DeleteFakeOmahaRequest) (*emptypb.Empty, error)

func (UnimplementedCommonServer) ExecDutCommand 

func (UnimplementedCommonServer) ExecDutCommand(*ExecDutCommandRequest, Common_ExecDutCommandServer) error

func (UnimplementedCommonServer) FetchCrashes 

func (UnimplementedCommonServer) FetchCrashes(*FetchCrashesRequest, Common_FetchCrashesServer) error

func (UnimplementedCommonServer) ProvisionAsh 

func (UnimplementedCommonServer) ProvisionAsh(context.Context, *ProvisionAshRequest) (*longrunning.Operation, error)

func (UnimplementedCommonServer) ProvisionDut 

func (UnimplementedCommonServer) ProvisionDut(context.Context, *ProvisionDutRequest) (*longrunning.Operation, error)

func (UnimplementedCommonServer) ProvisionLacros 

func (UnimplementedCommonServer) ProvisionLacros(context.Context, *ProvisionLacrosRequest) (*longrunning.Operation, error)

type UnimplementedWiringServer 

type UnimplementedWiringServer struct {
}

UnimplementedWiringServer should be embedded to have forward compatible implementations.

func (UnimplementedWiringServer) CacheForDut 

func (UnimplementedWiringServer) CacheForDut(context.Context, *CacheForDutRequest) (*longrunning.Operation, error)

func (UnimplementedWiringServer) CallServo 

func (UnimplementedWiringServer) CallServo(context.Context, *CallServoRequest) (*CallServoResponse, error)

func (UnimplementedWiringServer) ExposePortToDut 

func (UnimplementedWiringServer) ExposePortToDut(context.Context, *ExposePortToDutRequest) (*ExposePortToDutResponse, error)

func (UnimplementedWiringServer) GetDut 

func (UnimplementedWiringServer) GetDut(context.Context, *GetDutRequest) (*Dut, error)

func (UnimplementedWiringServer) OpenDutPort 

func (UnimplementedWiringServer) OpenDutPort(context.Context, *OpenDutPortRequest) (*OpenDutPortResponse, error)

func (UnimplementedWiringServer) SetDutPowerSupply 

func (UnimplementedWiringServer) SetDutPowerSupply(context.Context, *SetDutPowerSupplyRequest) (*SetDutPowerSupplyResponse, error)

type UnsafeCommonServer 

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

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

type UnsafeWiringServer 

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

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

type WiringClient 

type WiringClient interface {
	// GetDut gets a DUT resource, which contains various information
	// about a DUT.
	GetDut(ctx context.Context, in *GetDutRequest, opts ...grpc.CallOption) (*Dut, error)
	// Open a port on the DUT and return an address which the client can
	// use to connect to the port on the DUT.
	// The TLE SHOULD attempt to keep this address-to-port connection open for
	// the duration of the RTD's runtime.
	// The connection is not restarted if it is interrupted.
	//
	// If the connection from a previous call with the same arguments is
	// still open, this RPC SHOULD do nothing and return the same
	// response.
	// If the previous connection was closed, the implementation SHOULD
	// attempt to rebind and return the same address.
	// If the implementation lost and cannot reobtain the previous
	// address, it MAY return a new address.
	//
	// This RPC does NOT ensure that there is a service running on the
	// DUT for the given port.
	// A service running on the given port MUST NOT required for this RPC
	// to succeed.
	// It is not specified whether this RPC will open the given port in
	// the DUT's firewall, if the DUT has a firewall.
	OpenDutPort(ctx context.Context, in *OpenDutPortRequest, opts ...grpc.CallOption) (*OpenDutPortResponse, error)
	// SetDutPowerSupply sets the connected power state for the DUT.  It is
	// the caller's responsibility to wait for the effects of the call
	// to propagate, e.g. waiting in between calls to set the power OFF
	// and ON.
	//
	// EXPERIMENTAL
	SetDutPowerSupply(ctx context.Context, in *SetDutPowerSupplyRequest, opts ...grpc.CallOption) (*SetDutPowerSupplyResponse, error)
	// CacheForDut caches some data to be accessible for the DUT.
	// This will be made available to the DUT via a returned URL.
	// The implementation MUST ensure the returned URL is usable at least for the
	// lifetime of the RTD invocation.
	CacheForDut(ctx context.Context, in *CacheForDutRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// CallServo performs an XML-RPC call against the servod for
	// the servo connected to a DUT.
	//
	// The implementation, not the caller, ensures that there is a
	// running servod instance for the DUT's servo, or is otherwise able
	// to provide identical functionality.
	//
	// This RPC mirrors the XML-RPC specification (http://xmlrpc.com/spec.md).
	CallServo(ctx context.Context, in *CallServoRequest, opts ...grpc.CallOption) (*CallServoResponse, error)
	// ExposePortToDut exposes an RTD port to the specified DUT.
	//
	// The TLE SHOULD attempt to keep this address-to-port connection open for
	// the duration of the RTD's runtime.
	// The connection is not restarted if it is interrupted.
	// By default, the implementation MAY expose a port that cannot persist
	// across DUT reboots.
	// By default, the implementation MAY use 'localhost' as the exposed address.
	ExposePortToDut(ctx context.Context, in *ExposePortToDutRequest, opts ...grpc.CallOption) (*ExposePortToDutResponse, error)
}

WiringClient is the client API for Wiring service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWiringClient 

func NewWiringClient(cc grpc.ClientConnInterface) WiringClient

type WiringServer 

type WiringServer interface {
	// GetDut gets a DUT resource, which contains various information
	// about a DUT.
	GetDut(context.Context, *GetDutRequest) (*Dut, error)
	// Open a port on the DUT and return an address which the client can
	// use to connect to the port on the DUT.
	// The TLE SHOULD attempt to keep this address-to-port connection open for
	// the duration of the RTD's runtime.
	// The connection is not restarted if it is interrupted.
	//
	// If the connection from a previous call with the same arguments is
	// still open, this RPC SHOULD do nothing and return the same
	// response.
	// If the previous connection was closed, the implementation SHOULD
	// attempt to rebind and return the same address.
	// If the implementation lost and cannot reobtain the previous
	// address, it MAY return a new address.
	//
	// This RPC does NOT ensure that there is a service running on the
	// DUT for the given port.
	// A service running on the given port MUST NOT required for this RPC
	// to succeed.
	// It is not specified whether this RPC will open the given port in
	// the DUT's firewall, if the DUT has a firewall.
	OpenDutPort(context.Context, *OpenDutPortRequest) (*OpenDutPortResponse, error)
	// SetDutPowerSupply sets the connected power state for the DUT.  It is
	// the caller's responsibility to wait for the effects of the call
	// to propagate, e.g. waiting in between calls to set the power OFF
	// and ON.
	//
	// EXPERIMENTAL
	SetDutPowerSupply(context.Context, *SetDutPowerSupplyRequest) (*SetDutPowerSupplyResponse, error)
	// CacheForDut caches some data to be accessible for the DUT.
	// This will be made available to the DUT via a returned URL.
	// The implementation MUST ensure the returned URL is usable at least for the
	// lifetime of the RTD invocation.
	CacheForDut(context.Context, *CacheForDutRequest) (*longrunning.Operation, error)
	// CallServo performs an XML-RPC call against the servod for
	// the servo connected to a DUT.
	//
	// The implementation, not the caller, ensures that there is a
	// running servod instance for the DUT's servo, or is otherwise able
	// to provide identical functionality.
	//
	// This RPC mirrors the XML-RPC specification (http://xmlrpc.com/spec.md).
	CallServo(context.Context, *CallServoRequest) (*CallServoResponse, error)
	// ExposePortToDut exposes an RTD port to the specified DUT.
	//
	// The TLE SHOULD attempt to keep this address-to-port connection open for
	// the duration of the RTD's runtime.
	// The connection is not restarted if it is interrupted.
	// By default, the implementation MAY expose a port that cannot persist
	// across DUT reboots.
	// By default, the implementation MAY use 'localhost' as the exposed address.
	ExposePortToDut(context.Context, *ExposePortToDutRequest) (*ExposePortToDutResponse, error)
}

WiringServer is the server API for Wiring service. All implementations should embed UnimplementedWiringServer for forward compatibility

Source Files

View all Source files

Directories

Path Synopsis
dependencies
longrunning

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.