consoleserver

package
v0.0.0-...-a77d6fb Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2026 License: BSD-3-Clause Imports: 60 Imported by: 0

Documentation

Overview

Package consoleserver is the implementation of the backend of the console UI.

Index

Constants

View Source 
const (
	DefaultPageSize      = 10
	ExpectedEtaColumnKey = "expected_eta" // computed column key, doesn't exist in the db
	SlippageColumnKey    = "slippage"     // computed column key, doesn't exist in the db
)
View Source 
const (
	LOCAL_DB_CONNECTION_URL = "postgresql://postgres:password@localhost:5432/postgres"
)

Variables

This section is empty.

Functions

func BigQueryValueToDate 

func BigQueryValueToDate(value bigquery.Value) (date *fleetconsolerpc.DateOnly)

func EnsureNoNilValuesInDb 

func EnsureNoNilValuesInDb(ctx context.Context) error

func InstallServices 

func InstallServices(consoleFrontend fleetconsolerpc.FleetConsoleServer, srv grpc.ServiceRegistrar)

InstallServices installs services into the server.

func MapRow 

func MapRow(row map[string]bigquery.Value) *fleetconsolerpc.ResourceRequest

func NewFleetConsoleFrontend 

func NewFleetConsoleFrontend() fleetconsolerpc.FleetConsoleServer

NewFleetConsoleFrontend creates a new fleet console frontend.

func SetAdminServiceAddress 

func SetAdminServiceAddress(consoleFrontend *FleetConsoleFrontend, adminServiceAddress string)

SetAdminServiceAddress sets the admin service address.

func SetCIPDVersion 

func SetCIPDVersion(consoleFrontend *FleetConsoleFrontend, cipdVersion buildbucket.CIPDVersion)

SetCIPDVersion sets the CIPD version.

func SetCloudProject 

func SetCloudProject(consoleFrontend *FleetConsoleFrontend, cloudProject string)

SetCloudProject sets the cloud project.

func SetDeviceManagerClient 

func SetDeviceManagerClient(consoleFrontend *FleetConsoleFrontend, deviceManagerClient func(context.Context, bool) (*devicemanagerclient.Client, error))

SetDeviceManagerClient sets the device manager client.

func SetInventoryNamespace 

func SetInventoryNamespace(consoleFrontend *FleetConsoleFrontend, inventoryNamespace string)

SetInventoryNamespace sets the inventory namespace.

func SetInventoryServiceAddress 

func SetInventoryServiceAddress(consoleFrontend *FleetConsoleFrontend, inventoryServiceAddress string)

SetInventoryServiceAddress sets the inventory service address.

func SetSwarmingClient 

func SetSwarmingClient(consoleFrontend *FleetConsoleFrontend, swarmingClient swarmingClientFactory)

SetSwarmingClient sets the swarming client.

func SetUFSClient 

func SetUFSClient(consoleFrontend *FleetConsoleFrontend, ufsClient func(context.Context, bool) (ufsclient.Client, error))

SetUFSClient sets the UFS client.

Types

type FleetConsoleFrontend 

type FleetConsoleFrontend struct {
	fleetconsolerpc.UnimplementedFleetConsoleServer
	// contains filtered or unexported fields
}

FleetConsoleFrontend is the fleet console frontend.

func (*FleetConsoleFrontend) CleanExit 

func (frontend *FleetConsoleFrontend) CleanExit(ctx context.Context, req *fleetconsolerpc.CleanExitRequest) (*fleetconsolerpc.CleanExitResponse, error)

CleanExit exits the current process.

func (*FleetConsoleFrontend) CleanupAndroidDevices 

func (frontend *FleetConsoleFrontend) CleanupAndroidDevices(ctx context.Context, req *fleetconsolerpc.CleanupAndroidDevicesRequest) (_ *fleetconsolerpc.CleanupAndroidDevicesResponse, err error)

CleanupAndroidDevices does cleanup stuff for android data

func (*FleetConsoleFrontend) CountBrowserDevices 

func (frontend *FleetConsoleFrontend) CountBrowserDevices(ctx context.Context, req *fleetconsolerpc.CountBrowserDevicesRequest) (_ *fleetconsolerpc.CountBrowserDevicesResponse, err error)

func (*FleetConsoleFrontend) CountDevices 

func (frontend *FleetConsoleFrontend) CountDevices(ctx context.Context, req *fleetconsolerpc.CountDevicesRequest) (_ *fleetconsolerpc.CountDevicesResponse, err error)

func (*FleetConsoleFrontend) CountRepairMetrics 

func (frontend *FleetConsoleFrontend) CountRepairMetrics(ctx context.Context, req *fleetconsolerpc.CountRepairMetricsRequest) (_ *fleetconsolerpc.CountRepairMetricsResponse, err error)

CountDevices lists devices from the db.

func (*FleetConsoleFrontend) CountResourceRequests 

func (frontend *FleetConsoleFrontend) CountResourceRequests(ctx context.Context, req *fleetconsolerpc.CountResourceRequestsRequest) (_ *fleetconsolerpc.CountResourceRequestsResponse, err error)

func (*FleetConsoleFrontend) ExportDevicesToCSV 

func (frontend *FleetConsoleFrontend) ExportDevicesToCSV(ctx context.Context, req *fleetconsolerpc.ExportDevicesToCSVRequest) (*fleetconsolerpc.ExportDevicesToCSVResponse, error)

func (*FleetConsoleFrontend) GetBrowserDeviceDimensions 

func (frontend *FleetConsoleFrontend) GetBrowserDeviceDimensions(ctx context.Context, req *fleetconsolerpc.GetBrowserDeviceDimensionsRequest) (_ *fleetconsolerpc.GetBrowserDeviceDimensionsResponse, err error)

GetBrowserDeviceDimensions returns dimensions of all browser devices

func (*FleetConsoleFrontend) GetDeviceDimensions 

func (frontend *FleetConsoleFrontend) GetDeviceDimensions(ctx context.Context, req *fleetconsolerpc.GetDeviceDimensionsRequest) (_ *fleetconsolerpc.GetDeviceDimensionsResponse, err error)

GetDeviceDimensions returns dimensions of all devices

func (*FleetConsoleFrontend) GetRepairMetricsDimensions 

func (frontend *FleetConsoleFrontend) GetRepairMetricsDimensions(ctx context.Context, req *fleetconsolerpc.GetRepairMetricsDimensionsRequest) (_ *fleetconsolerpc.GetRepairMetricsDimensionsResponse, err error)

GetDeviceDimensions returns dimensions of all devices

func (*FleetConsoleFrontend) GetResourceRequestsMultiselectFilterValues 

func (frontend *FleetConsoleFrontend) GetResourceRequestsMultiselectFilterValues(ctx context.Context, req *fleetconsolerpc.GetResourceRequestsMultiselectFilterValuesRequest) (*fleetconsolerpc.GetResourceRequestsMultiselectFilterValuesResponse, error)

GetResourceRequestsMultiselectFilterValues lists resource requests.

func (*FleetConsoleFrontend) IsProdEnvironment 

func (frontend *FleetConsoleFrontend) IsProdEnvironment() bool

func (*FleetConsoleFrontend) ListAndroidDevices 

func (frontend *FleetConsoleFrontend) ListAndroidDevices(ctx context.Context, req *fleetconsolerpc.ListAndroidDevicesRequest) (_ *fleetconsolerpc.ListAndroidDevicesResponse, err error)

ListAndroidDevices lists devices from the db.

func (*FleetConsoleFrontend) ListBrowserDevices 

func (frontend *FleetConsoleFrontend) ListBrowserDevices(ctx context.Context, req *fleetconsolerpc.ListBrowserDevicesRequest) (_ *fleetconsolerpc.ListBrowserDevicesResponse, err error)

ListBrowserDevices lists devices from the db.

func (*FleetConsoleFrontend) ListDevices 

func (frontend *FleetConsoleFrontend) ListDevices(ctx context.Context, req *fleetconsolerpc.ListDevicesRequest) (_ *fleetconsolerpc.ListDevicesResponse, err error)

ListDevices lists devices from the db.

func (*FleetConsoleFrontend) ListProductCatalogEntries 

func (s *FleetConsoleFrontend) ListProductCatalogEntries(ctx context.Context, req *fleetconsolerpc.ListProductCatalogEntriesRequest) (*fleetconsolerpc.ListProductCatalogEntriesResponse, error)

ListProductCatalogEntries implements the RPC handler for listing product catalog entries.

func (*FleetConsoleFrontend) ListRepairMetrics 

func (frontend *FleetConsoleFrontend) ListRepairMetrics(ctx context.Context, req *fleetconsolerpc.ListRepairMetricsRequest) (_ *fleetconsolerpc.ListRepairMetricsResponse, err error)

ListDevices lists devices from the db.

func (*FleetConsoleFrontend) ListResourceRequests 

func (frontend *FleetConsoleFrontend) ListResourceRequests(ctx context.Context, req *fleetconsolerpc.ListResourceRequestsRequest) (*fleetconsolerpc.ListResourceRequestsResponse, error)

ListResourceRequests lists resource requests.

func (*FleetConsoleFrontend) Ping 

func (frontend *FleetConsoleFrontend) Ping(ctx context.Context, req *fleetconsolerpc.PingRequest) (*fleetconsolerpc.PingResponse, error)

Ping is the ping RPC. It responds with an empty response and never fails.

func (*FleetConsoleFrontend) PingBigQuery 

func (frontend *FleetConsoleFrontend) PingBigQuery(ctx context.Context, req *fleetconsolerpc.PingBigQueryRequest) (_ *fleetconsolerpc.PingBigQueryResponse, err error)

PingBigQuery pings the mock BQ database with a random query and logs the results.

func (*FleetConsoleFrontend) PingDB 

func (frontend *FleetConsoleFrontend) PingDB(ctx context.Context, req *fleetconsolerpc.PingDBRequest) (_ *fleetconsolerpc.PingDBResponse, err error)

PingDB pings the database.

func (*FleetConsoleFrontend) PingDeviceManager 

func (frontend *FleetConsoleFrontend) PingDeviceManager(ctx context.Context, req *fleetconsolerpc.PingDeviceManagerRequest) (_ *fleetconsolerpc.PingDeviceManagerResponse, err error)

PingDeviceManager pings device manager.

func (*FleetConsoleFrontend) PingSwarming 

func (frontend *FleetConsoleFrontend) PingSwarming(ctx context.Context, req *fleetconsolerpc.PingSwarmingRequest) (*fleetconsolerpc.PingSwarmingResponse, error)

PingSwarming pings the swarming service.

func (*FleetConsoleFrontend) PingUfs 

func (frontend *FleetConsoleFrontend) PingUfs(ctx context.Context, req *fleetconsolerpc.PingUfsRequest) (_ *fleetconsolerpc.PingUfsResponse, err error)

PingUfs pings UFS.

func (*FleetConsoleFrontend) RepopulateAndroidCache 

func (frontend *FleetConsoleFrontend) RepopulateAndroidCache(ctx context.Context, req *fleetconsolerpc.RepopulateAndroidCacheRequest) (*fleetconsolerpc.RepopulateAndroidCacheResponse, error)

RepopulateAndroidCache repopulates the Android cache from UFS.

func (*FleetConsoleFrontend) RepopulateBrowserCache 

func (frontend *FleetConsoleFrontend) RepopulateBrowserCache(ctx context.Context, req *fleetconsolerpc.RepopulateBrowserCacheRequest) (_ *fleetconsolerpc.RepopulateBrowserCacheResponse, err error)

RepopulateBrowserCache repopulates the browser devices cache.

func (*FleetConsoleFrontend) RepopulateCache 

func (frontend *FleetConsoleFrontend) RepopulateCache(ctx context.Context, req *fleetconsolerpc.RepopulateCacheRequest) (_ *fleetconsolerpc.RepopulateCacheResponse, err error)

RepopulateCache repopulates the AlloyDB cache.

func (*FleetConsoleFrontend) ScheduleAutorepair 

func (frontend *FleetConsoleFrontend) ScheduleAutorepair(ctx context.Context, req *fleetconsolerpc.ScheduleAutorepairRequest) (_ *fleetconsolerpc.ScheduleAutorepairResponse, err error)

func (*FleetConsoleFrontend) ScheduleBuild 

func (frontend *FleetConsoleFrontend) ScheduleBuild(ctx context.Context, req *fleetconsolerpc.ScheduleBuildRequest) (_ *fleetconsolerpc.ScheduleBuildResponse, err error)

func (*FleetConsoleFrontend) SyncProductCatalog 

func (s *FleetConsoleFrontend) SyncProductCatalog(ctx context.Context) error

SyncProductCatalog is a cron handler that syncs the product catalog from the config to the database.

func (*FleetConsoleFrontend) UpdateAndroidDevices 

func (frontend *FleetConsoleFrontend) UpdateAndroidDevices(ctx context.Context, req *fleetconsolerpc.UpdateAndroidDevicesRequest) (_ *fleetconsolerpc.UpdateAndroidDevicesResponse, err error)

UpdateAndroidDevices receives a LabResource message and process it. Maybe this shouldn't be part of FleetConsoleFrontend

func (*FleetConsoleFrontend) UpdateAndroidMetrics 

func (frontend *FleetConsoleFrontend) UpdateAndroidMetrics(ctx context.Context, req *fleetconsolerpc.UpdateAndroidMetricsRequest) (_ *fleetconsolerpc.UpdateAndroidMetricsResponse, err error)

type LabelRow 

type LabelRow struct {
	Key   string `sql:"key"`
	Value string `sql:"value"`
}

Source Files

View all Source files

Directories

Path Synopsis

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.