fleet

package
v0.0.0-...-9994f1b Latest Latest
Warning

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

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

Documentation

Overview

Package fleet contains service definitions for fleet management in crosskylabadmin.

Package fleet is a generated GoMock package.

Package fleet is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var (
	DutState_name = map[int32]string{
		0: "DutStateInvalid",
		1: "Ready",
		2: "NeedsCleanup",
		3: "NeedsRepair",
		4: "NeedsReset",
		5: "RepairFailed",
		6: "NeedsReplacement",
		7: "NeedsManualRepair",
		8: "NeedsDeploy",
	}
	DutState_value = map[string]int32{
		"DutStateInvalid":   0,
		"Ready":             1,
		"NeedsCleanup":      2,
		"NeedsRepair":       3,
		"NeedsReset":        4,
		"RepairFailed":      5,
		"NeedsReplacement":  6,
		"NeedsManualRepair": 7,
		"NeedsDeploy":       8,
	}
)

Enum value maps for DutState.

View Source 
var (
	AuditTask_name = map[int32]string{
		0: "TaskInvalid",
		1: "ServoUSBKey",
		2: "DUTStorage",
		3: "RPMConfig",
	}
	AuditTask_value = map[string]int32{
		"TaskInvalid": 0,
		"ServoUSBKey": 1,
		"DUTStorage":  2,
		"RPMConfig":   3,
	}
)

Enum value maps for AuditTask.

View Source 
var (
	PushBotsForAdminTasksRequest_SchedulingStrategy_name = map[int32]string{
		0: "DefaultSchedulingStrategy",
		1: "LabstationRebootStrategy",
	}
	PushBotsForAdminTasksRequest_SchedulingStrategy_value = map[string]int32{
		"DefaultSchedulingStrategy": 0,
		"LabstationRebootStrategy":  1,
	}
)

Enum value maps for PushBotsForAdminTasksRequest_SchedulingStrategy.

View Source 
var File_go_chromium_org_infra_appengine_crosskylabadmin_api_fleet_v1_common_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_infra_appengine_crosskylabadmin_api_fleet_v1_inventory_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_infra_appengine_crosskylabadmin_api_fleet_v1_tracker_proto protoreflect.FileDescriptor

Functions

func FileDescriptorSet 

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterInventoryServer 

func RegisterInventoryServer(s prpc.Registrar, srv InventoryServer)

func RegisterTrackerServer 

func RegisterTrackerServer(s prpc.Registrar, srv TrackerServer)

Types

type AuditTask 

type AuditTask int32
const (
	AuditTask_TaskInvalid AuditTask = 0
	AuditTask_ServoUSBKey AuditTask = 1
	AuditTask_DUTStorage  AuditTask = 2
	AuditTask_RPMConfig   AuditTask = 3
)

func (AuditTask) Descriptor 

func (AuditTask) Descriptor() protoreflect.EnumDescriptor

func (AuditTask) Enum 

func (x AuditTask) Enum() *AuditTask

func (AuditTask) EnumDescriptor deprecated 

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

Deprecated: Use AuditTask.Descriptor instead.

func (AuditTask) Number 

func (x AuditTask) Number() protoreflect.EnumNumber

func (AuditTask) String 

func (x AuditTask) String() string

func (AuditTask) Type 

func (AuditTask) Type() protoreflect.EnumType

type DecoratedInventory 

type DecoratedInventory struct {
	// Service is the service to decorate.
	Service InventoryServer
	// Prelude is called for each method before forwarding the call to Service.
	// If Prelude returns an error, then the call is skipped and the error is
	// processed via the Postlude (if one is defined), or it is returned directly.
	Prelude func(ctx context.Context, methodName string, req proto.Message) (context.Context, error)
	// Postlude is called for each method after Service has processed the call, or
	// after the Prelude has returned an error. This takes the Service's
	// response proto (which may be nil) and/or any error. The decorated
	// service will return the response (possibly mutated) and error that Postlude
	// returns.
	Postlude func(ctx context.Context, methodName string, rsp proto.Message, err error) error
}

func (*DecoratedInventory) DeleteSatlabStableVersion 

func (s *DecoratedInventory) DeleteSatlabStableVersion(ctx context.Context, req *DeleteSatlabStableVersionRequest) (rsp *DeleteSatlabStableVersionResponse, err error)

func (*DecoratedInventory) DumpStableVersionToDatastore 

func (s *DecoratedInventory) DumpStableVersionToDatastore(ctx context.Context, req *DumpStableVersionToDatastoreRequest) (rsp *DumpStableVersionToDatastoreResponse, err error)

func (*DecoratedInventory) GetRecoveryVersion 

func (s *DecoratedInventory) GetRecoveryVersion(ctx context.Context, req *GetRecoveryVersionRequest) (rsp *GetRecoveryVersionResponse, err error)

func (*DecoratedInventory) GetStableVersion 

func (s *DecoratedInventory) GetStableVersion(ctx context.Context, req *GetStableVersionRequest) (rsp *GetStableVersionResponse, err error)

func (*DecoratedInventory) SetSatlabStableVersion 

func (s *DecoratedInventory) SetSatlabStableVersion(ctx context.Context, req *SetSatlabStableVersionRequest) (rsp *SetSatlabStableVersionResponse, err error)

type DecoratedTracker 

type DecoratedTracker struct {
	// Service is the service to decorate.
	Service TrackerServer
	// Prelude is called for each method before forwarding the call to Service.
	// If Prelude returns an error, then the call is skipped and the error is
	// processed via the Postlude (if one is defined), or it is returned directly.
	Prelude func(ctx context.Context, methodName string, req proto.Message) (context.Context, error)
	// Postlude is called for each method after Service has processed the call, or
	// after the Prelude has returned an error. This takes the Service's
	// response proto (which may be nil) and/or any error. The decorated
	// service will return the response (possibly mutated) and error that Postlude
	// returns.
	Postlude func(ctx context.Context, methodName string, rsp proto.Message, err error) error
}

func (*DecoratedTracker) PushBotsForAdminAuditTasks 

func (s *DecoratedTracker) PushBotsForAdminAuditTasks(ctx context.Context, req *PushBotsForAdminAuditTasksRequest) (rsp *PushBotsForAdminAuditTasksResponse, err error)

func (*DecoratedTracker) PushBotsForAdminTasks 

func (s *DecoratedTracker) PushBotsForAdminTasks(ctx context.Context, req *PushBotsForAdminTasksRequest) (rsp *PushBotsForAdminTasksResponse, err error)

func (*DecoratedTracker) PushRepairJobsForLabstations 

func (s *DecoratedTracker) PushRepairJobsForLabstations(ctx context.Context, req *PushRepairJobsForLabstationsRequest) (rsp *PushRepairJobsForLabstationsResponse, err error)

func (*DecoratedTracker) ReportBots 

func (s *DecoratedTracker) ReportBots(ctx context.Context, req *ReportBotsRequest) (rsp *ReportBotsResponse, err error)

type DeleteSatlabStableVersionRequest 

type DeleteSatlabStableVersionRequest struct {

	// Types that are valid to be assigned to Strategy:
	//
	//	*DeleteSatlabStableVersionRequest_SatlabBoardModelDeletionCriterion
	//	*DeleteSatlabStableVersionRequest_SatlabHostnameDeletionCriterion
	Strategy isDeleteSatlabStableVersionRequest_Strategy `protobuf_oneof:"strategy"`
	// contains filtered or unexported fields
}

func (*DeleteSatlabStableVersionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSatlabStableVersionRequest.ProtoReflect.Descriptor instead.

func (*DeleteSatlabStableVersionRequest) GetSatlabBoardModelDeletionCriterion 

func (x *DeleteSatlabStableVersionRequest) GetSatlabBoardModelDeletionCriterion() *SatlabBoardModelDeletionCriterion

func (*DeleteSatlabStableVersionRequest) GetSatlabHostnameDeletionCriterion 

func (x *DeleteSatlabStableVersionRequest) GetSatlabHostnameDeletionCriterion() *SatlabHostnameDeletionCriterion

func (*DeleteSatlabStableVersionRequest) GetStrategy 

func (x *DeleteSatlabStableVersionRequest) GetStrategy() isDeleteSatlabStableVersionRequest_Strategy

func (*DeleteSatlabStableVersionRequest) ProtoMessage 

func (*DeleteSatlabStableVersionRequest) ProtoMessage()

func (*DeleteSatlabStableVersionRequest) ProtoReflect 

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

func (*DeleteSatlabStableVersionRequest) Reset 

func (x *DeleteSatlabStableVersionRequest) Reset()

func (*DeleteSatlabStableVersionRequest) String 

func (x *DeleteSatlabStableVersionRequest) String() string

type DeleteSatlabStableVersionRequest_SatlabBoardModelDeletionCriterion 

type DeleteSatlabStableVersionRequest_SatlabBoardModelDeletionCriterion struct {
	SatlabBoardModelDeletionCriterion *SatlabBoardModelDeletionCriterion `protobuf:"bytes,1,opt,name=satlabBoardModelDeletionCriterion,proto3,oneof"`
}

type DeleteSatlabStableVersionRequest_SatlabHostnameDeletionCriterion 

type DeleteSatlabStableVersionRequest_SatlabHostnameDeletionCriterion struct {
	SatlabHostnameDeletionCriterion *SatlabHostnameDeletionCriterion `protobuf:"bytes,2,opt,name=satlabHostnameDeletionCriterion,proto3,oneof"`
}

type DeleteSatlabStableVersionResponse 

type DeleteSatlabStableVersionResponse struct {
	DidDelete bool   `protobuf:"varint,1,opt,name=didDelete,proto3" json:"didDelete,omitempty"`
	Reason    string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSatlabStableVersionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSatlabStableVersionResponse.ProtoReflect.Descriptor instead.

func (*DeleteSatlabStableVersionResponse) GetDidDelete 

func (x *DeleteSatlabStableVersionResponse) GetDidDelete() bool

func (*DeleteSatlabStableVersionResponse) GetReason 

func (x *DeleteSatlabStableVersionResponse) GetReason() string

func (*DeleteSatlabStableVersionResponse) ProtoMessage 

func (*DeleteSatlabStableVersionResponse) ProtoMessage()

func (*DeleteSatlabStableVersionResponse) ProtoReflect 

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

func (*DeleteSatlabStableVersionResponse) Reset 

func (x *DeleteSatlabStableVersionResponse) Reset()

func (*DeleteSatlabStableVersionResponse) String 

func (x *DeleteSatlabStableVersionResponse) String() string

type DumpStableVersionToDatastoreRequest 

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

func (*DumpStableVersionToDatastoreRequest) Descriptor deprecated 

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

Deprecated: Use DumpStableVersionToDatastoreRequest.ProtoReflect.Descriptor instead.

func (*DumpStableVersionToDatastoreRequest) ProtoMessage 

func (*DumpStableVersionToDatastoreRequest) ProtoMessage()

func (*DumpStableVersionToDatastoreRequest) ProtoReflect 

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

func (*DumpStableVersionToDatastoreRequest) Reset 

func (x *DumpStableVersionToDatastoreRequest) Reset()

func (*DumpStableVersionToDatastoreRequest) String 

func (x *DumpStableVersionToDatastoreRequest) String() string

type DumpStableVersionToDatastoreResponse 

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

func (*DumpStableVersionToDatastoreResponse) Descriptor deprecated 

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

Deprecated: Use DumpStableVersionToDatastoreResponse.ProtoReflect.Descriptor instead.

func (*DumpStableVersionToDatastoreResponse) ProtoMessage 

func (*DumpStableVersionToDatastoreResponse) ProtoMessage()

func (*DumpStableVersionToDatastoreResponse) ProtoReflect 

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

func (*DumpStableVersionToDatastoreResponse) Reset 

func (x *DumpStableVersionToDatastoreResponse) Reset()

func (*DumpStableVersionToDatastoreResponse) String 

func (x *DumpStableVersionToDatastoreResponse) String() string

type DutState 

type DutState int32
const (
	DutState_DutStateInvalid   DutState = 0
	DutState_Ready             DutState = 1
	DutState_NeedsCleanup      DutState = 2
	DutState_NeedsRepair       DutState = 3
	DutState_NeedsReset        DutState = 4
	DutState_RepairFailed      DutState = 5
	DutState_NeedsReplacement  DutState = 6
	DutState_NeedsManualRepair DutState = 7
	DutState_NeedsDeploy       DutState = 8
)

func (DutState) Descriptor 

func (DutState) Descriptor() protoreflect.EnumDescriptor

func (DutState) Enum 

func (x DutState) Enum() *DutState

func (DutState) EnumDescriptor deprecated 

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

Deprecated: Use DutState.Descriptor instead.

func (DutState) Number 

func (x DutState) Number() protoreflect.EnumNumber

func (DutState) String 

func (x DutState) String() string

func (DutState) Type 

func (DutState) Type() protoreflect.EnumType

type GetRecoveryVersionRequest 

type GetRecoveryVersionRequest struct {

	// Name of device listed in inventory.
	DeviceName string   `protobuf:"bytes,1,opt,name=device_name,json=deviceName,proto3" json:"device_name,omitempty"`
	DeviceType string   `protobuf:"bytes,5,opt,name=device_type,json=deviceType,proto3" json:"device_type,omitempty"`
	Board      string   `protobuf:"bytes,2,opt,name=board,proto3" json:"board,omitempty"`
	Model      string   `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	Pools      []string `protobuf:"bytes,4,rep,name=pools,proto3" json:"pools,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecoveryVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetRecoveryVersionRequest.ProtoReflect.Descriptor instead.

func (*GetRecoveryVersionRequest) GetBoard 

func (x *GetRecoveryVersionRequest) GetBoard() string

func (*GetRecoveryVersionRequest) GetDeviceName 

func (x *GetRecoveryVersionRequest) GetDeviceName() string

func (*GetRecoveryVersionRequest) GetDeviceType 

func (x *GetRecoveryVersionRequest) GetDeviceType() string

func (*GetRecoveryVersionRequest) GetModel 

func (x *GetRecoveryVersionRequest) GetModel() string

func (*GetRecoveryVersionRequest) GetPools 

func (x *GetRecoveryVersionRequest) GetPools() []string

func (*GetRecoveryVersionRequest) ProtoMessage 

func (*GetRecoveryVersionRequest) ProtoMessage()

func (*GetRecoveryVersionRequest) ProtoReflect 

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

func (*GetRecoveryVersionRequest) Reset 

func (x *GetRecoveryVersionRequest) Reset()

func (*GetRecoveryVersionRequest) String 

func (x *GetRecoveryVersionRequest) String() string

type GetRecoveryVersionResponse 

type GetRecoveryVersionResponse struct {
	Version *lab_platform.StableVersion `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecoveryVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetRecoveryVersionResponse.ProtoReflect.Descriptor instead.

func (*GetRecoveryVersionResponse) GetVersion 

func (x *GetRecoveryVersionResponse) GetVersion() *lab_platform.StableVersion

func (*GetRecoveryVersionResponse) ProtoMessage 

func (*GetRecoveryVersionResponse) ProtoMessage()

func (*GetRecoveryVersionResponse) ProtoReflect 

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

func (*GetRecoveryVersionResponse) Reset 

func (x *GetRecoveryVersionResponse) Reset()

func (*GetRecoveryVersionResponse) String 

func (x *GetRecoveryVersionResponse) String() string

type GetStableVersionRequest 

type GetStableVersionRequest struct {

	// TODO(gregorynisbet): remove support for looking up
	// stable version information by buildTarget + model
	BuildTarget string `protobuf:"bytes,1,opt,name=buildTarget,proto3" json:"buildTarget,omitempty"`
	Model       string `protobuf:"bytes,2,opt,name=model,proto3" json:"model,omitempty"`
	// NOTE: {hostname} and {buildTarget, model} are alternatives
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// SatlabInformationalQuery identifies whether this request is an information-only request coming
	// from the satlab CLI.
	//
	// Supporting `./satlab get-stable-version -model ... -board ...`, which is necessary for users to be
	// able to how the stable versions are configured for their devices, requires us to be able to identify
	// requests for board+model that are intended to be associated with satlab devices.
	//
	// In the normal flow, which looks at hostnames only, we distinguish a satlab or non-satlab request using
	// `heuristics.LooksLikeSatlabDevice(hostname)`.
	SatlabInformationalQuery bool `protobuf:"varint,4,opt,name=satlabInformationalQuery,proto3" json:"satlabInformationalQuery,omitempty"`
	// contains filtered or unexported fields
}

next tag: 5

func (*GetStableVersionRequest) Descriptor deprecated 

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

Deprecated: Use GetStableVersionRequest.ProtoReflect.Descriptor instead.

func (*GetStableVersionRequest) GetBuildTarget 

func (x *GetStableVersionRequest) GetBuildTarget() string

func (*GetStableVersionRequest) GetHostname 

func (x *GetStableVersionRequest) GetHostname() string

func (*GetStableVersionRequest) GetModel 

func (x *GetStableVersionRequest) GetModel() string

func (*GetStableVersionRequest) GetSatlabInformationalQuery 

func (x *GetStableVersionRequest) GetSatlabInformationalQuery() bool

func (*GetStableVersionRequest) ProtoMessage 

func (*GetStableVersionRequest) ProtoMessage()

func (*GetStableVersionRequest) ProtoReflect 

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

func (*GetStableVersionRequest) Reset 

func (x *GetStableVersionRequest) Reset()

func (*GetStableVersionRequest) String 

func (x *GetStableVersionRequest) String() string

type GetStableVersionResponse 

type GetStableVersionResponse struct {
	CrosVersion      string `protobuf:"bytes,1,opt,name=crosVersion,proto3" json:"crosVersion,omitempty"`
	FirmwareVersion  string `protobuf:"bytes,2,opt,name=firmwareVersion,proto3" json:"firmwareVersion,omitempty"`
	FaftVersion      string `protobuf:"bytes,3,opt,name=faftVersion,proto3" json:"faftVersion,omitempty"`
	ServoCrosVersion string `protobuf:"bytes,4,opt,name=servoCrosVersion,proto3" json:"servoCrosVersion,omitempty"`
	// Reason is an explanation of *why* this particular stable version
	// was picked. Possible values are:
	//
	// 1) "host-specific"
	// 2) "board and model"
	//
	// This value is intended to be informational, and either logged or presented to an end user.
	Reason string `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

next tag: 6

func (*GetStableVersionResponse) Descriptor deprecated 

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

Deprecated: Use GetStableVersionResponse.ProtoReflect.Descriptor instead.

func (*GetStableVersionResponse) GetCrosVersion 

func (x *GetStableVersionResponse) GetCrosVersion() string

func (*GetStableVersionResponse) GetFaftVersion 

func (x *GetStableVersionResponse) GetFaftVersion() string

func (*GetStableVersionResponse) GetFirmwareVersion 

func (x *GetStableVersionResponse) GetFirmwareVersion() string

func (*GetStableVersionResponse) GetReason 

func (x *GetStableVersionResponse) GetReason() string

func (*GetStableVersionResponse) GetServoCrosVersion 

func (x *GetStableVersionResponse) GetServoCrosVersion() string

func (*GetStableVersionResponse) ProtoMessage 

func (*GetStableVersionResponse) ProtoMessage()

func (*GetStableVersionResponse) ProtoReflect 

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

func (*GetStableVersionResponse) Reset 

func (x *GetStableVersionResponse) Reset()

func (*GetStableVersionResponse) String 

func (x *GetStableVersionResponse) String() string

type InventoryClient 

type InventoryClient interface {
	// GetStableVersion reads the stable version for a particular DUT from datastore
	//
	// There is intentionally no RPC for overwriting the stable version with arbitrary content.
	GetStableVersion(ctx context.Context, in *GetStableVersionRequest, opts ...grpc.CallOption) (*GetStableVersionResponse, error)
	// GetRecoveryVersion reads the recovery version for a particular board/model/host.
	GetRecoveryVersion(ctx context.Context, in *GetRecoveryVersionRequest, opts ...grpc.CallOption) (*GetRecoveryVersionResponse, error)
	// SetSatlabStableVersion sets the stable version value (for which CrOSSkylabAdmin is the source of truth),
	// for satlab devices only.
	SetSatlabStableVersion(ctx context.Context, in *SetSatlabStableVersionRequest, opts ...grpc.CallOption) (*SetSatlabStableVersionResponse, error)
	// DeleteSatlabStableVersion deletes the satlab stable version value from CrOSSkylabAdmin which is the source of truth
	// for satlab devices only.
	DeleteSatlabStableVersion(ctx context.Context, in *DeleteSatlabStableVersionRequest, opts ...grpc.CallOption) (*DeleteSatlabStableVersionResponse, error)
	// DumpStableVersionToDatastore reads the stable version from the LUCI config file
	// and writes it to datastore.
	DumpStableVersionToDatastore(ctx context.Context, in *DumpStableVersionToDatastoreRequest, opts ...grpc.CallOption) (*DumpStableVersionToDatastoreResponse, error)
}

InventoryClient is the client API for Inventory service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInventoryClient 

func NewInventoryClient(cc grpc.ClientConnInterface) InventoryClient

func NewInventoryPRPCClient 

func NewInventoryPRPCClient(client *prpc.Client) InventoryClient

type InventoryServer 

type InventoryServer interface {
	// GetStableVersion reads the stable version for a particular DUT from datastore
	//
	// There is intentionally no RPC for overwriting the stable version with arbitrary content.
	GetStableVersion(context.Context, *GetStableVersionRequest) (*GetStableVersionResponse, error)
	// GetRecoveryVersion reads the recovery version for a particular board/model/host.
	GetRecoveryVersion(context.Context, *GetRecoveryVersionRequest) (*GetRecoveryVersionResponse, error)
	// SetSatlabStableVersion sets the stable version value (for which CrOSSkylabAdmin is the source of truth),
	// for satlab devices only.
	SetSatlabStableVersion(context.Context, *SetSatlabStableVersionRequest) (*SetSatlabStableVersionResponse, error)
	// DeleteSatlabStableVersion deletes the satlab stable version value from CrOSSkylabAdmin which is the source of truth
	// for satlab devices only.
	DeleteSatlabStableVersion(context.Context, *DeleteSatlabStableVersionRequest) (*DeleteSatlabStableVersionResponse, error)
	// DumpStableVersionToDatastore reads the stable version from the LUCI config file
	// and writes it to datastore.
	DumpStableVersionToDatastore(context.Context, *DumpStableVersionToDatastoreRequest) (*DumpStableVersionToDatastoreResponse, error)
}

InventoryServer is the server API for Inventory service.

type MockInventoryClient 

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

MockInventoryClient is a mock of InventoryClient interface.

func NewMockInventoryClient 

func NewMockInventoryClient(ctrl *gomock.Controller) *MockInventoryClient

NewMockInventoryClient creates a new mock instance.

func (*MockInventoryClient) DeleteSatlabStableVersion 

func (m *MockInventoryClient) DeleteSatlabStableVersion(ctx context.Context, in *DeleteSatlabStableVersionRequest, opts ...grpc.CallOption) (*DeleteSatlabStableVersionResponse, error)

DeleteSatlabStableVersion mocks base method.

func (*MockInventoryClient) DumpStableVersionToDatastore 

func (m *MockInventoryClient) DumpStableVersionToDatastore(ctx context.Context, in *DumpStableVersionToDatastoreRequest, opts ...grpc.CallOption) (*DumpStableVersionToDatastoreResponse, error)

DumpStableVersionToDatastore mocks base method.

func (*MockInventoryClient) EXPECT 

func (m *MockInventoryClient) EXPECT() *MockInventoryClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInventoryClient) GetRecoveryVersion 

func (m *MockInventoryClient) GetRecoveryVersion(ctx context.Context, in *GetRecoveryVersionRequest, opts ...grpc.CallOption) (*GetRecoveryVersionResponse, error)

GetRecoveryVersion mocks base method.

func (*MockInventoryClient) GetStableVersion 

func (m *MockInventoryClient) GetStableVersion(ctx context.Context, in *GetStableVersionRequest, opts ...grpc.CallOption) (*GetStableVersionResponse, error)

GetStableVersion mocks base method.

func (*MockInventoryClient) SetSatlabStableVersion 

func (m *MockInventoryClient) SetSatlabStableVersion(ctx context.Context, in *SetSatlabStableVersionRequest, opts ...grpc.CallOption) (*SetSatlabStableVersionResponse, error)

SetSatlabStableVersion mocks base method.

type MockInventoryClientMockRecorder 

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

MockInventoryClientMockRecorder is the mock recorder for MockInventoryClient.

func (*MockInventoryClientMockRecorder) DeleteSatlabStableVersion 

func (mr *MockInventoryClientMockRecorder) DeleteSatlabStableVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call

DeleteSatlabStableVersion indicates an expected call of DeleteSatlabStableVersion.

func (*MockInventoryClientMockRecorder) DumpStableVersionToDatastore 

func (mr *MockInventoryClientMockRecorder) DumpStableVersionToDatastore(ctx, in interface{}, opts ...interface{}) *gomock.Call

DumpStableVersionToDatastore indicates an expected call of DumpStableVersionToDatastore.

func (*MockInventoryClientMockRecorder) GetRecoveryVersion 

func (mr *MockInventoryClientMockRecorder) GetRecoveryVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetRecoveryVersion indicates an expected call of GetRecoveryVersion.

func (*MockInventoryClientMockRecorder) GetStableVersion 

func (mr *MockInventoryClientMockRecorder) GetStableVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetStableVersion indicates an expected call of GetStableVersion.

func (*MockInventoryClientMockRecorder) SetSatlabStableVersion 

func (mr *MockInventoryClientMockRecorder) SetSatlabStableVersion(ctx, in interface{}, opts ...interface{}) *gomock.Call

SetSatlabStableVersion indicates an expected call of SetSatlabStableVersion.

type MockInventoryServer 

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

MockInventoryServer is a mock of InventoryServer interface.

func NewMockInventoryServer 

func NewMockInventoryServer(ctrl *gomock.Controller) *MockInventoryServer

NewMockInventoryServer creates a new mock instance.

func (*MockInventoryServer) DeleteSatlabStableVersion 

func (m *MockInventoryServer) DeleteSatlabStableVersion(arg0 context.Context, arg1 *DeleteSatlabStableVersionRequest) (*DeleteSatlabStableVersionResponse, error)

DeleteSatlabStableVersion mocks base method.

func (*MockInventoryServer) DumpStableVersionToDatastore 

func (m *MockInventoryServer) DumpStableVersionToDatastore(arg0 context.Context, arg1 *DumpStableVersionToDatastoreRequest) (*DumpStableVersionToDatastoreResponse, error)

DumpStableVersionToDatastore mocks base method.

func (*MockInventoryServer) EXPECT 

func (m *MockInventoryServer) EXPECT() *MockInventoryServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockInventoryServer) GetRecoveryVersion 

func (m *MockInventoryServer) GetRecoveryVersion(arg0 context.Context, arg1 *GetRecoveryVersionRequest) (*GetRecoveryVersionResponse, error)

GetRecoveryVersion mocks base method.

func (*MockInventoryServer) GetStableVersion 

func (m *MockInventoryServer) GetStableVersion(arg0 context.Context, arg1 *GetStableVersionRequest) (*GetStableVersionResponse, error)

GetStableVersion mocks base method.

func (*MockInventoryServer) SetSatlabStableVersion 

func (m *MockInventoryServer) SetSatlabStableVersion(arg0 context.Context, arg1 *SetSatlabStableVersionRequest) (*SetSatlabStableVersionResponse, error)

SetSatlabStableVersion mocks base method.

type MockInventoryServerMockRecorder 

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

MockInventoryServerMockRecorder is the mock recorder for MockInventoryServer.

func (*MockInventoryServerMockRecorder) DeleteSatlabStableVersion 

func (mr *MockInventoryServerMockRecorder) DeleteSatlabStableVersion(arg0, arg1 interface{}) *gomock.Call

DeleteSatlabStableVersion indicates an expected call of DeleteSatlabStableVersion.

func (*MockInventoryServerMockRecorder) DumpStableVersionToDatastore 

func (mr *MockInventoryServerMockRecorder) DumpStableVersionToDatastore(arg0, arg1 interface{}) *gomock.Call

DumpStableVersionToDatastore indicates an expected call of DumpStableVersionToDatastore.

func (*MockInventoryServerMockRecorder) GetRecoveryVersion 

func (mr *MockInventoryServerMockRecorder) GetRecoveryVersion(arg0, arg1 interface{}) *gomock.Call

GetRecoveryVersion indicates an expected call of GetRecoveryVersion.

func (*MockInventoryServerMockRecorder) GetStableVersion 

func (mr *MockInventoryServerMockRecorder) GetStableVersion(arg0, arg1 interface{}) *gomock.Call

GetStableVersion indicates an expected call of GetStableVersion.

func (*MockInventoryServerMockRecorder) SetSatlabStableVersion 

func (mr *MockInventoryServerMockRecorder) SetSatlabStableVersion(arg0, arg1 interface{}) *gomock.Call

SetSatlabStableVersion indicates an expected call of SetSatlabStableVersion.

type MockTrackerClient 

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

MockTrackerClient is a mock of TrackerClient interface.

func NewMockTrackerClient 

func NewMockTrackerClient(ctrl *gomock.Controller) *MockTrackerClient

NewMockTrackerClient creates a new mock instance.

func (*MockTrackerClient) EXPECT 

func (m *MockTrackerClient) EXPECT() *MockTrackerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTrackerClient) PushBotsForAdminAuditTasks 

func (m *MockTrackerClient) PushBotsForAdminAuditTasks(ctx context.Context, in *PushBotsForAdminAuditTasksRequest, opts ...grpc.CallOption) (*PushBotsForAdminAuditTasksResponse, error)

PushBotsForAdminAuditTasks mocks base method.

func (*MockTrackerClient) PushBotsForAdminTasks 

func (m *MockTrackerClient) PushBotsForAdminTasks(ctx context.Context, in *PushBotsForAdminTasksRequest, opts ...grpc.CallOption) (*PushBotsForAdminTasksResponse, error)

PushBotsForAdminTasks mocks base method.

func (*MockTrackerClient) PushRepairJobsForLabstations 

func (m *MockTrackerClient) PushRepairJobsForLabstations(ctx context.Context, in *PushRepairJobsForLabstationsRequest, opts ...grpc.CallOption) (*PushRepairJobsForLabstationsResponse, error)

PushRepairJobsForLabstations mocks base method.

func (*MockTrackerClient) ReportBots 

func (m *MockTrackerClient) ReportBots(ctx context.Context, in *ReportBotsRequest, opts ...grpc.CallOption) (*ReportBotsResponse, error)

ReportBots mocks base method.

type MockTrackerClientMockRecorder 

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

MockTrackerClientMockRecorder is the mock recorder for MockTrackerClient.

func (*MockTrackerClientMockRecorder) PushBotsForAdminAuditTasks 

func (mr *MockTrackerClientMockRecorder) PushBotsForAdminAuditTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

PushBotsForAdminAuditTasks indicates an expected call of PushBotsForAdminAuditTasks.

func (*MockTrackerClientMockRecorder) PushBotsForAdminTasks 

func (mr *MockTrackerClientMockRecorder) PushBotsForAdminTasks(ctx, in interface{}, opts ...interface{}) *gomock.Call

PushBotsForAdminTasks indicates an expected call of PushBotsForAdminTasks.

func (*MockTrackerClientMockRecorder) PushRepairJobsForLabstations 

func (mr *MockTrackerClientMockRecorder) PushRepairJobsForLabstations(ctx, in interface{}, opts ...interface{}) *gomock.Call

PushRepairJobsForLabstations indicates an expected call of PushRepairJobsForLabstations.

func (*MockTrackerClientMockRecorder) ReportBots 

func (mr *MockTrackerClientMockRecorder) ReportBots(ctx, in interface{}, opts ...interface{}) *gomock.Call

ReportBots indicates an expected call of ReportBots.

type MockTrackerServer 

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

MockTrackerServer is a mock of TrackerServer interface.

func NewMockTrackerServer 

func NewMockTrackerServer(ctrl *gomock.Controller) *MockTrackerServer

NewMockTrackerServer creates a new mock instance.

func (*MockTrackerServer) EXPECT 

func (m *MockTrackerServer) EXPECT() *MockTrackerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTrackerServer) PushBotsForAdminAuditTasks 

func (m *MockTrackerServer) PushBotsForAdminAuditTasks(arg0 context.Context, arg1 *PushBotsForAdminAuditTasksRequest) (*PushBotsForAdminAuditTasksResponse, error)

PushBotsForAdminAuditTasks mocks base method.

func (*MockTrackerServer) PushBotsForAdminTasks 

func (m *MockTrackerServer) PushBotsForAdminTasks(arg0 context.Context, arg1 *PushBotsForAdminTasksRequest) (*PushBotsForAdminTasksResponse, error)

PushBotsForAdminTasks mocks base method.

func (*MockTrackerServer) PushRepairJobsForLabstations 

func (m *MockTrackerServer) PushRepairJobsForLabstations(arg0 context.Context, arg1 *PushRepairJobsForLabstationsRequest) (*PushRepairJobsForLabstationsResponse, error)

PushRepairJobsForLabstations mocks base method.

func (*MockTrackerServer) ReportBots 

func (m *MockTrackerServer) ReportBots(arg0 context.Context, arg1 *ReportBotsRequest) (*ReportBotsResponse, error)

ReportBots mocks base method.

type MockTrackerServerMockRecorder 

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

MockTrackerServerMockRecorder is the mock recorder for MockTrackerServer.

func (*MockTrackerServerMockRecorder) PushBotsForAdminAuditTasks 

func (mr *MockTrackerServerMockRecorder) PushBotsForAdminAuditTasks(arg0, arg1 interface{}) *gomock.Call

PushBotsForAdminAuditTasks indicates an expected call of PushBotsForAdminAuditTasks.

func (*MockTrackerServerMockRecorder) PushBotsForAdminTasks 

func (mr *MockTrackerServerMockRecorder) PushBotsForAdminTasks(arg0, arg1 interface{}) *gomock.Call

PushBotsForAdminTasks indicates an expected call of PushBotsForAdminTasks.

func (*MockTrackerServerMockRecorder) PushRepairJobsForLabstations 

func (mr *MockTrackerServerMockRecorder) PushRepairJobsForLabstations(arg0, arg1 interface{}) *gomock.Call

PushRepairJobsForLabstations indicates an expected call of PushRepairJobsForLabstations.

func (*MockTrackerServerMockRecorder) ReportBots 

func (mr *MockTrackerServerMockRecorder) ReportBots(arg0, arg1 interface{}) *gomock.Call

ReportBots indicates an expected call of ReportBots.

type MockisDeleteSatlabStableVersionRequest_Strategy 

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

MockisDeleteSatlabStableVersionRequest_Strategy is a mock of isDeleteSatlabStableVersionRequest_Strategy interface.

func NewMockisDeleteSatlabStableVersionRequest_Strategy 

func NewMockisDeleteSatlabStableVersionRequest_Strategy(ctrl *gomock.Controller) *MockisDeleteSatlabStableVersionRequest_Strategy

NewMockisDeleteSatlabStableVersionRequest_Strategy creates a new mock instance.

func (*MockisDeleteSatlabStableVersionRequest_Strategy) EXPECT 

func (m *MockisDeleteSatlabStableVersionRequest_Strategy) EXPECT() *MockisDeleteSatlabStableVersionRequest_StrategyMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockisDeleteSatlabStableVersionRequest_StrategyMockRecorder 

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

MockisDeleteSatlabStableVersionRequest_StrategyMockRecorder is the mock recorder for MockisDeleteSatlabStableVersionRequest_Strategy.

type MockisSetSatlabStableVersionRequest_Strategy 

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

MockisSetSatlabStableVersionRequest_Strategy is a mock of isSetSatlabStableVersionRequest_Strategy interface.

func NewMockisSetSatlabStableVersionRequest_Strategy 

func NewMockisSetSatlabStableVersionRequest_Strategy(ctrl *gomock.Controller) *MockisSetSatlabStableVersionRequest_Strategy

NewMockisSetSatlabStableVersionRequest_Strategy creates a new mock instance.

func (*MockisSetSatlabStableVersionRequest_Strategy) EXPECT 

func (m *MockisSetSatlabStableVersionRequest_Strategy) EXPECT() *MockisSetSatlabStableVersionRequest_StrategyMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockisSetSatlabStableVersionRequest_StrategyMockRecorder 

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

MockisSetSatlabStableVersionRequest_StrategyMockRecorder is the mock recorder for MockisSetSatlabStableVersionRequest_Strategy.

type PushBotsForAdminAuditTasksRequest 

type PushBotsForAdminAuditTasksRequest struct {
	Task AuditTask `protobuf:"varint,1,opt,name=task,proto3,enum=crosskylabadmin.fleet.AuditTask" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*PushBotsForAdminAuditTasksRequest) Descriptor deprecated 

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

Deprecated: Use PushBotsForAdminAuditTasksRequest.ProtoReflect.Descriptor instead.

func (*PushBotsForAdminAuditTasksRequest) GetTask 

func (x *PushBotsForAdminAuditTasksRequest) GetTask() AuditTask

func (*PushBotsForAdminAuditTasksRequest) ProtoMessage 

func (*PushBotsForAdminAuditTasksRequest) ProtoMessage()

func (*PushBotsForAdminAuditTasksRequest) ProtoReflect 

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

func (*PushBotsForAdminAuditTasksRequest) Reset 

func (x *PushBotsForAdminAuditTasksRequest) Reset()

func (*PushBotsForAdminAuditTasksRequest) String 

func (x *PushBotsForAdminAuditTasksRequest) String() string

type PushBotsForAdminAuditTasksResponse 

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

func (*PushBotsForAdminAuditTasksResponse) Descriptor deprecated 

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

Deprecated: Use PushBotsForAdminAuditTasksResponse.ProtoReflect.Descriptor instead.

func (*PushBotsForAdminAuditTasksResponse) ProtoMessage 

func (*PushBotsForAdminAuditTasksResponse) ProtoMessage()

func (*PushBotsForAdminAuditTasksResponse) ProtoReflect 

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

func (*PushBotsForAdminAuditTasksResponse) Reset 

func (x *PushBotsForAdminAuditTasksResponse) Reset()

func (*PushBotsForAdminAuditTasksResponse) String 

func (x *PushBotsForAdminAuditTasksResponse) String() string

type PushBotsForAdminTasksRequest 

type PushBotsForAdminTasksRequest struct {
	TargetDutState     DutState                                        `` /* 142-byte string literal not displayed */
	SchedulingStrategy PushBotsForAdminTasksRequest_SchedulingStrategy `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

PushBotsForAdminTasksRequest is used for an internal RPC that looks at the existing bots and determines which ones to repair or audit or perform some other admin task on.

It takes the states for the DUTs we're looking at (for example "needs_repair" or "ready" or "repair_failed") as well as a strategy, which is used to control the smart-scheduling feature.

func (*PushBotsForAdminTasksRequest) Descriptor deprecated 

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

Deprecated: Use PushBotsForAdminTasksRequest.ProtoReflect.Descriptor instead.

func (*PushBotsForAdminTasksRequest) GetSchedulingStrategy 

func (x *PushBotsForAdminTasksRequest) GetSchedulingStrategy() PushBotsForAdminTasksRequest_SchedulingStrategy

func (*PushBotsForAdminTasksRequest) GetTargetDutState 

func (x *PushBotsForAdminTasksRequest) GetTargetDutState() DutState

func (*PushBotsForAdminTasksRequest) ProtoMessage 

func (*PushBotsForAdminTasksRequest) ProtoMessage()

func (*PushBotsForAdminTasksRequest) ProtoReflect 

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

func (*PushBotsForAdminTasksRequest) Reset 

func (x *PushBotsForAdminTasksRequest) Reset()

func (*PushBotsForAdminTasksRequest) String 

func (x *PushBotsForAdminTasksRequest) String() string

type PushBotsForAdminTasksRequest_SchedulingStrategy 

type PushBotsForAdminTasksRequest_SchedulingStrategy int32
const (
	// DefaultSchedulingStrategy means no smart scheduling. We only use the swarming state and the cron mechanism in GCP.
	PushBotsForAdminTasksRequest_DefaultSchedulingStrategy PushBotsForAdminTasksRequest_SchedulingStrategy = 0
	// LabstationRebootStrategy means that we repair the DUTs connected to a labstation after the labstation has rebooted.
	PushBotsForAdminTasksRequest_LabstationRebootStrategy PushBotsForAdminTasksRequest_SchedulingStrategy = 1
)

func (PushBotsForAdminTasksRequest_SchedulingStrategy) Descriptor 

func (PushBotsForAdminTasksRequest_SchedulingStrategy) Descriptor() protoreflect.EnumDescriptor

func (PushBotsForAdminTasksRequest_SchedulingStrategy) Enum 

func (x PushBotsForAdminTasksRequest_SchedulingStrategy) Enum() *PushBotsForAdminTasksRequest_SchedulingStrategy

func (PushBotsForAdminTasksRequest_SchedulingStrategy) EnumDescriptor deprecated 

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

Deprecated: Use PushBotsForAdminTasksRequest_SchedulingStrategy.Descriptor instead.

func (PushBotsForAdminTasksRequest_SchedulingStrategy) Number 

func (x PushBotsForAdminTasksRequest_SchedulingStrategy) Number() protoreflect.EnumNumber

func (PushBotsForAdminTasksRequest_SchedulingStrategy) String 

func (x PushBotsForAdminTasksRequest_SchedulingStrategy) String() string

func (PushBotsForAdminTasksRequest_SchedulingStrategy) Type 

func (PushBotsForAdminTasksRequest_SchedulingStrategy) Type() protoreflect.EnumType

type PushBotsForAdminTasksResponse 

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

func (*PushBotsForAdminTasksResponse) Descriptor deprecated 

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

Deprecated: Use PushBotsForAdminTasksResponse.ProtoReflect.Descriptor instead.

func (*PushBotsForAdminTasksResponse) ProtoMessage 

func (*PushBotsForAdminTasksResponse) ProtoMessage()

func (*PushBotsForAdminTasksResponse) ProtoReflect 

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

func (*PushBotsForAdminTasksResponse) Reset 

func (x *PushBotsForAdminTasksResponse) Reset()

func (*PushBotsForAdminTasksResponse) String 

func (x *PushBotsForAdminTasksResponse) String() string

type PushRepairJobsForLabstationsRequest 

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

func (*PushRepairJobsForLabstationsRequest) Descriptor deprecated 

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

Deprecated: Use PushRepairJobsForLabstationsRequest.ProtoReflect.Descriptor instead.

func (*PushRepairJobsForLabstationsRequest) ProtoMessage 

func (*PushRepairJobsForLabstationsRequest) ProtoMessage()

func (*PushRepairJobsForLabstationsRequest) ProtoReflect 

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

func (*PushRepairJobsForLabstationsRequest) Reset 

func (x *PushRepairJobsForLabstationsRequest) Reset()

func (*PushRepairJobsForLabstationsRequest) String 

func (x *PushRepairJobsForLabstationsRequest) String() string

type PushRepairJobsForLabstationsResponse 

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

func (*PushRepairJobsForLabstationsResponse) Descriptor deprecated 

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

Deprecated: Use PushRepairJobsForLabstationsResponse.ProtoReflect.Descriptor instead.

func (*PushRepairJobsForLabstationsResponse) ProtoMessage 

func (*PushRepairJobsForLabstationsResponse) ProtoMessage()

func (*PushRepairJobsForLabstationsResponse) ProtoReflect 

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

func (*PushRepairJobsForLabstationsResponse) Reset 

func (x *PushRepairJobsForLabstationsResponse) Reset()

func (*PushRepairJobsForLabstationsResponse) String 

func (x *PushRepairJobsForLabstationsResponse) String() string

type ReportBotsRequest 

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

func (*ReportBotsRequest) Descriptor deprecated 

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

Deprecated: Use ReportBotsRequest.ProtoReflect.Descriptor instead.

func (*ReportBotsRequest) ProtoMessage 

func (*ReportBotsRequest) ProtoMessage()

func (*ReportBotsRequest) ProtoReflect 

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

func (*ReportBotsRequest) Reset 

func (x *ReportBotsRequest) Reset()

func (*ReportBotsRequest) String 

func (x *ReportBotsRequest) String() string

type ReportBotsResponse 

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

func (*ReportBotsResponse) Descriptor deprecated 

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

Deprecated: Use ReportBotsResponse.ProtoReflect.Descriptor instead.

func (*ReportBotsResponse) ProtoMessage 

func (*ReportBotsResponse) ProtoMessage()

func (*ReportBotsResponse) ProtoReflect 

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

func (*ReportBotsResponse) Reset 

func (x *ReportBotsResponse) Reset()

func (*ReportBotsResponse) String 

func (x *ReportBotsResponse) String() string

type SatlabBoardAndModelStrategy 

type SatlabBoardAndModelStrategy struct {
	SatlabID string `protobuf:"bytes,1,opt,name=satlabID,proto3" json:"satlabID,omitempty"`
	Board    string `protobuf:"bytes,2,opt,name=board,proto3" json:"board,omitempty"`
	Model    string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

SatlabBoardAndModelStrategy is a combination of keys that define a stable version entry for Satlab devices. This kind of entry is scoped to a board and model. The satlab ID is requested but currently ignored.

func (*SatlabBoardAndModelStrategy) Descriptor deprecated 

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

Deprecated: Use SatlabBoardAndModelStrategy.ProtoReflect.Descriptor instead.

func (*SatlabBoardAndModelStrategy) GetBoard 

func (x *SatlabBoardAndModelStrategy) GetBoard() string

func (*SatlabBoardAndModelStrategy) GetModel 

func (x *SatlabBoardAndModelStrategy) GetModel() string

func (*SatlabBoardAndModelStrategy) GetSatlabID 

func (x *SatlabBoardAndModelStrategy) GetSatlabID() string

func (*SatlabBoardAndModelStrategy) ProtoMessage 

func (*SatlabBoardAndModelStrategy) ProtoMessage()

func (*SatlabBoardAndModelStrategy) ProtoReflect 

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

func (*SatlabBoardAndModelStrategy) Reset 

func (x *SatlabBoardAndModelStrategy) Reset()

func (*SatlabBoardAndModelStrategy) String 

func (x *SatlabBoardAndModelStrategy) String() string

type SatlabBoardModelDeletionCriterion 

type SatlabBoardModelDeletionCriterion struct {
	SatlabID string `protobuf:"bytes,1,opt,name=satlabID,proto3" json:"satlabID,omitempty"`
	Board    string `protobuf:"bytes,2,opt,name=board,proto3" json:"board,omitempty"`
	Model    string `protobuf:"bytes,3,opt,name=model,proto3" json:"model,omitempty"`
	// contains filtered or unexported fields
}

SatlabBoardModelDeletionCriterion is similar to SatlabBoardAndModelStrategy, but 

a) All the fields must be provided for the request to be well-formed.
b) We guarantee that there will be exactly one best match at all times.

func (*SatlabBoardModelDeletionCriterion) Descriptor deprecated 

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

Deprecated: Use SatlabBoardModelDeletionCriterion.ProtoReflect.Descriptor instead.

func (*SatlabBoardModelDeletionCriterion) GetBoard 

func (x *SatlabBoardModelDeletionCriterion) GetBoard() string

func (*SatlabBoardModelDeletionCriterion) GetModel 

func (x *SatlabBoardModelDeletionCriterion) GetModel() string

func (*SatlabBoardModelDeletionCriterion) GetSatlabID 

func (x *SatlabBoardModelDeletionCriterion) GetSatlabID() string

func (*SatlabBoardModelDeletionCriterion) ProtoMessage 

func (*SatlabBoardModelDeletionCriterion) ProtoMessage()

func (*SatlabBoardModelDeletionCriterion) ProtoReflect 

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

func (*SatlabBoardModelDeletionCriterion) Reset 

func (x *SatlabBoardModelDeletionCriterion) Reset()

func (*SatlabBoardModelDeletionCriterion) String 

func (x *SatlabBoardModelDeletionCriterion) String() string

type SatlabHostnameDeletionCriterion 

type SatlabHostnameDeletionCriterion struct {
	SatlabID string `protobuf:"bytes,1,opt,name=satlabID,proto3" json:"satlabID,omitempty"`
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

SatlabHostnameDeletionCriterion is similar to SatlabHostnameStrategy, but 

a) All the fields must be provided for the request to be well-formed.
b) We guarantee that there will be exactly one best match at all times.

func (*SatlabHostnameDeletionCriterion) Descriptor deprecated 

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

Deprecated: Use SatlabHostnameDeletionCriterion.ProtoReflect.Descriptor instead.

func (*SatlabHostnameDeletionCriterion) GetHostname 

func (x *SatlabHostnameDeletionCriterion) GetHostname() string

func (*SatlabHostnameDeletionCriterion) GetSatlabID 

func (x *SatlabHostnameDeletionCriterion) GetSatlabID() string

func (*SatlabHostnameDeletionCriterion) ProtoMessage 

func (*SatlabHostnameDeletionCriterion) ProtoMessage()

func (*SatlabHostnameDeletionCriterion) ProtoReflect 

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

func (*SatlabHostnameDeletionCriterion) Reset 

func (x *SatlabHostnameDeletionCriterion) Reset()

func (*SatlabHostnameDeletionCriterion) String 

func (x *SatlabHostnameDeletionCriterion) String() string

type SatlabHostnameStrategy 

type SatlabHostnameStrategy struct {
	SatlabID string `protobuf:"bytes,1,opt,name=satlabID,proto3" json:"satlabID,omitempty"`
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

SatlabHostnameStrategy is the key used for a Satlab stable version entry that is scoped to a specific host. We request the satlab ID in addition to the hostname for future-proofing reasons.

func (*SatlabHostnameStrategy) Descriptor deprecated 

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

Deprecated: Use SatlabHostnameStrategy.ProtoReflect.Descriptor instead.

func (*SatlabHostnameStrategy) GetHostname 

func (x *SatlabHostnameStrategy) GetHostname() string

func (*SatlabHostnameStrategy) GetSatlabID 

func (x *SatlabHostnameStrategy) GetSatlabID() string

func (*SatlabHostnameStrategy) ProtoMessage 

func (*SatlabHostnameStrategy) ProtoMessage()

func (*SatlabHostnameStrategy) ProtoReflect 

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

func (*SatlabHostnameStrategy) Reset 

func (x *SatlabHostnameStrategy) Reset()

func (*SatlabHostnameStrategy) String 

func (x *SatlabHostnameStrategy) String() string

type SetSatlabStableVersionRequest 

type SetSatlabStableVersionRequest struct {

	// Types that are valid to be assigned to Strategy:
	//
	//	*SetSatlabStableVersionRequest_SatlabBoardAndModelStrategy
	//	*SetSatlabStableVersionRequest_SatlabHostnameStrategy
	Strategy        isSetSatlabStableVersionRequest_Strategy `protobuf_oneof:"strategy"`
	CrosVersion     string                                   `protobuf:"bytes,3,opt,name=crosVersion,proto3" json:"crosVersion,omitempty"`
	FirmwareVersion string                                   `protobuf:"bytes,4,opt,name=firmwareVersion,proto3" json:"firmwareVersion,omitempty"`
	// This is the same thing as the "faftVersion", but it uses the newer terminology.
	FirmwareImage string `protobuf:"bytes,5,opt,name=firmwareImage,proto3" json:"firmwareImage,omitempty"`
	// contains filtered or unexported fields
}

func (*SetSatlabStableVersionRequest) Descriptor deprecated 

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

Deprecated: Use SetSatlabStableVersionRequest.ProtoReflect.Descriptor instead.

func (*SetSatlabStableVersionRequest) GetCrosVersion 

func (x *SetSatlabStableVersionRequest) GetCrosVersion() string

func (*SetSatlabStableVersionRequest) GetFirmwareImage 

func (x *SetSatlabStableVersionRequest) GetFirmwareImage() string

func (*SetSatlabStableVersionRequest) GetFirmwareVersion 

func (x *SetSatlabStableVersionRequest) GetFirmwareVersion() string

func (*SetSatlabStableVersionRequest) GetSatlabBoardAndModelStrategy 

func (x *SetSatlabStableVersionRequest) GetSatlabBoardAndModelStrategy() *SatlabBoardAndModelStrategy

func (*SetSatlabStableVersionRequest) GetSatlabHostnameStrategy 

func (x *SetSatlabStableVersionRequest) GetSatlabHostnameStrategy() *SatlabHostnameStrategy

func (*SetSatlabStableVersionRequest) GetStrategy 

func (x *SetSatlabStableVersionRequest) GetStrategy() isSetSatlabStableVersionRequest_Strategy

func (*SetSatlabStableVersionRequest) ProtoMessage 

func (*SetSatlabStableVersionRequest) ProtoMessage()

func (*SetSatlabStableVersionRequest) ProtoReflect 

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

func (*SetSatlabStableVersionRequest) Reset 

func (x *SetSatlabStableVersionRequest) Reset()

func (*SetSatlabStableVersionRequest) String 

func (x *SetSatlabStableVersionRequest) String() string

type SetSatlabStableVersionRequest_SatlabBoardAndModelStrategy 

type SetSatlabStableVersionRequest_SatlabBoardAndModelStrategy struct {
	SatlabBoardAndModelStrategy *SatlabBoardAndModelStrategy `protobuf:"bytes,1,opt,name=satlabBoardAndModelStrategy,proto3,oneof"`
}

type SetSatlabStableVersionRequest_SatlabHostnameStrategy 

type SetSatlabStableVersionRequest_SatlabHostnameStrategy struct {
	SatlabHostnameStrategy *SatlabHostnameStrategy `protobuf:"bytes,2,opt,name=satlabHostnameStrategy,proto3,oneof"`
}

type SetSatlabStableVersionResponse 

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

func (*SetSatlabStableVersionResponse) Descriptor deprecated 

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

Deprecated: Use SetSatlabStableVersionResponse.ProtoReflect.Descriptor instead.

func (*SetSatlabStableVersionResponse) ProtoMessage 

func (*SetSatlabStableVersionResponse) ProtoMessage()

func (*SetSatlabStableVersionResponse) ProtoReflect 

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

func (*SetSatlabStableVersionResponse) Reset 

func (x *SetSatlabStableVersionResponse) Reset()

func (*SetSatlabStableVersionResponse) String 

func (x *SetSatlabStableVersionResponse) String() string

type TrackerClient 

type TrackerClient interface {
	// Filter out and queue the CrOS bots that require admin tasks Repair and
	// Reset.
	PushBotsForAdminTasks(ctx context.Context, in *PushBotsForAdminTasksRequest, opts ...grpc.CallOption) (*PushBotsForAdminTasksResponse, error)
	// Filter out and queue the labstation bots that require admin tasks Repair.
	PushRepairJobsForLabstations(ctx context.Context, in *PushRepairJobsForLabstationsRequest, opts ...grpc.CallOption) (*PushRepairJobsForLabstationsResponse, error)
	// Report bots metrics.
	ReportBots(ctx context.Context, in *ReportBotsRequest, opts ...grpc.CallOption) (*ReportBotsResponse, error)
	// Filter out and queue the CrOS bots to run admin tasks Audit.
	PushBotsForAdminAuditTasks(ctx context.Context, in *PushBotsForAdminAuditTasksRequest, opts ...grpc.CallOption) (*PushBotsForAdminAuditTasksResponse, error)
}

TrackerClient is the client API for Tracker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTrackerClient 

func NewTrackerClient(cc grpc.ClientConnInterface) TrackerClient

func NewTrackerPRPCClient 

func NewTrackerPRPCClient(client *prpc.Client) TrackerClient

type TrackerServer 

type TrackerServer interface {
	// Filter out and queue the CrOS bots that require admin tasks Repair and
	// Reset.
	PushBotsForAdminTasks(context.Context, *PushBotsForAdminTasksRequest) (*PushBotsForAdminTasksResponse, error)
	// Filter out and queue the labstation bots that require admin tasks Repair.
	PushRepairJobsForLabstations(context.Context, *PushRepairJobsForLabstationsRequest) (*PushRepairJobsForLabstationsResponse, error)
	// Report bots metrics.
	ReportBots(context.Context, *ReportBotsRequest) (*ReportBotsResponse, error)
	// Filter out and queue the CrOS bots to run admin tasks Audit.
	PushBotsForAdminAuditTasks(context.Context, *PushBotsForAdminAuditTasksRequest) (*PushBotsForAdminAuditTasksResponse, error)
}

TrackerServer is the server API for Tracker service.

type UnimplementedInventoryServer 

type UnimplementedInventoryServer struct {
}

UnimplementedInventoryServer can be embedded to have forward compatible implementations.

func (*UnimplementedInventoryServer) DeleteSatlabStableVersion 

func (*UnimplementedInventoryServer) DeleteSatlabStableVersion(context.Context, *DeleteSatlabStableVersionRequest) (*DeleteSatlabStableVersionResponse, error)

func (*UnimplementedInventoryServer) DumpStableVersionToDatastore 

func (*UnimplementedInventoryServer) DumpStableVersionToDatastore(context.Context, *DumpStableVersionToDatastoreRequest) (*DumpStableVersionToDatastoreResponse, error)

func (*UnimplementedInventoryServer) GetRecoveryVersion 

func (*UnimplementedInventoryServer) GetRecoveryVersion(context.Context, *GetRecoveryVersionRequest) (*GetRecoveryVersionResponse, error)

func (*UnimplementedInventoryServer) GetStableVersion 

func (*UnimplementedInventoryServer) GetStableVersion(context.Context, *GetStableVersionRequest) (*GetStableVersionResponse, error)

func (*UnimplementedInventoryServer) SetSatlabStableVersion 

func (*UnimplementedInventoryServer) SetSatlabStableVersion(context.Context, *SetSatlabStableVersionRequest) (*SetSatlabStableVersionResponse, error)

type UnimplementedTrackerServer 

type UnimplementedTrackerServer struct {
}

UnimplementedTrackerServer can be embedded to have forward compatible implementations.

func (*UnimplementedTrackerServer) PushBotsForAdminAuditTasks 

func (*UnimplementedTrackerServer) PushBotsForAdminAuditTasks(context.Context, *PushBotsForAdminAuditTasksRequest) (*PushBotsForAdminAuditTasksResponse, error)

func (*UnimplementedTrackerServer) PushBotsForAdminTasks 

func (*UnimplementedTrackerServer) PushBotsForAdminTasks(context.Context, *PushBotsForAdminTasksRequest) (*PushBotsForAdminTasksResponse, error)

func (*UnimplementedTrackerServer) PushRepairJobsForLabstations 

func (*UnimplementedTrackerServer) PushRepairJobsForLabstations(context.Context, *PushRepairJobsForLabstationsRequest) (*PushRepairJobsForLabstationsResponse, error)

func (*UnimplementedTrackerServer) ReportBots 

func (*UnimplementedTrackerServer) ReportBots(context.Context, *ReportBotsRequest) (*ReportBotsResponse, 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.