Documentation
¶
Overview ¶
Package api contains the drone queen service API.
Index ¶
- Variables
- func FileDescriptorSet() *descriptorpb.FileDescriptorSet
- func RegisterDroneServer(s prpc.Registrar, srv DroneServer)
- func RegisterInspectServer(s prpc.Registrar, srv InspectServer)
- func RegisterInventoryProviderServer(s prpc.Registrar, srv InventoryProviderServer)
- type DeclareDutsRequest
- func (*DeclareDutsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeclareDutsRequest) GetAvailableDuts() []*DeclareDutsRequest_Dut
- func (*DeclareDutsRequest) ProtoMessage()
- func (x *DeclareDutsRequest) ProtoReflect() protoreflect.Message
- func (x *DeclareDutsRequest) Reset()
- func (x *DeclareDutsRequest) String() string
- type DeclareDutsRequest_Dut
- func (*DeclareDutsRequest_Dut) Descriptor() ([]byte, []int)deprecated
- func (x *DeclareDutsRequest_Dut) GetHive() string
- func (x *DeclareDutsRequest_Dut) GetName() string
- func (*DeclareDutsRequest_Dut) ProtoMessage()
- func (x *DeclareDutsRequest_Dut) ProtoReflect() protoreflect.Message
- func (x *DeclareDutsRequest_Dut) Reset()
- func (x *DeclareDutsRequest_Dut) String() string
- type DeclareDutsResponse
- type DecoratedDrone
- type DecoratedInspect
- type DecoratedInventoryProvider
- type DroneClient
- type DroneServer
- type InspectClient
- type InspectServer
- type InventoryProviderClient
- type InventoryProviderServer
- type ListDronesRequest
- type ListDronesResponse
- func (*ListDronesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDronesResponse) GetDrones() []*ListDronesResponse_Drone
- func (*ListDronesResponse) ProtoMessage()
- func (x *ListDronesResponse) ProtoReflect() protoreflect.Message
- func (x *ListDronesResponse) Reset()
- func (x *ListDronesResponse) String() string
- type ListDronesResponse_Drone
- func (*ListDronesResponse_Drone) Descriptor() ([]byte, []int)deprecated
- func (x *ListDronesResponse_Drone) GetDroneDescription() string
- func (x *ListDronesResponse_Drone) GetExpirationTime() *timestamppb.Timestamp
- func (x *ListDronesResponse_Drone) GetHive() string
- func (x *ListDronesResponse_Drone) GetId() string
- func (*ListDronesResponse_Drone) ProtoMessage()
- func (x *ListDronesResponse_Drone) ProtoReflect() protoreflect.Message
- func (x *ListDronesResponse_Drone) Reset()
- func (x *ListDronesResponse_Drone) String() string
- type ListDutsRequest
- type ListDutsResponse
- func (*ListDutsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListDutsResponse) GetDuts() []*ListDutsResponse_Dut
- func (*ListDutsResponse) ProtoMessage()
- func (x *ListDutsResponse) ProtoReflect() protoreflect.Message
- func (x *ListDutsResponse) Reset()
- func (x *ListDutsResponse) String() string
- type ListDutsResponse_Dut
- func (*ListDutsResponse_Dut) Descriptor() ([]byte, []int)deprecated
- func (x *ListDutsResponse_Dut) GetAssignedDrone() string
- func (x *ListDutsResponse_Dut) GetDraining() bool
- func (x *ListDutsResponse_Dut) GetHive() string
- func (x *ListDutsResponse_Dut) GetId() string
- func (*ListDutsResponse_Dut) ProtoMessage()
- func (x *ListDutsResponse_Dut) ProtoReflect() protoreflect.Message
- func (x *ListDutsResponse_Dut) Reset()
- func (x *ListDutsResponse_Dut) String() string
- type ReleaseDutsRequest
- func (*ReleaseDutsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReleaseDutsRequest) GetDroneUuid() string
- func (x *ReleaseDutsRequest) GetDuts() []string
- func (*ReleaseDutsRequest) ProtoMessage()
- func (x *ReleaseDutsRequest) ProtoReflect() protoreflect.Message
- func (x *ReleaseDutsRequest) Reset()
- func (x *ReleaseDutsRequest) String() string
- type ReleaseDutsResponse
- type ReportDroneRequest
- func (*ReportDroneRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReportDroneRequest) GetDroneDescription() string
- func (x *ReportDroneRequest) GetDroneUuid() string
- func (x *ReportDroneRequest) GetHive() string
- func (x *ReportDroneRequest) GetLoadIndicators() *ReportDroneRequest_LoadIndicators
- func (*ReportDroneRequest) ProtoMessage()
- func (x *ReportDroneRequest) ProtoReflect() protoreflect.Message
- func (x *ReportDroneRequest) Reset()
- func (x *ReportDroneRequest) String() string
- type ReportDroneRequest_LoadIndicators
- func (*ReportDroneRequest_LoadIndicators) Descriptor() ([]byte, []int)deprecated
- func (x *ReportDroneRequest_LoadIndicators) GetDutCapacity() uint32
- func (*ReportDroneRequest_LoadIndicators) ProtoMessage()
- func (x *ReportDroneRequest_LoadIndicators) ProtoReflect() protoreflect.Message
- func (x *ReportDroneRequest_LoadIndicators) Reset()
- func (x *ReportDroneRequest_LoadIndicators) String() string
- type ReportDroneResponse
- func (*ReportDroneResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReportDroneResponse) GetAssignedDuts() []string
- func (x *ReportDroneResponse) GetDrainingDuts() []string
- func (x *ReportDroneResponse) GetDroneUuid() string
- func (x *ReportDroneResponse) GetExpirationTime() *timestamppb.Timestamp
- func (x *ReportDroneResponse) GetStatus() ReportDroneResponse_Status
- func (*ReportDroneResponse) ProtoMessage()
- func (x *ReportDroneResponse) ProtoReflect() protoreflect.Message
- func (x *ReportDroneResponse) Reset()
- func (x *ReportDroneResponse) String() string
- type ReportDroneResponse_Status
- func (ReportDroneResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x ReportDroneResponse_Status) Enum() *ReportDroneResponse_Status
- func (ReportDroneResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReportDroneResponse_Status) Number() protoreflect.EnumNumber
- func (x ReportDroneResponse_Status) String() string
- func (ReportDroneResponse_Status) Type() protoreflect.EnumType
- type UnimplementedDroneServer
- type UnimplementedInspectServer
- type UnimplementedInventoryProviderServer
Constants ¶
This section is empty.
Variables ¶
var ( ReportDroneResponse_Status_name = map[int32]string{ 0: "UNKNOWN_ERROR", 1: "OK", 2: "UNKNOWN_UUID", } ReportDroneResponse_Status_value = map[string]int32{ "UNKNOWN_ERROR": 0, "OK": 1, "UNKNOWN_UUID": 2, } )
Enum value maps for ReportDroneResponse_Status.
var File_go_chromium_org_infra_appengine_drone_queen_api_service_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 RegisterDroneServer ¶
func RegisterDroneServer(s prpc.Registrar, srv DroneServer)
func RegisterInspectServer ¶
func RegisterInspectServer(s prpc.Registrar, srv InspectServer)
func RegisterInventoryProviderServer ¶
func RegisterInventoryProviderServer(s prpc.Registrar, srv InventoryProviderServer)
Types ¶
type DeclareDutsRequest ¶
type DeclareDutsRequest struct { // available_duts is a list of DUTs made available to drones. It contains // assignment information for a DUT. DUTs omitted from this list will be // drained and deleted. AvailableDuts []*DeclareDutsRequest_Dut `protobuf:"bytes,2,rep,name=available_duts,json=availableDuts,proto3" json:"available_duts,omitempty"` // contains filtered or unexported fields }
func (*DeclareDutsRequest) Descriptor
deprecated
func (*DeclareDutsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeclareDutsRequest.ProtoReflect.Descriptor instead.
func (*DeclareDutsRequest) GetAvailableDuts ¶
func (x *DeclareDutsRequest) GetAvailableDuts() []*DeclareDutsRequest_Dut
func (*DeclareDutsRequest) ProtoMessage ¶
func (*DeclareDutsRequest) ProtoMessage()
func (*DeclareDutsRequest) ProtoReflect ¶
func (x *DeclareDutsRequest) ProtoReflect() protoreflect.Message
func (*DeclareDutsRequest) Reset ¶
func (x *DeclareDutsRequest) Reset()
func (*DeclareDutsRequest) String ¶
func (x *DeclareDutsRequest) String() string
type DeclareDutsRequest_Dut ¶
type DeclareDutsRequest_Dut struct { // name of the DUT. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // hive value of the DUT. This is used for DUT/drone affinity. // The DUT is assigned to a drone with same hive value. Hive string `protobuf:"bytes,2,opt,name=hive,proto3" json:"hive,omitempty"` // contains filtered or unexported fields }
func (*DeclareDutsRequest_Dut) Descriptor
deprecated
func (*DeclareDutsRequest_Dut) Descriptor() ([]byte, []int)
Deprecated: Use DeclareDutsRequest_Dut.ProtoReflect.Descriptor instead.
func (*DeclareDutsRequest_Dut) GetHive ¶
func (x *DeclareDutsRequest_Dut) GetHive() string
func (*DeclareDutsRequest_Dut) GetName ¶
func (x *DeclareDutsRequest_Dut) GetName() string
func (*DeclareDutsRequest_Dut) ProtoMessage ¶
func (*DeclareDutsRequest_Dut) ProtoMessage()
func (*DeclareDutsRequest_Dut) ProtoReflect ¶
func (x *DeclareDutsRequest_Dut) ProtoReflect() protoreflect.Message
func (*DeclareDutsRequest_Dut) Reset ¶
func (x *DeclareDutsRequest_Dut) Reset()
func (*DeclareDutsRequest_Dut) String ¶
func (x *DeclareDutsRequest_Dut) String() string
type DeclareDutsResponse ¶
type DeclareDutsResponse struct {
// contains filtered or unexported fields
}
func (*DeclareDutsResponse) Descriptor
deprecated
func (*DeclareDutsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeclareDutsResponse.ProtoReflect.Descriptor instead.
func (*DeclareDutsResponse) ProtoMessage ¶
func (*DeclareDutsResponse) ProtoMessage()
func (*DeclareDutsResponse) ProtoReflect ¶
func (x *DeclareDutsResponse) ProtoReflect() protoreflect.Message
func (*DeclareDutsResponse) Reset ¶
func (x *DeclareDutsResponse) Reset()
func (*DeclareDutsResponse) String ¶
func (x *DeclareDutsResponse) String() string
type DecoratedDrone ¶
type DecoratedDrone struct { // Service is the service to decorate. Service DroneServer // 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 (*DecoratedDrone) ReleaseDuts ¶
func (s *DecoratedDrone) ReleaseDuts(ctx context.Context, req *ReleaseDutsRequest) (rsp *ReleaseDutsResponse, err error)
func (*DecoratedDrone) ReportDrone ¶
func (s *DecoratedDrone) ReportDrone(ctx context.Context, req *ReportDroneRequest) (rsp *ReportDroneResponse, err error)
type DecoratedInspect ¶
type DecoratedInspect struct { // Service is the service to decorate. Service InspectServer // 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 (*DecoratedInspect) ListDrones ¶
func (s *DecoratedInspect) ListDrones(ctx context.Context, req *ListDronesRequest) (rsp *ListDronesResponse, err error)
func (*DecoratedInspect) ListDuts ¶
func (s *DecoratedInspect) ListDuts(ctx context.Context, req *ListDutsRequest) (rsp *ListDutsResponse, err error)
type DecoratedInventoryProvider ¶
type DecoratedInventoryProvider struct { // Service is the service to decorate. Service InventoryProviderServer // 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 (*DecoratedInventoryProvider) DeclareDuts ¶
func (s *DecoratedInventoryProvider) DeclareDuts(ctx context.Context, req *DeclareDutsRequest) (rsp *DeclareDutsResponse, err error)
type DroneClient ¶
type DroneClient interface { // ReportDrone is called by drones to report liveness and get DUT // assignments. // // See the README for details on the contract that the drone must // follow. ReportDrone(ctx context.Context, in *ReportDroneRequest, opts ...grpc.CallOption) (*ReportDroneResponse, error) // ReleaseDuts is called by drones to release ownership of DUTs. ReleaseDuts(ctx context.Context, in *ReleaseDutsRequest, opts ...grpc.CallOption) (*ReleaseDutsResponse, error) }
DroneClient is the client API for Drone service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDroneClient ¶
func NewDroneClient(cc grpc.ClientConnInterface) DroneClient
func NewDronePRPCClient ¶
func NewDronePRPCClient(client *prpc.Client) DroneClient
type DroneServer ¶
type DroneServer interface { // ReportDrone is called by drones to report liveness and get DUT // assignments. // // See the README for details on the contract that the drone must // follow. ReportDrone(context.Context, *ReportDroneRequest) (*ReportDroneResponse, error) // ReleaseDuts is called by drones to release ownership of DUTs. ReleaseDuts(context.Context, *ReleaseDutsRequest) (*ReleaseDutsResponse, error) }
DroneServer is the server API for Drone service.
type InspectClient ¶
type InspectClient interface { ListDrones(ctx context.Context, in *ListDronesRequest, opts ...grpc.CallOption) (*ListDronesResponse, error) ListDuts(ctx context.Context, in *ListDutsRequest, opts ...grpc.CallOption) (*ListDutsResponse, error) }
InspectClient is the client API for Inspect service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewInspectClient ¶
func NewInspectClient(cc grpc.ClientConnInterface) InspectClient
func NewInspectPRPCClient ¶
func NewInspectPRPCClient(client *prpc.Client) InspectClient
type InspectServer ¶
type InspectServer interface { ListDrones(context.Context, *ListDronesRequest) (*ListDronesResponse, error) ListDuts(context.Context, *ListDutsRequest) (*ListDutsResponse, error) }
InspectServer is the server API for Inspect service.
type InventoryProviderClient ¶
type InventoryProviderClient interface { // DeclareDuts tells the service about all of the DUTs available to // assign to drones. DeclareDuts(ctx context.Context, in *DeclareDutsRequest, opts ...grpc.CallOption) (*DeclareDutsResponse, error) }
InventoryProviderClient is the client API for InventoryProvider service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewInventoryProviderClient ¶
func NewInventoryProviderClient(cc grpc.ClientConnInterface) InventoryProviderClient
func NewInventoryProviderPRPCClient ¶
func NewInventoryProviderPRPCClient(client *prpc.Client) InventoryProviderClient
type InventoryProviderServer ¶
type InventoryProviderServer interface { // DeclareDuts tells the service about all of the DUTs available to // assign to drones. DeclareDuts(context.Context, *DeclareDutsRequest) (*DeclareDutsResponse, error) }
InventoryProviderServer is the server API for InventoryProvider service.
type ListDronesRequest ¶
type ListDronesRequest struct {
// contains filtered or unexported fields
}
func (*ListDronesRequest) Descriptor
deprecated
func (*ListDronesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDronesRequest.ProtoReflect.Descriptor instead.
func (*ListDronesRequest) ProtoMessage ¶
func (*ListDronesRequest) ProtoMessage()
func (*ListDronesRequest) ProtoReflect ¶
func (x *ListDronesRequest) ProtoReflect() protoreflect.Message
func (*ListDronesRequest) Reset ¶
func (x *ListDronesRequest) Reset()
func (*ListDronesRequest) String ¶
func (x *ListDronesRequest) String() string
type ListDronesResponse ¶
type ListDronesResponse struct { Drones []*ListDronesResponse_Drone `protobuf:"bytes,1,rep,name=drones,proto3" json:"drones,omitempty"` // contains filtered or unexported fields }
func (*ListDronesResponse) Descriptor
deprecated
func (*ListDronesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDronesResponse.ProtoReflect.Descriptor instead.
func (*ListDronesResponse) GetDrones ¶
func (x *ListDronesResponse) GetDrones() []*ListDronesResponse_Drone
func (*ListDronesResponse) ProtoMessage ¶
func (*ListDronesResponse) ProtoMessage()
func (*ListDronesResponse) ProtoReflect ¶
func (x *ListDronesResponse) ProtoReflect() protoreflect.Message
func (*ListDronesResponse) Reset ¶
func (x *ListDronesResponse) Reset()
func (*ListDronesResponse) String ¶
func (x *ListDronesResponse) String() string
type ListDronesResponse_Drone ¶
type ListDronesResponse_Drone struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"` DroneDescription string `protobuf:"bytes,3,opt,name=drone_description,json=droneDescription,proto3" json:"drone_description,omitempty"` Hive string `protobuf:"bytes,4,opt,name=hive,proto3" json:"hive,omitempty"` // contains filtered or unexported fields }
func (*ListDronesResponse_Drone) Descriptor
deprecated
func (*ListDronesResponse_Drone) Descriptor() ([]byte, []int)
Deprecated: Use ListDronesResponse_Drone.ProtoReflect.Descriptor instead.
func (*ListDronesResponse_Drone) GetDroneDescription ¶
func (x *ListDronesResponse_Drone) GetDroneDescription() string
func (*ListDronesResponse_Drone) GetExpirationTime ¶
func (x *ListDronesResponse_Drone) GetExpirationTime() *timestamppb.Timestamp
func (*ListDronesResponse_Drone) GetHive ¶
func (x *ListDronesResponse_Drone) GetHive() string
func (*ListDronesResponse_Drone) GetId ¶
func (x *ListDronesResponse_Drone) GetId() string
func (*ListDronesResponse_Drone) ProtoMessage ¶
func (*ListDronesResponse_Drone) ProtoMessage()
func (*ListDronesResponse_Drone) ProtoReflect ¶
func (x *ListDronesResponse_Drone) ProtoReflect() protoreflect.Message
func (*ListDronesResponse_Drone) Reset ¶
func (x *ListDronesResponse_Drone) Reset()
func (*ListDronesResponse_Drone) String ¶
func (x *ListDronesResponse_Drone) String() string
type ListDutsRequest ¶
type ListDutsRequest struct {
// contains filtered or unexported fields
}
func (*ListDutsRequest) Descriptor
deprecated
func (*ListDutsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListDutsRequest.ProtoReflect.Descriptor instead.
func (*ListDutsRequest) ProtoMessage ¶
func (*ListDutsRequest) ProtoMessage()
func (*ListDutsRequest) ProtoReflect ¶
func (x *ListDutsRequest) ProtoReflect() protoreflect.Message
func (*ListDutsRequest) Reset ¶
func (x *ListDutsRequest) Reset()
func (*ListDutsRequest) String ¶
func (x *ListDutsRequest) String() string
type ListDutsResponse ¶
type ListDutsResponse struct { Duts []*ListDutsResponse_Dut `protobuf:"bytes,1,rep,name=duts,proto3" json:"duts,omitempty"` // contains filtered or unexported fields }
func (*ListDutsResponse) Descriptor
deprecated
func (*ListDutsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListDutsResponse.ProtoReflect.Descriptor instead.
func (*ListDutsResponse) GetDuts ¶
func (x *ListDutsResponse) GetDuts() []*ListDutsResponse_Dut
func (*ListDutsResponse) ProtoMessage ¶
func (*ListDutsResponse) ProtoMessage()
func (*ListDutsResponse) ProtoReflect ¶
func (x *ListDutsResponse) ProtoReflect() protoreflect.Message
func (*ListDutsResponse) Reset ¶
func (x *ListDutsResponse) Reset()
func (*ListDutsResponse) String ¶
func (x *ListDutsResponse) String() string
type ListDutsResponse_Dut ¶
type ListDutsResponse_Dut struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` AssignedDrone string `protobuf:"bytes,2,opt,name=assigned_drone,json=assignedDrone,proto3" json:"assigned_drone,omitempty"` Draining bool `protobuf:"varint,3,opt,name=draining,proto3" json:"draining,omitempty"` Hive string `protobuf:"bytes,4,opt,name=hive,proto3" json:"hive,omitempty"` // contains filtered or unexported fields }
func (*ListDutsResponse_Dut) Descriptor
deprecated
func (*ListDutsResponse_Dut) Descriptor() ([]byte, []int)
Deprecated: Use ListDutsResponse_Dut.ProtoReflect.Descriptor instead.
func (*ListDutsResponse_Dut) GetAssignedDrone ¶
func (x *ListDutsResponse_Dut) GetAssignedDrone() string
func (*ListDutsResponse_Dut) GetDraining ¶
func (x *ListDutsResponse_Dut) GetDraining() bool
func (*ListDutsResponse_Dut) GetHive ¶
func (x *ListDutsResponse_Dut) GetHive() string
func (*ListDutsResponse_Dut) GetId ¶
func (x *ListDutsResponse_Dut) GetId() string
func (*ListDutsResponse_Dut) ProtoMessage ¶
func (*ListDutsResponse_Dut) ProtoMessage()
func (*ListDutsResponse_Dut) ProtoReflect ¶
func (x *ListDutsResponse_Dut) ProtoReflect() protoreflect.Message
func (*ListDutsResponse_Dut) Reset ¶
func (x *ListDutsResponse_Dut) Reset()
func (*ListDutsResponse_Dut) String ¶
func (x *ListDutsResponse_Dut) String() string
type ReleaseDutsRequest ¶
type ReleaseDutsRequest struct { // drone_uuid is the UUID assigned to the drone. DroneUuid string `protobuf:"bytes,1,opt,name=drone_uuid,json=droneUuid,proto3" json:"drone_uuid,omitempty"` // duts to release. It is not an error if a DUT is not assigned to // the drone. Duts []string `protobuf:"bytes,2,rep,name=duts,proto3" json:"duts,omitempty"` // contains filtered or unexported fields }
func (*ReleaseDutsRequest) Descriptor
deprecated
func (*ReleaseDutsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReleaseDutsRequest.ProtoReflect.Descriptor instead.
func (*ReleaseDutsRequest) GetDroneUuid ¶
func (x *ReleaseDutsRequest) GetDroneUuid() string
func (*ReleaseDutsRequest) GetDuts ¶
func (x *ReleaseDutsRequest) GetDuts() []string
func (*ReleaseDutsRequest) ProtoMessage ¶
func (*ReleaseDutsRequest) ProtoMessage()
func (*ReleaseDutsRequest) ProtoReflect ¶
func (x *ReleaseDutsRequest) ProtoReflect() protoreflect.Message
func (*ReleaseDutsRequest) Reset ¶
func (x *ReleaseDutsRequest) Reset()
func (*ReleaseDutsRequest) String ¶
func (x *ReleaseDutsRequest) String() string
type ReleaseDutsResponse ¶
type ReleaseDutsResponse struct {
// contains filtered or unexported fields
}
func (*ReleaseDutsResponse) Descriptor
deprecated
func (*ReleaseDutsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReleaseDutsResponse.ProtoReflect.Descriptor instead.
func (*ReleaseDutsResponse) ProtoMessage ¶
func (*ReleaseDutsResponse) ProtoMessage()
func (*ReleaseDutsResponse) ProtoReflect ¶
func (x *ReleaseDutsResponse) ProtoReflect() protoreflect.Message
func (*ReleaseDutsResponse) Reset ¶
func (x *ReleaseDutsResponse) Reset()
func (*ReleaseDutsResponse) String ¶
func (x *ReleaseDutsResponse) String() string
type ReportDroneRequest ¶
type ReportDroneRequest struct { // drone_uuid is the UUID assigned to the drone. New drones should // leave this empty; a new UUID will be assigned to the drone. DroneUuid string `protobuf:"bytes,1,opt,name=drone_uuid,json=droneUuid,proto3" json:"drone_uuid,omitempty"` // load_indicators are used for load balancing. LoadIndicators *ReportDroneRequest_LoadIndicators `protobuf:"bytes,2,opt,name=load_indicators,json=loadIndicators,proto3" json:"load_indicators,omitempty"` // drone_description is a human friendly description of the current drone. DroneDescription string `protobuf:"bytes,3,opt,name=drone_description,json=droneDescription,proto3" json:"drone_description,omitempty"` // hive value for the drone agent. This is used for DUT/drone affinity. // DUTs with same hive value will be assigned to this drone. Hive string `protobuf:"bytes,4,opt,name=hive,proto3" json:"hive,omitempty"` // contains filtered or unexported fields }
func (*ReportDroneRequest) Descriptor
deprecated
func (*ReportDroneRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReportDroneRequest.ProtoReflect.Descriptor instead.
func (*ReportDroneRequest) GetDroneDescription ¶
func (x *ReportDroneRequest) GetDroneDescription() string
func (*ReportDroneRequest) GetDroneUuid ¶
func (x *ReportDroneRequest) GetDroneUuid() string
func (*ReportDroneRequest) GetHive ¶
func (x *ReportDroneRequest) GetHive() string
func (*ReportDroneRequest) GetLoadIndicators ¶
func (x *ReportDroneRequest) GetLoadIndicators() *ReportDroneRequest_LoadIndicators
func (*ReportDroneRequest) ProtoMessage ¶
func (*ReportDroneRequest) ProtoMessage()
func (*ReportDroneRequest) ProtoReflect ¶
func (x *ReportDroneRequest) ProtoReflect() protoreflect.Message
func (*ReportDroneRequest) Reset ¶
func (x *ReportDroneRequest) Reset()
func (*ReportDroneRequest) String ¶
func (x *ReportDroneRequest) String() string
type ReportDroneRequest_LoadIndicators ¶
type ReportDroneRequest_LoadIndicators struct { // dut_capacity is a simple load indicator that indicates how many // total DUTs the drone can support. DutCapacity uint32 `protobuf:"varint,1,opt,name=dut_capacity,json=dutCapacity,proto3" json:"dut_capacity,omitempty"` // contains filtered or unexported fields }
func (*ReportDroneRequest_LoadIndicators) Descriptor
deprecated
func (*ReportDroneRequest_LoadIndicators) Descriptor() ([]byte, []int)
Deprecated: Use ReportDroneRequest_LoadIndicators.ProtoReflect.Descriptor instead.
func (*ReportDroneRequest_LoadIndicators) GetDutCapacity ¶
func (x *ReportDroneRequest_LoadIndicators) GetDutCapacity() uint32
func (*ReportDroneRequest_LoadIndicators) ProtoMessage ¶
func (*ReportDroneRequest_LoadIndicators) ProtoMessage()
func (*ReportDroneRequest_LoadIndicators) ProtoReflect ¶
func (x *ReportDroneRequest_LoadIndicators) ProtoReflect() protoreflect.Message
func (*ReportDroneRequest_LoadIndicators) Reset ¶
func (x *ReportDroneRequest_LoadIndicators) Reset()
func (*ReportDroneRequest_LoadIndicators) String ¶
func (x *ReportDroneRequest_LoadIndicators) String() string
type ReportDroneResponse ¶
type ReportDroneResponse struct { // status reports the status of the call. It is important to check // this for errors. Status ReportDroneResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=drone_queen.ReportDroneResponse_Status" json:"status,omitempty"` // drone_uuid is the UUID assigned to the drone. If drone_uuid was // set in the request, this field will either have the same value or // be omitted. DroneUuid string `protobuf:"bytes,2,opt,name=drone_uuid,json=droneUuid,proto3" json:"drone_uuid,omitempty"` // expiration_time is when the current assignment expires. ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"` // assigned_duts are the DUTs assigned to the drone. AssignedDuts []string `protobuf:"bytes,4,rep,name=assigned_duts,json=assignedDuts,proto3" json:"assigned_duts,omitempty"` // draining_duts are the DUTs that the drone should drain. This is // always a subset of assigned_duts. DrainingDuts []string `protobuf:"bytes,5,rep,name=draining_duts,json=drainingDuts,proto3" json:"draining_duts,omitempty"` // contains filtered or unexported fields }
func (*ReportDroneResponse) Descriptor
deprecated
func (*ReportDroneResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReportDroneResponse.ProtoReflect.Descriptor instead.
func (*ReportDroneResponse) GetAssignedDuts ¶
func (x *ReportDroneResponse) GetAssignedDuts() []string
func (*ReportDroneResponse) GetDrainingDuts ¶
func (x *ReportDroneResponse) GetDrainingDuts() []string
func (*ReportDroneResponse) GetDroneUuid ¶
func (x *ReportDroneResponse) GetDroneUuid() string
func (*ReportDroneResponse) GetExpirationTime ¶
func (x *ReportDroneResponse) GetExpirationTime() *timestamppb.Timestamp
func (*ReportDroneResponse) GetStatus ¶
func (x *ReportDroneResponse) GetStatus() ReportDroneResponse_Status
func (*ReportDroneResponse) ProtoMessage ¶
func (*ReportDroneResponse) ProtoMessage()
func (*ReportDroneResponse) ProtoReflect ¶
func (x *ReportDroneResponse) ProtoReflect() protoreflect.Message
func (*ReportDroneResponse) Reset ¶
func (x *ReportDroneResponse) Reset()
func (*ReportDroneResponse) String ¶
func (x *ReportDroneResponse) String() string
type ReportDroneResponse_Status ¶
type ReportDroneResponse_Status int32
const ( // UNKNOWN_ERROR should not be used normally. It is the default // value if the status is missing or unknown. For example, if the // service uses a new enum value that the client does not know // about yet, the client will use the default value. ReportDroneResponse_UNKNOWN_ERROR ReportDroneResponse_Status = 0 ReportDroneResponse_OK ReportDroneResponse_Status = 1 ReportDroneResponse_UNKNOWN_UUID ReportDroneResponse_Status = 2 )
func (ReportDroneResponse_Status) Descriptor ¶
func (ReportDroneResponse_Status) Descriptor() protoreflect.EnumDescriptor
func (ReportDroneResponse_Status) Enum ¶
func (x ReportDroneResponse_Status) Enum() *ReportDroneResponse_Status
func (ReportDroneResponse_Status) EnumDescriptor
deprecated
func (ReportDroneResponse_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReportDroneResponse_Status.Descriptor instead.
func (ReportDroneResponse_Status) Number ¶
func (x ReportDroneResponse_Status) Number() protoreflect.EnumNumber
func (ReportDroneResponse_Status) String ¶
func (x ReportDroneResponse_Status) String() string
func (ReportDroneResponse_Status) Type ¶
func (ReportDroneResponse_Status) Type() protoreflect.EnumType
type UnimplementedDroneServer ¶
type UnimplementedDroneServer struct { }
UnimplementedDroneServer can be embedded to have forward compatible implementations.
func (*UnimplementedDroneServer) ReleaseDuts ¶
func (*UnimplementedDroneServer) ReleaseDuts(context.Context, *ReleaseDutsRequest) (*ReleaseDutsResponse, error)
func (*UnimplementedDroneServer) ReportDrone ¶
func (*UnimplementedDroneServer) ReportDrone(context.Context, *ReportDroneRequest) (*ReportDroneResponse, error)
type UnimplementedInspectServer ¶
type UnimplementedInspectServer struct { }
UnimplementedInspectServer can be embedded to have forward compatible implementations.
func (*UnimplementedInspectServer) ListDrones ¶
func (*UnimplementedInspectServer) ListDrones(context.Context, *ListDronesRequest) (*ListDronesResponse, error)
func (*UnimplementedInspectServer) ListDuts ¶
func (*UnimplementedInspectServer) ListDuts(context.Context, *ListDutsRequest) (*ListDutsResponse, error)
type UnimplementedInventoryProviderServer ¶
type UnimplementedInventoryProviderServer struct { }
UnimplementedInventoryProviderServer can be embedded to have forward compatible implementations.
func (*UnimplementedInventoryProviderServer) DeclareDuts ¶
func (*UnimplementedInventoryProviderServer) DeclareDuts(context.Context, *DeclareDutsRequest) (*DeclareDutsResponse, error)