v1api

package
v0.5.0-alpha Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2021 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDriveServiceServer 

func RegisterDriveServiceServer(s *grpc.Server, srv DriveServiceServer)

Types

type AvailableCapacity 

type AvailableCapacity struct {
	Location             string   `protobuf:"bytes,1,opt,name=Location,proto3" json:"Location,omitempty"`
	NodeId               string   `protobuf:"bytes,2,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	StorageClass         string   `protobuf:"bytes,3,opt,name=storageClass,proto3" json:"storageClass,omitempty"`
	Size                 int64    `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AvailableCapacity) Descriptor 

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

func (*AvailableCapacity) GetLocation 

func (m *AvailableCapacity) GetLocation() string

func (*AvailableCapacity) GetNodeId 

func (m *AvailableCapacity) GetNodeId() string

func (*AvailableCapacity) GetSize 

func (m *AvailableCapacity) GetSize() int64

func (*AvailableCapacity) GetStorageClass 

func (m *AvailableCapacity) GetStorageClass() string

func (*AvailableCapacity) ProtoMessage 

func (*AvailableCapacity) ProtoMessage()

func (*AvailableCapacity) Reset 

func (m *AvailableCapacity) Reset()

func (*AvailableCapacity) String 

func (m *AvailableCapacity) String() string

func (*AvailableCapacity) XXX_DiscardUnknown 

func (m *AvailableCapacity) XXX_DiscardUnknown()

func (*AvailableCapacity) XXX_Marshal 

func (m *AvailableCapacity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AvailableCapacity) XXX_Merge 

func (m *AvailableCapacity) XXX_Merge(src proto.Message)

func (*AvailableCapacity) XXX_Size 

func (m *AvailableCapacity) XXX_Size() int

func (*AvailableCapacity) XXX_Unmarshal 

func (m *AvailableCapacity) XXX_Unmarshal(b []byte) error

type AvailableCapacityReservation 

type AvailableCapacityReservation struct {
	Namespace            string                `protobuf:"bytes,1,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
	Status               string                `protobuf:"bytes,2,opt,name=Status,proto3" json:"Status,omitempty"`
	NodeRequests         *NodeRequests         `protobuf:"bytes,3,opt,name=NodeRequests,proto3" json:"NodeRequests,omitempty"`
	ReservationRequests  []*ReservationRequest `protobuf:"bytes,4,rep,name=ReservationRequests,proto3" json:"ReservationRequests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*AvailableCapacityReservation) Descriptor 

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

func (*AvailableCapacityReservation) GetNamespace 

func (m *AvailableCapacityReservation) GetNamespace() string

func (*AvailableCapacityReservation) GetNodeRequests 

func (m *AvailableCapacityReservation) GetNodeRequests() *NodeRequests

func (*AvailableCapacityReservation) GetReservationRequests 

func (m *AvailableCapacityReservation) GetReservationRequests() []*ReservationRequest

func (*AvailableCapacityReservation) GetStatus 

func (m *AvailableCapacityReservation) GetStatus() string

func (*AvailableCapacityReservation) ProtoMessage 

func (*AvailableCapacityReservation) ProtoMessage()

func (*AvailableCapacityReservation) Reset 

func (m *AvailableCapacityReservation) Reset()

func (*AvailableCapacityReservation) String 

func (m *AvailableCapacityReservation) String() string

func (*AvailableCapacityReservation) XXX_DiscardUnknown 

func (m *AvailableCapacityReservation) XXX_DiscardUnknown()

func (*AvailableCapacityReservation) XXX_Marshal 

func (m *AvailableCapacityReservation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AvailableCapacityReservation) XXX_Merge 

func (m *AvailableCapacityReservation) XXX_Merge(src proto.Message)

func (*AvailableCapacityReservation) XXX_Size 

func (m *AvailableCapacityReservation) XXX_Size() int

func (*AvailableCapacityReservation) XXX_Unmarshal 

func (m *AvailableCapacityReservation) XXX_Unmarshal(b []byte) error

type CapacityRequest 

type CapacityRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	StorageClass         string   `protobuf:"bytes,2,opt,name=StorageClass,proto3" json:"StorageClass,omitempty"`
	Size                 int64    `protobuf:"varint,3,opt,name=Size,proto3" json:"Size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CapacityRequest) Descriptor 

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

func (*CapacityRequest) GetName 

func (m *CapacityRequest) GetName() string

func (*CapacityRequest) GetSize 

func (m *CapacityRequest) GetSize() int64

func (*CapacityRequest) GetStorageClass 

func (m *CapacityRequest) GetStorageClass() string

func (*CapacityRequest) ProtoMessage 

func (*CapacityRequest) ProtoMessage()

func (*CapacityRequest) Reset 

func (m *CapacityRequest) Reset()

func (*CapacityRequest) String 

func (m *CapacityRequest) String() string

func (*CapacityRequest) XXX_DiscardUnknown 

func (m *CapacityRequest) XXX_DiscardUnknown()

func (*CapacityRequest) XXX_Marshal 

func (m *CapacityRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CapacityRequest) XXX_Merge 

func (m *CapacityRequest) XXX_Merge(src proto.Message)

func (*CapacityRequest) XXX_Size 

func (m *CapacityRequest) XXX_Size() int

func (*CapacityRequest) XXX_Unmarshal 

func (m *CapacityRequest) XXX_Unmarshal(b []byte) error

type Drive 

type Drive struct {
	UUID         string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	VID          string `protobuf:"bytes,2,opt,name=VID,proto3" json:"VID,omitempty"`
	PID          string `protobuf:"bytes,3,opt,name=PID,proto3" json:"PID,omitempty"`
	SerialNumber string `protobuf:"bytes,4,opt,name=SerialNumber,proto3" json:"SerialNumber,omitempty"`
	Health       string `protobuf:"bytes,5,opt,name=Health,proto3" json:"Health,omitempty"`
	Type         string `protobuf:"bytes,6,opt,name=Type,proto3" json:"Type,omitempty"`
	// size in bytes
	Size   int64  `protobuf:"varint,7,opt,name=Size,proto3" json:"Size,omitempty"`
	Status string `protobuf:"bytes,8,opt,name=Status,proto3" json:"Status,omitempty"`
	Usage  string `protobuf:"bytes,9,opt,name=Usage,proto3" json:"Usage,omitempty"`
	NodeId string `protobuf:"bytes,10,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	// path to the device. may not be set by drivemgr.
	Path                 string   `protobuf:"bytes,11,opt,name=Path,proto3" json:"Path,omitempty"`
	Enclosure            string   `protobuf:"bytes,12,opt,name=Enclosure,proto3" json:"Enclosure,omitempty"`
	Slot                 string   `protobuf:"bytes,13,opt,name=Slot,proto3" json:"Slot,omitempty"`
	Bay                  string   `protobuf:"bytes,14,opt,name=Bay,proto3" json:"Bay,omitempty"`
	Firmware             string   `protobuf:"bytes,15,opt,name=Firmware,proto3" json:"Firmware,omitempty"`
	Endurance            int64    `protobuf:"varint,16,opt,name=Endurance,proto3" json:"Endurance,omitempty"`
	LEDState             string   `protobuf:"bytes,17,opt,name=LEDState,proto3" json:"LEDState,omitempty"`
	IsSystem             bool     `protobuf:"varint,18,opt,name=IsSystem,proto3" json:"IsSystem,omitempty"`
	IsClean              bool     `protobuf:"varint,19,opt,name=IsClean,proto3" json:"IsClean,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Drive) Descriptor 

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

func (*Drive) GetBay 

func (m *Drive) GetBay() string

func (*Drive) GetEnclosure 

func (m *Drive) GetEnclosure() string

func (*Drive) GetEndurance 

func (m *Drive) GetEndurance() int64

func (*Drive) GetFirmware 

func (m *Drive) GetFirmware() string

func (*Drive) GetHealth 

func (m *Drive) GetHealth() string

func (*Drive) GetIsClean 

func (m *Drive) GetIsClean() bool

func (*Drive) GetIsSystem 

func (m *Drive) GetIsSystem() bool

func (*Drive) GetLEDState 

func (m *Drive) GetLEDState() string

func (*Drive) GetNodeId 

func (m *Drive) GetNodeId() string

func (*Drive) GetPID 

func (m *Drive) GetPID() string

func (*Drive) GetPath 

func (m *Drive) GetPath() string

func (*Drive) GetSerialNumber 

func (m *Drive) GetSerialNumber() string

func (*Drive) GetSize 

func (m *Drive) GetSize() int64

func (*Drive) GetSlot 

func (m *Drive) GetSlot() string

func (*Drive) GetStatus 

func (m *Drive) GetStatus() string

func (*Drive) GetType 

func (m *Drive) GetType() string

func (*Drive) GetUUID 

func (m *Drive) GetUUID() string

func (*Drive) GetUsage 

func (m *Drive) GetUsage() string

func (*Drive) GetVID 

func (m *Drive) GetVID() string

func (*Drive) ProtoMessage 

func (*Drive) ProtoMessage()

func (*Drive) Reset 

func (m *Drive) Reset()

func (*Drive) String 

func (m *Drive) String() string

func (*Drive) XXX_DiscardUnknown 

func (m *Drive) XXX_DiscardUnknown()

func (*Drive) XXX_Marshal 

func (m *Drive) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Drive) XXX_Merge 

func (m *Drive) XXX_Merge(src proto.Message)

func (*Drive) XXX_Size 

func (m *Drive) XXX_Size() int

func (*Drive) XXX_Unmarshal 

func (m *Drive) XXX_Unmarshal(b []byte) error

type DriveLocateRequest 

type DriveLocateRequest struct {
	DriveSerialNumber    string   `protobuf:"bytes,1,opt,name=driveSerialNumber,proto3" json:"driveSerialNumber,omitempty"`
	Action               int32    `protobuf:"varint,2,opt,name=action,proto3" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DriveLocateRequest) Descriptor 

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

func (*DriveLocateRequest) GetAction 

func (m *DriveLocateRequest) GetAction() int32

func (*DriveLocateRequest) GetDriveSerialNumber 

func (m *DriveLocateRequest) GetDriveSerialNumber() string

func (*DriveLocateRequest) ProtoMessage 

func (*DriveLocateRequest) ProtoMessage()

func (*DriveLocateRequest) Reset 

func (m *DriveLocateRequest) Reset()

func (*DriveLocateRequest) String 

func (m *DriveLocateRequest) String() string

func (*DriveLocateRequest) XXX_DiscardUnknown 

func (m *DriveLocateRequest) XXX_DiscardUnknown()

func (*DriveLocateRequest) XXX_Marshal 

func (m *DriveLocateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DriveLocateRequest) XXX_Merge 

func (m *DriveLocateRequest) XXX_Merge(src proto.Message)

func (*DriveLocateRequest) XXX_Size 

func (m *DriveLocateRequest) XXX_Size() int

func (*DriveLocateRequest) XXX_Unmarshal 

func (m *DriveLocateRequest) XXX_Unmarshal(b []byte) error

type DriveLocateResponse 

type DriveLocateResponse struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DriveLocateResponse) Descriptor 

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

func (*DriveLocateResponse) GetStatus 

func (m *DriveLocateResponse) GetStatus() int32

func (*DriveLocateResponse) ProtoMessage 

func (*DriveLocateResponse) ProtoMessage()

func (*DriveLocateResponse) Reset 

func (m *DriveLocateResponse) Reset()

func (*DriveLocateResponse) String 

func (m *DriveLocateResponse) String() string

func (*DriveLocateResponse) XXX_DiscardUnknown 

func (m *DriveLocateResponse) XXX_DiscardUnknown()

func (*DriveLocateResponse) XXX_Marshal 

func (m *DriveLocateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DriveLocateResponse) XXX_Merge 

func (m *DriveLocateResponse) XXX_Merge(src proto.Message)

func (*DriveLocateResponse) XXX_Size 

func (m *DriveLocateResponse) XXX_Size() int

func (*DriveLocateResponse) XXX_Unmarshal 

func (m *DriveLocateResponse) XXX_Unmarshal(b []byte) error

type DriveServiceClient 

type DriveServiceClient interface {
	GetDrivesList(ctx context.Context, in *DrivesRequest, opts ...grpc.CallOption) (*DrivesResponse, error)
	Locate(ctx context.Context, in *DriveLocateRequest, opts ...grpc.CallOption) (*DriveLocateResponse, error)
	LocateNode(ctx context.Context, in *NodeLocateRequest, opts ...grpc.CallOption) (*Empty, error)
}

DriveServiceClient is the client API for DriveService service.

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

func NewDriveServiceClient 

func NewDriveServiceClient(cc *grpc.ClientConn) DriveServiceClient

type DriveServiceServer 

type DriveServiceServer interface {
	GetDrivesList(context.Context, *DrivesRequest) (*DrivesResponse, error)
	Locate(context.Context, *DriveLocateRequest) (*DriveLocateResponse, error)
	LocateNode(context.Context, *NodeLocateRequest) (*Empty, error)
}

DriveServiceServer is the server API for DriveService service.

type DrivesRequest 

type DrivesRequest struct {
	NodeId               string   `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DrivesRequest) Descriptor 

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

func (*DrivesRequest) GetNodeId 

func (m *DrivesRequest) GetNodeId() string

func (*DrivesRequest) ProtoMessage 

func (*DrivesRequest) ProtoMessage()

func (*DrivesRequest) Reset 

func (m *DrivesRequest) Reset()

func (*DrivesRequest) String 

func (m *DrivesRequest) String() string

func (*DrivesRequest) XXX_DiscardUnknown 

func (m *DrivesRequest) XXX_DiscardUnknown()

func (*DrivesRequest) XXX_Marshal 

func (m *DrivesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DrivesRequest) XXX_Merge 

func (m *DrivesRequest) XXX_Merge(src proto.Message)

func (*DrivesRequest) XXX_Size 

func (m *DrivesRequest) XXX_Size() int

func (*DrivesRequest) XXX_Unmarshal 

func (m *DrivesRequest) XXX_Unmarshal(b []byte) error

type DrivesResponse 

type DrivesResponse struct {
	Disks                []*Drive `protobuf:"bytes,1,rep,name=disks,proto3" json:"disks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DrivesResponse) Descriptor 

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

func (*DrivesResponse) GetDisks 

func (m *DrivesResponse) GetDisks() []*Drive

func (*DrivesResponse) ProtoMessage 

func (*DrivesResponse) ProtoMessage()

func (*DrivesResponse) Reset 

func (m *DrivesResponse) Reset()

func (*DrivesResponse) String 

func (m *DrivesResponse) String() string

func (*DrivesResponse) XXX_DiscardUnknown 

func (m *DrivesResponse) XXX_DiscardUnknown()

func (*DrivesResponse) XXX_Marshal 

func (m *DrivesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DrivesResponse) XXX_Merge 

func (m *DrivesResponse) XXX_Merge(src proto.Message)

func (*DrivesResponse) XXX_Size 

func (m *DrivesResponse) XXX_Size() int

func (*DrivesResponse) XXX_Unmarshal 

func (m *DrivesResponse) XXX_Unmarshal(b []byte) error

type Empty 

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type LogicalVolumeGroup 

type LogicalVolumeGroup struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Node                 string   `protobuf:"bytes,2,opt,name=Node,proto3" json:"Node,omitempty"`
	Locations            []string `protobuf:"bytes,3,rep,name=Locations,proto3" json:"Locations,omitempty"`
	Size                 int64    `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"`
	VolumeRefs           []string `protobuf:"bytes,5,rep,name=VolumeRefs,proto3" json:"VolumeRefs,omitempty"`
	Status               string   `protobuf:"bytes,6,opt,name=Status,proto3" json:"Status,omitempty"`
	Health               string   `protobuf:"bytes,7,opt,name=Health,proto3" json:"Health,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogicalVolumeGroup) Descriptor 

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

func (*LogicalVolumeGroup) GetHealth 

func (m *LogicalVolumeGroup) GetHealth() string

func (*LogicalVolumeGroup) GetLocations 

func (m *LogicalVolumeGroup) GetLocations() []string

func (*LogicalVolumeGroup) GetName 

func (m *LogicalVolumeGroup) GetName() string

func (*LogicalVolumeGroup) GetNode 

func (m *LogicalVolumeGroup) GetNode() string

func (*LogicalVolumeGroup) GetSize 

func (m *LogicalVolumeGroup) GetSize() int64

func (*LogicalVolumeGroup) GetStatus 

func (m *LogicalVolumeGroup) GetStatus() string

func (*LogicalVolumeGroup) GetVolumeRefs 

func (m *LogicalVolumeGroup) GetVolumeRefs() []string

func (*LogicalVolumeGroup) ProtoMessage 

func (*LogicalVolumeGroup) ProtoMessage()

func (*LogicalVolumeGroup) Reset 

func (m *LogicalVolumeGroup) Reset()

func (*LogicalVolumeGroup) String 

func (m *LogicalVolumeGroup) String() string

func (*LogicalVolumeGroup) XXX_DiscardUnknown 

func (m *LogicalVolumeGroup) XXX_DiscardUnknown()

func (*LogicalVolumeGroup) XXX_Marshal 

func (m *LogicalVolumeGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogicalVolumeGroup) XXX_Merge 

func (m *LogicalVolumeGroup) XXX_Merge(src proto.Message)

func (*LogicalVolumeGroup) XXX_Size 

func (m *LogicalVolumeGroup) XXX_Size() int

func (*LogicalVolumeGroup) XXX_Unmarshal 

func (m *LogicalVolumeGroup) XXX_Unmarshal(b []byte) error

type Node 

type Node struct {
	UUID string `protobuf:"bytes,1,opt,name=UUID,proto3" json:"UUID,omitempty"`
	// key - address type, value - address, align with NodeAddress struct from k8s.io/api/core/v1
	Addresses            map[string]string `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Node) Descriptor 

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

func (*Node) GetAddresses 

func (m *Node) GetAddresses() map[string]string

func (*Node) GetUUID 

func (m *Node) GetUUID() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

func (m *Node) XXX_Unmarshal(b []byte) error

type NodeLocateRequest 

type NodeLocateRequest struct {
	Action               int32    `protobuf:"varint,1,opt,name=action,proto3" json:"action,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeLocateRequest) Descriptor 

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

func (*NodeLocateRequest) GetAction 

func (m *NodeLocateRequest) GetAction() int32

func (*NodeLocateRequest) ProtoMessage 

func (*NodeLocateRequest) ProtoMessage()

func (*NodeLocateRequest) Reset 

func (m *NodeLocateRequest) Reset()

func (*NodeLocateRequest) String 

func (m *NodeLocateRequest) String() string

func (*NodeLocateRequest) XXX_DiscardUnknown 

func (m *NodeLocateRequest) XXX_DiscardUnknown()

func (*NodeLocateRequest) XXX_Marshal 

func (m *NodeLocateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeLocateRequest) XXX_Merge 

func (m *NodeLocateRequest) XXX_Merge(src proto.Message)

func (*NodeLocateRequest) XXX_Size 

func (m *NodeLocateRequest) XXX_Size() int

func (*NodeLocateRequest) XXX_Unmarshal 

func (m *NodeLocateRequest) XXX_Unmarshal(b []byte) error

type NodeRequests 

type NodeRequests struct {
	// requested - filled by scheduler/extender
	Requested []string `protobuf:"bytes,1,rep,name=Requested,proto3" json:"Requested,omitempty"`
	// reserved - filled by csi driver controller
	Reserved             []string `protobuf:"bytes,2,rep,name=Reserved,proto3" json:"Reserved,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeRequests) Descriptor 

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

func (*NodeRequests) GetRequested 

func (m *NodeRequests) GetRequested() []string

func (*NodeRequests) GetReserved 

func (m *NodeRequests) GetReserved() []string

func (*NodeRequests) ProtoMessage 

func (*NodeRequests) ProtoMessage()

func (*NodeRequests) Reset 

func (m *NodeRequests) Reset()

func (*NodeRequests) String 

func (m *NodeRequests) String() string

func (*NodeRequests) XXX_DiscardUnknown 

func (m *NodeRequests) XXX_DiscardUnknown()

func (*NodeRequests) XXX_Marshal 

func (m *NodeRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeRequests) XXX_Merge 

func (m *NodeRequests) XXX_Merge(src proto.Message)

func (*NodeRequests) XXX_Size 

func (m *NodeRequests) XXX_Size() int

func (*NodeRequests) XXX_Unmarshal 

func (m *NodeRequests) XXX_Unmarshal(b []byte) error

type ReservationRequest 

type ReservationRequest struct {
	// request per volume filled by scheduler/extender
	CapacityRequest *CapacityRequest `protobuf:"bytes,1,opt,name=CapacityRequest,proto3" json:"CapacityRequest,omitempty"`
	// reservation filled by csi driver controller
	Reservations         []string `protobuf:"bytes,2,rep,name=Reservations,proto3" json:"Reservations,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReservationRequest) Descriptor 

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

func (*ReservationRequest) GetCapacityRequest 

func (m *ReservationRequest) GetCapacityRequest() *CapacityRequest

func (*ReservationRequest) GetReservations 

func (m *ReservationRequest) GetReservations() []string

func (*ReservationRequest) ProtoMessage 

func (*ReservationRequest) ProtoMessage()

func (*ReservationRequest) Reset 

func (m *ReservationRequest) Reset()

func (*ReservationRequest) String 

func (m *ReservationRequest) String() string

func (*ReservationRequest) XXX_DiscardUnknown 

func (m *ReservationRequest) XXX_DiscardUnknown()

func (*ReservationRequest) XXX_Marshal 

func (m *ReservationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReservationRequest) XXX_Merge 

func (m *ReservationRequest) XXX_Merge(src proto.Message)

func (*ReservationRequest) XXX_Size 

func (m *ReservationRequest) XXX_Size() int

func (*ReservationRequest) XXX_Unmarshal 

func (m *ReservationRequest) XXX_Unmarshal(b []byte) error

type UnimplementedDriveServiceServer 

type UnimplementedDriveServiceServer struct {
}

UnimplementedDriveServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDriveServiceServer) GetDrivesList 

func (*UnimplementedDriveServiceServer) GetDrivesList(ctx context.Context, req *DrivesRequest) (*DrivesResponse, error)

func (*UnimplementedDriveServiceServer) Locate 

func (*UnimplementedDriveServiceServer) Locate(ctx context.Context, req *DriveLocateRequest) (*DriveLocateResponse, error)

func (*UnimplementedDriveServiceServer) LocateNode 

func (*UnimplementedDriveServiceServer) LocateNode(ctx context.Context, req *NodeLocateRequest) (*Empty, error)

type Volume 

type Volume struct {
	Id                   string   `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id,omitempty"`
	Location             string   `protobuf:"bytes,2,opt,name=Location,proto3" json:"Location,omitempty"`
	LocationType         string   `protobuf:"bytes,3,opt,name=LocationType,proto3" json:"LocationType,omitempty"`
	StorageClass         string   `protobuf:"bytes,4,opt,name=StorageClass,proto3" json:"StorageClass,omitempty"`
	NodeId               string   `protobuf:"bytes,5,opt,name=NodeId,proto3" json:"NodeId,omitempty"`
	Owners               []string `protobuf:"bytes,6,rep,name=Owners,proto3" json:"Owners,omitempty"`
	Size                 int64    `protobuf:"varint,7,opt,name=Size,proto3" json:"Size,omitempty"`
	Mode                 string   `protobuf:"bytes,8,opt,name=Mode,proto3" json:"Mode,omitempty"`
	Type                 string   `protobuf:"bytes,9,opt,name=Type,proto3" json:"Type,omitempty"`
	Health               string   `protobuf:"bytes,10,opt,name=Health,proto3" json:"Health,omitempty"`
	OperationalStatus    string   `protobuf:"bytes,11,opt,name=OperationalStatus,proto3" json:"OperationalStatus,omitempty"`
	CSIStatus            string   `protobuf:"bytes,12,opt,name=CSIStatus,proto3" json:"CSIStatus,omitempty"`
	Usage                string   `protobuf:"bytes,13,opt,name=Usage,proto3" json:"Usage,omitempty"`
	Ephemeral            bool     `protobuf:"varint,14,opt,name=Ephemeral,proto3" json:"Ephemeral,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Volume) Descriptor 

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

func (*Volume) GetCSIStatus 

func (m *Volume) GetCSIStatus() string

func (*Volume) GetEphemeral 

func (m *Volume) GetEphemeral() bool

func (*Volume) GetHealth 

func (m *Volume) GetHealth() string

func (*Volume) GetId 

func (m *Volume) GetId() string

func (*Volume) GetLocation 

func (m *Volume) GetLocation() string

func (*Volume) GetLocationType 

func (m *Volume) GetLocationType() string

func (*Volume) GetMode 

func (m *Volume) GetMode() string

func (*Volume) GetNodeId 

func (m *Volume) GetNodeId() string

func (*Volume) GetOperationalStatus 

func (m *Volume) GetOperationalStatus() string

func (*Volume) GetOwners 

func (m *Volume) GetOwners() []string

func (*Volume) GetSize 

func (m *Volume) GetSize() int64

func (*Volume) GetStorageClass 

func (m *Volume) GetStorageClass() string

func (*Volume) GetType 

func (m *Volume) GetType() string

func (*Volume) GetUsage 

func (m *Volume) GetUsage() string

func (*Volume) ProtoMessage 

func (*Volume) ProtoMessage()

func (*Volume) Reset 

func (m *Volume) Reset()

func (*Volume) String 

func (m *Volume) String() string

func (*Volume) XXX_DiscardUnknown 

func (m *Volume) XXX_DiscardUnknown()

func (*Volume) XXX_Marshal 

func (m *Volume) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Volume) XXX_Merge 

func (m *Volume) XXX_Merge(src proto.Message)

func (*Volume) XXX_Size 

func (m *Volume) XXX_Size() int

func (*Volume) XXX_Unmarshal 

func (m *Volume) XXX_Unmarshal(b []byte) 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.