rpc_services

package
v0.0.0-...-f4b31ea Latest Latest
Warning

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

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

Documentation

Overview

Copyright 2023 The Chromium Authors Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Copyright 2024 The Chromium Authors Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Copyright 2023 The Chromium Authors Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Copyright 2023 The Chromium Authors Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Copyright 2024 The Chromium Authors Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Copyright 2023 The Chromium Authors Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SatlabRpcServiceServer 

type SatlabRpcServiceServer struct {
	pb.UnimplementedSatlabRpcServiceServer
	// contains filtered or unexported fields
}

SatlabRpcServiceServer is the gRPC service that provides every function.

func New 

func New(
	dev bool,
	buildService build_service.IBuildService,
	bucketService bucket_services.IBucketServices,
	dutService dut_services.IDUTServices,
	cpuTemperatureOrchestrator *cpu_temperature.CPUTemperatureOrchestrator,
	swarmingService services.ISwarmingService,
) *SatlabRpcServiceServer

func (*SatlabRpcServiceServer) AbortJobs 

func (s *SatlabRpcServiceServer) AbortJobs(ctx context.Context, in *pb.AbortJobsRequest) (*pb.AbortJobsResponse, error)

CancelJobs handles the request that users want to cancel jobs.

func (*SatlabRpcServiceServer) AddDuts 

func (s *SatlabRpcServiceServer) AddDuts(ctx context.Context, in *pb.AddDutsRequest) (*pb.AddDutsResponse, error)

func (*SatlabRpcServiceServer) AddPool 

func (s *SatlabRpcServiceServer) AddPool(ctx context.Context, in *pb.AddPoolRequest) (*pb.AddPoolResponse, error)

func (*SatlabRpcServiceServer) Close 

func (s *SatlabRpcServiceServer) Close(ctx context.Context)

Close clean up

func (*SatlabRpcServiceServer) DeleteDuts 

func (s *SatlabRpcServiceServer) DeleteDuts(ctx context.Context, in *pb.DeleteDutsRequest) (*pb.DeleteDutsResponse, error)

DeleteDuts the RPC service for deleting DUTs

func (*SatlabRpcServiceServer) DownloadLog 

func (s *SatlabRpcServiceServer) DownloadLog(_ *pb.DownloadLogRequest, server pb.SatlabRpcService_DownloadLogServer) error

func (*SatlabRpcServiceServer) GetChildTasksCountByStatus 

func (s *SatlabRpcServiceServer) GetChildTasksCountByStatus(
	ctx context.Context,
	startTime *timestamp.Timestamp,
	jobID string,
	tags []string,
	jobStates []swarmingapi.StateQuery,
) (*pb.TasksStatusCount, error)

GetChildTasksCountByStatus returns child tasks count for given states.

func (*SatlabRpcServiceServer) GetCloudConfiguration 

func (s *SatlabRpcServiceServer) GetCloudConfiguration(ctx context.Context, in *pb.GetCloudConfigurationRequest) (*pb.GetCloudConfigurationResponse, error)

GetCloudConfiguration get the cloud configuration from env and boto file.

func (*SatlabRpcServiceServer) GetConnectedDuts 

func (s *SatlabRpcServiceServer) GetConnectedDuts(ctx context.Context, executor executor.IExecCommander) ([]*pb.Dut, error)

func (*SatlabRpcServiceServer) GetDutDetail 

func (s *SatlabRpcServiceServer) GetDutDetail(ctx context.Context, in *pb.GetDutDetailRequest) (*pb.GetDutDetailResponse, error)

func (*SatlabRpcServiceServer) GetJobDetails 

func (s *SatlabRpcServiceServer) GetJobDetails(ctx context.Context, taskInfo *swarmingapi.TaskResultResponse) (*pb.Job, error)

GetJobDetails extracts tasks details used by Satlab UI.

func (*SatlabRpcServiceServer) GetNetworkInfo 

func (s *SatlabRpcServiceServer) GetNetworkInfo(ctx context.Context, _ *pb.GetNetworkInfoRequest) (*pb.GetNetworkInfoResponse, error)

GetNetworkInfo gets newwork information of satlab.

func (*SatlabRpcServiceServer) GetPeripheralInformation 

func (s *SatlabRpcServiceServer) GetPeripheralInformation(ctx context.Context, in *pb.GetPeripheralInformationRequest) (*pb.GetPeripheralInformationResponse, error)

GetPeripheralInformation get peripheral inforamtion by given DUT IP.

func (*SatlabRpcServiceServer) GetSystemInfo 

func (s *SatlabRpcServiceServer) GetSystemInfo(ctx context.Context, _ *pb.GetSystemInfoRequest) (*pb.GetSystemInfoResponse, error)

GetSystemInfo get the system information

func (*SatlabRpcServiceServer) GetTestPlan 

func (s *SatlabRpcServiceServer) GetTestPlan(ctx context.Context, in *pb.GetTestPlanRequest) (*pb.GetTestPlanResponse, error)

func (*SatlabRpcServiceServer) GetVersionInfo 

func (s *SatlabRpcServiceServer) GetVersionInfo(ctx context.Context, _ *pb.GetVersionInfoRequest) (*pb.GetVersionInfoResponse, error)

func (*SatlabRpcServiceServer) ListAccessibleModels 

func (s *SatlabRpcServiceServer) ListAccessibleModels(ctx context.Context, in *pb.ListAccessibleModelsRequest) (*pb.ListAccessibleModelsResponse, error)

ListAccessibleModels the gRPC server entry point to list all models for a given board

pb.ListAccessibleModelsRequest in the request from the client we use it as a filter to list the models.

func (*SatlabRpcServiceServer) ListBuildTargets 

func (s *SatlabRpcServiceServer) ListBuildTargets(ctx context.Context, _ *pb.ListBuildTargetsRequest) (*pb.ListBuildTargetsResponse, error)

ListBuildTargets the gRPC server entry point to list all the build targets.

ListBuildTargetsRequest _ we don't need use any parameter from the request, but we need to define it as a parameter to satisfy the compiler. To see more, we can look at the `src/satlab_rpcserver/satlabrpc.proto`

func (*SatlabRpcServiceServer) ListBuildVersions 

func (s *SatlabRpcServiceServer) ListBuildVersions(ctx context.Context, in *pb.ListBuildVersionsRequest) (*pb.ListBuildVersionsResponse, error)

ListBuildVersions the gRPC server entry point to list all build versions for given board, model, and milestone. TODO Add a cache for listing build versions

pb.ListBuildVersionsRequest in the request from the client we use to it as a filter to list the build versions.

func (*SatlabRpcServiceServer) ListConnectedDutsFirmware 

func (s *SatlabRpcServiceServer) ListConnectedDutsFirmware(ctx context.Context, _ *pb.ListConnectedDutsFirmwareRequest) (*pb.ListConnectedDutsFirmwareResponse, error)

ListConnectedDutsFirmware get current and firmware update on each DUT

func (*SatlabRpcServiceServer) ListDutEvents 

func (s *SatlabRpcServiceServer) ListDutEvents(ctx context.Context, in *pb.ListDutEventsRequest) (*pb.ListDutEventsResponse, error)

func (*SatlabRpcServiceServer) ListDutTasks 

func (s *SatlabRpcServiceServer) ListDutTasks(ctx context.Context, in *pb.ListDutTasksRequest) (*pb.ListDutTasksResponse, error)

func (*SatlabRpcServiceServer) ListDuts 

func (s *SatlabRpcServiceServer) ListDuts(ctx context.Context, in *pb.ListDutsRequest) (*pb.ListDutsResponse, error)

func (*SatlabRpcServiceServer) ListEnrolledDuts 

func (s *SatlabRpcServiceServer) ListEnrolledDuts(ctx context.Context, in *pb.ListEnrolledDutsRequest) (*pb.ListEnrolledDutsResponse, error)

func (*SatlabRpcServiceServer) ListJobs 

func (s *SatlabRpcServiceServer) ListJobs(ctx context.Context, in *pb.ListJobsRequest) (*pb.ListJobsResponse, error)

ListJobs a GRPC call to list all jobs(swarming tasks) based on filters.

func (*SatlabRpcServiceServer) ListMilestones 

func (s *SatlabRpcServiceServer) ListMilestones(ctx context.Context, in *pb.ListMilestonesRequest) (*pb.ListMilestonesResponse, error)

ListMilestones the gRPC server entry point to list all milestones from GCS bucket. TODO Add a cache for listing milestones

pb.ListMilestonesRequest in the request from the client we use it as a filter to list the milestones.

func (*SatlabRpcServiceServer) ListTestPlans 

func (s *SatlabRpcServiceServer) ListTestPlans(ctx context.Context, _ *pb.ListTestPlansRequest) (*pb.ListTestPlansResponse, error)

func (*SatlabRpcServiceServer) OpenCCD 

func (s *SatlabRpcServiceServer) OpenCCD(req *pb.OpenCCDRequest, stream pb.SatlabRpcService_OpenCCDServer) error

OpenCCD trigger `open CCD`

func (*SatlabRpcServiceServer) Reboot 

func (s *SatlabRpcServiceServer) Reboot(context.Context, *pb.RebootRequest) (*pb.RebootResponse, error)

Reboot call a reboot command on RPC container

func (*SatlabRpcServiceServer) RepairDuts 

func (s *SatlabRpcServiceServer) RepairDuts(ctx context.Context, in *pb.RepairDutsRequest) (*pb.RepairDutsResponse, error)

RepairDuts a GRPC call for repairing the DUTs.

func (*SatlabRpcServiceServer) RunLabQual 

func (s *SatlabRpcServiceServer) RunLabQual(
	ctx context.Context,
	in *pb.RunLabQualRequest,
) (*pb.RunLabQualResponse, error)

RunBvt run a bvt test with special parameters

func (*SatlabRpcServiceServer) RunQualification 

func (s *SatlabRpcServiceServer) RunQualification(
	ctx context.Context,
	req *pb.RunQualificationRequest,
) (*pb.RunQualificationResponse, error)

RunQualification runs a generic PVS qualification on the provided hardware and software.

func (*SatlabRpcServiceServer) RunStorageQual 

func (s *SatlabRpcServiceServer) RunStorageQual(
	ctx context.Context,
	in *pb.RunStorageQualRequest,
) (*pb.RunStorageQualResponse, error)

RunStorageQual run a storage qualification suite or test

func (*SatlabRpcServiceServer) RunSuite 

func (s *SatlabRpcServiceServer) RunSuite(ctx context.Context, in *pb.RunSuiteRequest) (*pb.RunSuiteResponse, error)

Run suite triggers the test suite on the satlab. Right now, this is implemented using CTPBuildRequest

func (*SatlabRpcServiceServer) RunTest 

func (s *SatlabRpcServiceServer) RunTest(ctx context.Context, in *pb.RunTestRequest) (*pb.RunTestResponse, error)

func (*SatlabRpcServiceServer) RunTestPlan 

func (s *SatlabRpcServiceServer) RunTestPlan(ctx context.Context, in *pb.RunTestPlanRequest) (*pb.RunTestPlanResponse, error)

func (*SatlabRpcServiceServer) SendMessageToCCDSession 

func (s *SatlabRpcServiceServer) SendMessageToCCDSession(ctx context.Context, req *pb.SendMessageToCCDSessionRequest) (*pb.SendMessageToCCDSessionResponse, error)

func (*SatlabRpcServiceServer) SetCloudConfiguration 

func (s *SatlabRpcServiceServer) SetCloudConfiguration(ctx context.Context, in *pb.SetCloudConfigurationRequest) (*pb.SetCloudConfigurationResponse, error)

func (*SatlabRpcServiceServer) StableVersion 

func (s *SatlabRpcServiceServer) StableVersion(ctx context.Context, in *pb.StableVersionRequest) (*pb.StableVersionResponse, error)

func (*SatlabRpcServiceServer) StageBuild 

func (s *SatlabRpcServiceServer) StageBuild(ctx context.Context, in *pb.StageBuildRequest) (*pb.StageBuildResponse, error)

StageBuild stage a build version in bucket.

pb.StageBuildRequest in the request from client which we want to stage the artifact in the partner bucket.

func (*SatlabRpcServiceServer) StartServod 

func (s *SatlabRpcServiceServer) StartServod(ctx context.Context, in *api.StartServodRequest) (*longrunning.Operation, error)

StartServod start Docker servod container.

func (*SatlabRpcServiceServer) UpdateDutsFirmware 

func (s *SatlabRpcServiceServer) UpdateDutsFirmware(ctx context.Context, in *pb.UpdateDutsFirmwareRequest) (*pb.UpdateDutsFirmwareResponse, error)

UpdateDutsFirmware update Duts by given IPs

func (*SatlabRpcServiceServer) UpdatePool 

func (s *SatlabRpcServiceServer) UpdatePool(ctx context.Context, in *pb.UpdatePoolRequest) (*pb.UpdatePoolResponse, error)

func (*SatlabRpcServiceServer) UploadLog 

func (s *SatlabRpcServiceServer) UploadLog(ctx context.Context, _ *pb.UploadLogRequest) (*pb.UploadLogResponse, error)

type Streaming 

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

func (*Streaming) Write 

func (s *Streaming) Write(data []byte) (n int, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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