consoleserver

Documentation

Overview

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

Index

• func InstallServices(consoleFrontend fleetconsolerpc.FleetConsoleServer, srv grpc.ServiceRegistrar)
• func MustSetDBConnection(ctx context.Context, consoleFrontend *FleetConsoleFrontend)
• func NewFleetConsoleFrontend() fleetconsolerpc.FleetConsoleServer
• func SetCloudProject(consoleFrontend *FleetConsoleFrontend, cloudProject string)
• func SetDeviceManagerClient(consoleFrontend *FleetConsoleFrontend, ...)
• func SetUFSClient(consoleFrontend *FleetConsoleFrontend, ...)
• type FleetConsoleFrontend
  • func (frontend *FleetConsoleFrontend) CleanExit(ctx context.Context, req *fleetconsolerpc.CleanExitRequest) (*fleetconsolerpc.CleanExitResponse, error)
  • func (frontend *FleetConsoleFrontend) CountDevices(ctx context.Context, req *fleetconsolerpc.CountDevicesRequest) (_ *fleetconsolerpc.CountDevicesResponse, err error)
  • func (frontend *FleetConsoleFrontend) GetDeviceDimensions(ctx context.Context, req *emptypb.Empty) (_ *fleetconsolerpc.GetDeviceDimensionsResponse, err error)
  • func (frontend *FleetConsoleFrontend) ListDevices(ctx context.Context, req *fleetconsolerpc.ListDevicesRequest) (_ *fleetconsolerpc.ListDevicesResponse, err error)
  • func (frontend *FleetConsoleFrontend) ListResourceRequests(ctx context.Context, req *fleetconsolerpc.ListResourceRequestsRequest) (*fleetconsolerpc.ListResourceRequestsResponse, error)
  • func (frontend *FleetConsoleFrontend) Ping(ctx context.Context, req *fleetconsolerpc.PingRequest) (*fleetconsolerpc.PingResponse, error)
  • func (frontend *FleetConsoleFrontend) PingBigQuery(ctx context.Context, req *fleetconsolerpc.PingBigQueryRequest) (_ *fleetconsolerpc.PingBigQueryResponse, err error)
  • func (frontend *FleetConsoleFrontend) PingDB(ctx context.Context, req *fleetconsolerpc.PingDBRequest) (_ *fleetconsolerpc.PingDBResponse, err error)
  • func (frontend *FleetConsoleFrontend) PingDeviceManager(ctx context.Context, req *fleetconsolerpc.PingDeviceManagerRequest) (_ *fleetconsolerpc.PingDeviceManagerResponse, err error)
  • func (frontend *FleetConsoleFrontend) PingUfs(ctx context.Context, req *fleetconsolerpc.PingUfsRequest) (_ *fleetconsolerpc.PingUfsResponse, err error)
  • func (frontend *FleetConsoleFrontend) RepopulateCache(ctx context.Context, req *fleetconsolerpc.RepopulateCacheRequest) (_ *fleetconsolerpc.RepopulateCacheResponse, err error)

Functions

func InstallServices

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

InstallServices installs services into the server.

func MustSetDBConnection

func MustSetDBConnection(ctx context.Context, consoleFrontend *FleetConsoleFrontend)

MustSetDBConnection sets the db connection and panics if it can't retrieve the secret or connect to the database.

func NewFleetConsoleFrontend

func NewFleetConsoleFrontend() fleetconsolerpc.FleetConsoleServer

NewFleetConsoleFrontend creates a new fleet console frontend.

func SetCloudProject

func SetCloudProject(consoleFrontend *FleetConsoleFrontend, cloudProject string)

SetCloudProject sets the cloud project

func SetDeviceManagerClient

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

SetDeviceManagerClient sets the device manager client.

func SetUFSClient

func SetUFSClient(consoleFrontend *FleetConsoleFrontend, ufsClient func(context.Context, string) (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) CountDevices

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

func (*FleetConsoleFrontend) GetDeviceDimensions

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

GetDeviceDimensions returns dimensions of all devices

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) 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) PingUfs

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

PingUfs pings UFS.

func (*FleetConsoleFrontend) RepopulateCache

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