Documentation ¶
Index ¶
- Variables
- func RegisterIdentityServer(s grpc.ServiceRegistrar, srv IdentityServer)
- type Capability
- func (*Capability) Descriptor() ([]byte, []int)deprecated
- func (x *Capability) GetNetworkFence() *Capability_NetworkFence
- func (x *Capability) GetReclaimSpace() *Capability_ReclaimSpace
- func (x *Capability) GetService() *Capability_Service
- func (m *Capability) GetType() isCapability_Type
- func (x *Capability) GetVolumeReplication() *Capability_VolumeReplication
- func (*Capability) ProtoMessage()
- func (x *Capability) ProtoReflect() protoreflect.Message
- func (x *Capability) Reset()
- func (x *Capability) String() string
- type Capability_NetworkFence
- func (*Capability_NetworkFence) Descriptor() ([]byte, []int)deprecated
- func (x *Capability_NetworkFence) GetType() Capability_NetworkFence_Type
- func (*Capability_NetworkFence) ProtoMessage()
- func (x *Capability_NetworkFence) ProtoReflect() protoreflect.Message
- func (x *Capability_NetworkFence) Reset()
- func (x *Capability_NetworkFence) String() string
- type Capability_NetworkFence_
- type Capability_NetworkFence_Type
- func (Capability_NetworkFence_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Capability_NetworkFence_Type) Enum() *Capability_NetworkFence_Type
- func (Capability_NetworkFence_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Capability_NetworkFence_Type) Number() protoreflect.EnumNumber
- func (x Capability_NetworkFence_Type) String() string
- func (Capability_NetworkFence_Type) Type() protoreflect.EnumType
- type Capability_ReclaimSpace
- func (*Capability_ReclaimSpace) Descriptor() ([]byte, []int)deprecated
- func (x *Capability_ReclaimSpace) GetType() Capability_ReclaimSpace_Type
- func (*Capability_ReclaimSpace) ProtoMessage()
- func (x *Capability_ReclaimSpace) ProtoReflect() protoreflect.Message
- func (x *Capability_ReclaimSpace) Reset()
- func (x *Capability_ReclaimSpace) String() string
- type Capability_ReclaimSpace_
- type Capability_ReclaimSpace_Type
- func (Capability_ReclaimSpace_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Capability_ReclaimSpace_Type) Enum() *Capability_ReclaimSpace_Type
- func (Capability_ReclaimSpace_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Capability_ReclaimSpace_Type) Number() protoreflect.EnumNumber
- func (x Capability_ReclaimSpace_Type) String() string
- func (Capability_ReclaimSpace_Type) Type() protoreflect.EnumType
- type Capability_Service
- func (*Capability_Service) Descriptor() ([]byte, []int)deprecated
- func (x *Capability_Service) GetType() Capability_Service_Type
- func (*Capability_Service) ProtoMessage()
- func (x *Capability_Service) ProtoReflect() protoreflect.Message
- func (x *Capability_Service) Reset()
- func (x *Capability_Service) String() string
- type Capability_Service_
- type Capability_Service_Type
- func (Capability_Service_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Capability_Service_Type) Enum() *Capability_Service_Type
- func (Capability_Service_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Capability_Service_Type) Number() protoreflect.EnumNumber
- func (x Capability_Service_Type) String() string
- func (Capability_Service_Type) Type() protoreflect.EnumType
- type Capability_VolumeReplication
- func (*Capability_VolumeReplication) Descriptor() ([]byte, []int)deprecated
- func (x *Capability_VolumeReplication) GetType() Capability_VolumeReplication_Type
- func (*Capability_VolumeReplication) ProtoMessage()
- func (x *Capability_VolumeReplication) ProtoReflect() protoreflect.Message
- func (x *Capability_VolumeReplication) Reset()
- func (x *Capability_VolumeReplication) String() string
- type Capability_VolumeReplication_
- type Capability_VolumeReplication_Type
- func (Capability_VolumeReplication_Type) Descriptor() protoreflect.EnumDescriptor
- func (x Capability_VolumeReplication_Type) Enum() *Capability_VolumeReplication_Type
- func (Capability_VolumeReplication_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x Capability_VolumeReplication_Type) Number() protoreflect.EnumNumber
- func (x Capability_VolumeReplication_Type) String() string
- func (Capability_VolumeReplication_Type) Type() protoreflect.EnumType
- type GetCapabilitiesRequest
- type GetCapabilitiesResponse
- func (*GetCapabilitiesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetCapabilitiesResponse) GetCapabilities() []*Capability
- func (*GetCapabilitiesResponse) ProtoMessage()
- func (x *GetCapabilitiesResponse) ProtoReflect() protoreflect.Message
- func (x *GetCapabilitiesResponse) Reset()
- func (x *GetCapabilitiesResponse) String() string
- type GetIdentityRequest
- type GetIdentityResponse
- func (*GetIdentityResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetIdentityResponse) GetManifest() map[string]string
- func (x *GetIdentityResponse) GetName() string
- func (x *GetIdentityResponse) GetVendorVersion() string
- func (*GetIdentityResponse) ProtoMessage()
- func (x *GetIdentityResponse) ProtoReflect() protoreflect.Message
- func (x *GetIdentityResponse) Reset()
- func (x *GetIdentityResponse) String() string
- type IdentityClient
- type IdentityServer
- type ProbeRequest
- type ProbeResponse
- type UnimplementedIdentityServer
- func (UnimplementedIdentityServer) GetCapabilities(context.Context, *GetCapabilitiesRequest) (*GetCapabilitiesResponse, error)
- func (UnimplementedIdentityServer) GetIdentity(context.Context, *GetIdentityRequest) (*GetIdentityResponse, error)
- func (UnimplementedIdentityServer) Probe(context.Context, *ProbeRequest) (*ProbeResponse, error)
- type UnsafeIdentityServer
Constants ¶
This section is empty.
Variables ¶
var ( Capability_Service_Type_name = map[int32]string{ 0: "UNKNOWN", 1: "CONTROLLER_SERVICE", 2: "NODE_SERVICE", } Capability_Service_Type_value = map[string]int32{ "UNKNOWN": 0, "CONTROLLER_SERVICE": 1, "NODE_SERVICE": 2, } )
Enum value maps for Capability_Service_Type.
var ( Capability_ReclaimSpace_Type_name = map[int32]string{ 0: "UNKNOWN", 1: "OFFLINE", 2: "ONLINE", } Capability_ReclaimSpace_Type_value = map[string]int32{ "UNKNOWN": 0, "OFFLINE": 1, "ONLINE": 2, } )
Enum value maps for Capability_ReclaimSpace_Type.
var ( Capability_NetworkFence_Type_name = map[int32]string{ 0: "UNKNOWN", 1: "NETWORK_FENCE", } Capability_NetworkFence_Type_value = map[string]int32{ "UNKNOWN": 0, "NETWORK_FENCE": 1, } )
Enum value maps for Capability_NetworkFence_Type.
var ( Capability_VolumeReplication_Type_name = map[int32]string{ 0: "UNKNOWN", 1: "VOLUME_REPLICATION", } Capability_VolumeReplication_Type_value = map[string]int32{ "UNKNOWN": 0, "VOLUME_REPLICATION": 1, } )
Enum value maps for Capability_VolumeReplication_Type.
var File_identity_identity_proto protoreflect.FileDescriptor
var Identity_ServiceDesc = grpc.ServiceDesc{ ServiceName: "identity.Identity", HandlerType: (*IdentityServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetIdentity", Handler: _Identity_GetIdentity_Handler, }, { MethodName: "GetCapabilities", Handler: _Identity_GetCapabilities_Handler, }, { MethodName: "Probe", Handler: _Identity_Probe_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "identity/identity.proto", }
Identity_ServiceDesc is the grpc.ServiceDesc for Identity service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIdentityServer ¶
func RegisterIdentityServer(s grpc.ServiceRegistrar, srv IdentityServer)
Types ¶
type Capability ¶
type Capability struct { // Types that are assignable to Type: // *Capability_Service_ // *Capability_ReclaimSpace_ // *Capability_NetworkFence_ // *Capability_VolumeReplication_ Type isCapability_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
Specifies one or more capabilities of the CSI-driver.
func (*Capability) Descriptor
deprecated
func (*Capability) Descriptor() ([]byte, []int)
Deprecated: Use Capability.ProtoReflect.Descriptor instead.
func (*Capability) GetNetworkFence ¶
func (x *Capability) GetNetworkFence() *Capability_NetworkFence
func (*Capability) GetReclaimSpace ¶
func (x *Capability) GetReclaimSpace() *Capability_ReclaimSpace
func (*Capability) GetService ¶
func (x *Capability) GetService() *Capability_Service
func (*Capability) GetType ¶
func (m *Capability) GetType() isCapability_Type
func (*Capability) GetVolumeReplication ¶
func (x *Capability) GetVolumeReplication() *Capability_VolumeReplication
func (*Capability) ProtoMessage ¶
func (*Capability) ProtoMessage()
func (*Capability) ProtoReflect ¶
func (x *Capability) ProtoReflect() protoreflect.Message
func (*Capability) Reset ¶
func (x *Capability) Reset()
func (*Capability) String ¶
func (x *Capability) String() string
type Capability_NetworkFence ¶
type Capability_NetworkFence struct { // type contains the Type of CSI Service that the CSI-driver supports. Type Capability_NetworkFence_Type `protobuf:"varint,1,opt,name=type,proto3,enum=identity.Capability_NetworkFence_Type" json:"type,omitempty"` // contains filtered or unexported fields }
NetworkFence contains the features of the NetworkFence operation that the CSI-driver supports.
func (*Capability_NetworkFence) Descriptor
deprecated
func (*Capability_NetworkFence) Descriptor() ([]byte, []int)
Deprecated: Use Capability_NetworkFence.ProtoReflect.Descriptor instead.
func (*Capability_NetworkFence) GetType ¶
func (x *Capability_NetworkFence) GetType() Capability_NetworkFence_Type
func (*Capability_NetworkFence) ProtoMessage ¶
func (*Capability_NetworkFence) ProtoMessage()
func (*Capability_NetworkFence) ProtoReflect ¶
func (x *Capability_NetworkFence) ProtoReflect() protoreflect.Message
func (*Capability_NetworkFence) Reset ¶
func (x *Capability_NetworkFence) Reset()
func (*Capability_NetworkFence) String ¶
func (x *Capability_NetworkFence) String() string
type Capability_NetworkFence_ ¶
type Capability_NetworkFence_ struct { // NetworkFence operation capabilities NetworkFence *Capability_NetworkFence `protobuf:"bytes,3,opt,name=network_fence,json=networkFence,proto3,oneof"` }
type Capability_NetworkFence_Type ¶
type Capability_NetworkFence_Type int32
Type describes a CSI Service that CSI-drivers can support.
const ( // UNKNOWN indicates that the CSI-driver does not support the NetworkFence // operation in the current mode. The CSI-Addons CO plugin will most // likely ignore this node for the NetworkFence operation. Capability_NetworkFence_UNKNOWN Capability_NetworkFence_Type = 0 // NETWORK_FENCE indicates that the CSI-driver provides RPCs for a // NetworkFence operation. // The presence of this capability determines whether the CSI-Addons CO // plugin can invoke RPCs that require access to the storage system, // similar to the CSI Controller (provisioner). Capability_NetworkFence_NETWORK_FENCE Capability_NetworkFence_Type = 1 )
func (Capability_NetworkFence_Type) Descriptor ¶
func (Capability_NetworkFence_Type) Descriptor() protoreflect.EnumDescriptor
func (Capability_NetworkFence_Type) Enum ¶
func (x Capability_NetworkFence_Type) Enum() *Capability_NetworkFence_Type
func (Capability_NetworkFence_Type) EnumDescriptor
deprecated
func (Capability_NetworkFence_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Capability_NetworkFence_Type.Descriptor instead.
func (Capability_NetworkFence_Type) Number ¶
func (x Capability_NetworkFence_Type) Number() protoreflect.EnumNumber
func (Capability_NetworkFence_Type) String ¶
func (x Capability_NetworkFence_Type) String() string
func (Capability_NetworkFence_Type) Type ¶
func (Capability_NetworkFence_Type) Type() protoreflect.EnumType
type Capability_ReclaimSpace ¶
type Capability_ReclaimSpace struct { // type contains the Type of CSI Service that the CSI-driver supports. Type Capability_ReclaimSpace_Type `protobuf:"varint,1,opt,name=type,proto3,enum=identity.Capability_ReclaimSpace_Type" json:"type,omitempty"` // contains filtered or unexported fields }
ReclaimSpace contains the features of the ReclaimSpace operation that the CSI-driver supports.
func (*Capability_ReclaimSpace) Descriptor
deprecated
func (*Capability_ReclaimSpace) Descriptor() ([]byte, []int)
Deprecated: Use Capability_ReclaimSpace.ProtoReflect.Descriptor instead.
func (*Capability_ReclaimSpace) GetType ¶
func (x *Capability_ReclaimSpace) GetType() Capability_ReclaimSpace_Type
func (*Capability_ReclaimSpace) ProtoMessage ¶
func (*Capability_ReclaimSpace) ProtoMessage()
func (*Capability_ReclaimSpace) ProtoReflect ¶
func (x *Capability_ReclaimSpace) ProtoReflect() protoreflect.Message
func (*Capability_ReclaimSpace) Reset ¶
func (x *Capability_ReclaimSpace) Reset()
func (*Capability_ReclaimSpace) String ¶
func (x *Capability_ReclaimSpace) String() string
type Capability_ReclaimSpace_ ¶
type Capability_ReclaimSpace_ struct { // ReclaimSpace operation capabilities. ReclaimSpace *Capability_ReclaimSpace `protobuf:"bytes,2,opt,name=reclaim_space,json=reclaimSpace,proto3,oneof"` }
type Capability_ReclaimSpace_Type ¶
type Capability_ReclaimSpace_Type int32
Type describes a CSI Service that CSI-drivers can support.
const ( // UNKNOWN indicates that the CSI-driver does not support the ReclaimSpace // operation in the current mode. The CSI-driver may be able to support // the operation when is it configured differently. The CSI-Addons CO // plugin will most likely ignore this node for the ReclaimSpace // operation. Capability_ReclaimSpace_UNKNOWN Capability_ReclaimSpace_Type = 0 // OFFLINE indicates that the CSI-driver provides RPCs for an offline // ReclaimSpace operation. // The presence of this capability determines whether the CSI-Addons CO // plugin can invoke RPCs that require access to the storage system, // similar to the CSI Controller (provisioner). Capability_ReclaimSpace_OFFLINE Capability_ReclaimSpace_Type = 1 // ONLINE indicates that the CSI-driver provides RPCs for an online // ReclaimSpace operation. // The presence of this capability determines whether the CSI-Addons CO // plugin can invoke RPCs that require a volume to be staged/attached to // the node. Capability_ReclaimSpace_ONLINE Capability_ReclaimSpace_Type = 2 )
func (Capability_ReclaimSpace_Type) Descriptor ¶
func (Capability_ReclaimSpace_Type) Descriptor() protoreflect.EnumDescriptor
func (Capability_ReclaimSpace_Type) Enum ¶
func (x Capability_ReclaimSpace_Type) Enum() *Capability_ReclaimSpace_Type
func (Capability_ReclaimSpace_Type) EnumDescriptor
deprecated
func (Capability_ReclaimSpace_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Capability_ReclaimSpace_Type.Descriptor instead.
func (Capability_ReclaimSpace_Type) Number ¶
func (x Capability_ReclaimSpace_Type) Number() protoreflect.EnumNumber
func (Capability_ReclaimSpace_Type) String ¶
func (x Capability_ReclaimSpace_Type) String() string
func (Capability_ReclaimSpace_Type) Type ¶
func (Capability_ReclaimSpace_Type) Type() protoreflect.EnumType
type Capability_Service ¶
type Capability_Service struct { // type contains the Type of CSI Service that the CSI-driver supports. Type Capability_Service_Type `protobuf:"varint,1,opt,name=type,proto3,enum=identity.Capability_Service_Type" json:"type,omitempty"` // contains filtered or unexported fields }
Service contains the type of CSI Service that the CSI-driver provides.
func (*Capability_Service) Descriptor
deprecated
func (*Capability_Service) Descriptor() ([]byte, []int)
Deprecated: Use Capability_Service.ProtoReflect.Descriptor instead.
func (*Capability_Service) GetType ¶
func (x *Capability_Service) GetType() Capability_Service_Type
func (*Capability_Service) ProtoMessage ¶
func (*Capability_Service) ProtoMessage()
func (*Capability_Service) ProtoReflect ¶
func (x *Capability_Service) ProtoReflect() protoreflect.Message
func (*Capability_Service) Reset ¶
func (x *Capability_Service) Reset()
func (*Capability_Service) String ¶
func (x *Capability_Service) String() string
type Capability_Service_ ¶
type Capability_Service_ struct { // Service or operation that the CSI-driver supports. Service *Capability_Service `protobuf:"bytes,1,opt,name=service,proto3,oneof"` }
type Capability_Service_Type ¶
type Capability_Service_Type int32
Type describes a CSI Service that CSI-drivers can support.
const ( // UNKNOWN indicates that the CSI-driver does not neither provide the CSI // ControllerService or CSI NodeService. The CSI-Addons CO plugin will // most likely ignore the node providing this Identity Service. Capability_Service_UNKNOWN Capability_Service_Type = 0 // CONTROLLER_SERVICE indicates that the CSI-driver provides RPCs for the // CSI ControllerService. // The presence of this capability determines whether the CSI-Addons CO // plugin can invoke RPCs that require access to the storage system, // similar to the CSI Controller (provisioner). Capability_Service_CONTROLLER_SERVICE Capability_Service_Type = 1 // NODE_SERVICE indicates that the CSI-driver provides RPCs for the CSI // NodeService. // The presence of this capability determines whether the CSI-Addons CO // plugin can invoke RPCs that require a volume to be staged/attached to // the node. Capability_Service_NODE_SERVICE Capability_Service_Type = 2 )
func (Capability_Service_Type) Descriptor ¶
func (Capability_Service_Type) Descriptor() protoreflect.EnumDescriptor
func (Capability_Service_Type) Enum ¶
func (x Capability_Service_Type) Enum() *Capability_Service_Type
func (Capability_Service_Type) EnumDescriptor
deprecated
func (Capability_Service_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Capability_Service_Type.Descriptor instead.
func (Capability_Service_Type) Number ¶
func (x Capability_Service_Type) Number() protoreflect.EnumNumber
func (Capability_Service_Type) String ¶
func (x Capability_Service_Type) String() string
func (Capability_Service_Type) Type ¶
func (Capability_Service_Type) Type() protoreflect.EnumType
type Capability_VolumeReplication ¶
type Capability_VolumeReplication struct { // type contains the Type of CSI Service that the CSI-driver supports. Type Capability_VolumeReplication_Type `protobuf:"varint,1,opt,name=type,proto3,enum=identity.Capability_VolumeReplication_Type" json:"type,omitempty"` // contains filtered or unexported fields }
VolumeReplication contains the features of the volumereplication operation that the CSI-driver supports.
func (*Capability_VolumeReplication) Descriptor
deprecated
func (*Capability_VolumeReplication) Descriptor() ([]byte, []int)
Deprecated: Use Capability_VolumeReplication.ProtoReflect.Descriptor instead.
func (*Capability_VolumeReplication) GetType ¶
func (x *Capability_VolumeReplication) GetType() Capability_VolumeReplication_Type
func (*Capability_VolumeReplication) ProtoMessage ¶
func (*Capability_VolumeReplication) ProtoMessage()
func (*Capability_VolumeReplication) ProtoReflect ¶
func (x *Capability_VolumeReplication) ProtoReflect() protoreflect.Message
func (*Capability_VolumeReplication) Reset ¶
func (x *Capability_VolumeReplication) Reset()
func (*Capability_VolumeReplication) String ¶
func (x *Capability_VolumeReplication) String() string
type Capability_VolumeReplication_ ¶
type Capability_VolumeReplication_ struct { // VolumeReplication operation capabilities. VolumeReplication *Capability_VolumeReplication `protobuf:"bytes,4,opt,name=volume_replication,json=volumeReplication,proto3,oneof"` }
type Capability_VolumeReplication_Type ¶
type Capability_VolumeReplication_Type int32
Type describes a CSI Service that CSI-drivers can support.
const ( // UNKNOWN indicates that the CSI-driver does not support the // VolumeReplication operation in the current mode. The CSI-Addons CO // plugin will most likely ignore this node for the // VolumeReplication operation. Capability_VolumeReplication_UNKNOWN Capability_VolumeReplication_Type = 0 // VOLUME_REPLICATION indicates that the CSI-driver provides RPCs for a // VolumeReplication operation. // The presence of this capability determines whether the CSI-Addons CO // plugin can invoke RPCs that require access to the storage system, // similar to the CSI Controller (provisioner). Capability_VolumeReplication_VOLUME_REPLICATION Capability_VolumeReplication_Type = 1 )
func (Capability_VolumeReplication_Type) Descriptor ¶
func (Capability_VolumeReplication_Type) Descriptor() protoreflect.EnumDescriptor
func (Capability_VolumeReplication_Type) Enum ¶
func (x Capability_VolumeReplication_Type) Enum() *Capability_VolumeReplication_Type
func (Capability_VolumeReplication_Type) EnumDescriptor
deprecated
func (Capability_VolumeReplication_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use Capability_VolumeReplication_Type.Descriptor instead.
func (Capability_VolumeReplication_Type) Number ¶
func (x Capability_VolumeReplication_Type) Number() protoreflect.EnumNumber
func (Capability_VolumeReplication_Type) String ¶
func (x Capability_VolumeReplication_Type) String() string
func (Capability_VolumeReplication_Type) Type ¶
func (Capability_VolumeReplication_Type) Type() protoreflect.EnumType
type GetCapabilitiesRequest ¶
type GetCapabilitiesRequest struct {
// contains filtered or unexported fields
}
GetCapabilitiesRequest is sent by the CSI-Addons CO plugin to detect the features that a CSI-driver supports.
func (*GetCapabilitiesRequest) Descriptor
deprecated
func (*GetCapabilitiesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetCapabilitiesRequest.ProtoReflect.Descriptor instead.
func (*GetCapabilitiesRequest) ProtoMessage ¶
func (*GetCapabilitiesRequest) ProtoMessage()
func (*GetCapabilitiesRequest) ProtoReflect ¶
func (x *GetCapabilitiesRequest) ProtoReflect() protoreflect.Message
func (*GetCapabilitiesRequest) Reset ¶
func (x *GetCapabilitiesRequest) Reset()
func (*GetCapabilitiesRequest) String ¶
func (x *GetCapabilitiesRequest) String() string
type GetCapabilitiesResponse ¶
type GetCapabilitiesResponse struct { // All the capabilities that the controller service supports. This // field is OPTIONAL. Capabilities []*Capability `protobuf:"bytes,1,rep,name=capabilities,proto3" json:"capabilities,omitempty"` // contains filtered or unexported fields }
GetCapabilitiesResponse is returned by the CSI-driver as a response to a GetCapabilitiesRequest.
func (*GetCapabilitiesResponse) Descriptor
deprecated
func (*GetCapabilitiesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetCapabilitiesResponse.ProtoReflect.Descriptor instead.
func (*GetCapabilitiesResponse) GetCapabilities ¶
func (x *GetCapabilitiesResponse) GetCapabilities() []*Capability
func (*GetCapabilitiesResponse) ProtoMessage ¶
func (*GetCapabilitiesResponse) ProtoMessage()
func (*GetCapabilitiesResponse) ProtoReflect ¶
func (x *GetCapabilitiesResponse) ProtoReflect() protoreflect.Message
func (*GetCapabilitiesResponse) Reset ¶
func (x *GetCapabilitiesResponse) Reset()
func (*GetCapabilitiesResponse) String ¶
func (x *GetCapabilitiesResponse) String() string
type GetIdentityRequest ¶
type GetIdentityRequest struct {
// contains filtered or unexported fields
}
GetIdentityRequest is sent by the CSI-Addons CO plugin to obtain the drivername, version and optional details from the CSI-driver.
func (*GetIdentityRequest) Descriptor
deprecated
func (*GetIdentityRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetIdentityRequest.ProtoReflect.Descriptor instead.
func (*GetIdentityRequest) ProtoMessage ¶
func (*GetIdentityRequest) ProtoMessage()
func (*GetIdentityRequest) ProtoReflect ¶
func (x *GetIdentityRequest) ProtoReflect() protoreflect.Message
func (*GetIdentityRequest) Reset ¶
func (x *GetIdentityRequest) Reset()
func (*GetIdentityRequest) String ¶
func (x *GetIdentityRequest) String() string
type GetIdentityResponse ¶
type GetIdentityResponse struct { // The name MUST follow domain name notation format // (https://tools.ietf.org/html/rfc1035#section-2.3.1). It SHOULD include // the CSI-drivers's host company name and the CSI-driver name, to minimize // the possibility of collisions. It MUST be 63 characters or less, beginning // and ending with an alphanumeric character ([a-z0-9A-Z]) with dashes (-), // dots (.), and alphanumerics between. This field is REQUIRED. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // This field is REQUIRED. Value of this field is opaque to the CO. VendorVersion string `protobuf:"bytes,2,opt,name=vendor_version,json=vendorVersion,proto3" json:"vendor_version,omitempty"` // This field is OPTIONAL. Values are opaque to the CO. Manifest map[string]string `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
GetIdentityResponse is returned by the CSI-driver as a response to a GetIdentityRequest.
func (*GetIdentityResponse) Descriptor
deprecated
func (*GetIdentityResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetIdentityResponse.ProtoReflect.Descriptor instead.
func (*GetIdentityResponse) GetManifest ¶
func (x *GetIdentityResponse) GetManifest() map[string]string
func (*GetIdentityResponse) GetName ¶
func (x *GetIdentityResponse) GetName() string
func (*GetIdentityResponse) GetVendorVersion ¶
func (x *GetIdentityResponse) GetVendorVersion() string
func (*GetIdentityResponse) ProtoMessage ¶
func (*GetIdentityResponse) ProtoMessage()
func (*GetIdentityResponse) ProtoReflect ¶
func (x *GetIdentityResponse) ProtoReflect() protoreflect.Message
func (*GetIdentityResponse) Reset ¶
func (x *GetIdentityResponse) Reset()
func (*GetIdentityResponse) String ¶
func (x *GetIdentityResponse) String() string
type IdentityClient ¶
type IdentityClient interface { // GetIdentity returns basic information about the side-car and CSI-driver. GetIdentity(ctx context.Context, in *GetIdentityRequest, opts ...grpc.CallOption) (*GetIdentityResponse, error) // GetCapabilities returns the capabilities that the CSI-driver supports. GetCapabilities(ctx context.Context, in *GetCapabilitiesRequest, opts ...grpc.CallOption) (*GetCapabilitiesResponse, error) // Probe is called by the CO plugin to validate that the CSI-Addons Node is // still healthy. Probe(ctx context.Context, in *ProbeRequest, opts ...grpc.CallOption) (*ProbeResponse, error) }
IdentityClient is the client API for Identity service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIdentityClient ¶
func NewIdentityClient(cc grpc.ClientConnInterface) IdentityClient
type IdentityServer ¶
type IdentityServer interface { // GetIdentity returns basic information about the side-car and CSI-driver. GetIdentity(context.Context, *GetIdentityRequest) (*GetIdentityResponse, error) // GetCapabilities returns the capabilities that the CSI-driver supports. GetCapabilities(context.Context, *GetCapabilitiesRequest) (*GetCapabilitiesResponse, error) // Probe is called by the CO plugin to validate that the CSI-Addons Node is // still healthy. Probe(context.Context, *ProbeRequest) (*ProbeResponse, error) // contains filtered or unexported methods }
IdentityServer is the server API for Identity service. All implementations must embed UnimplementedIdentityServer for forward compatibility
type ProbeRequest ¶
type ProbeRequest struct {
// contains filtered or unexported fields
}
ProbeRequest is sent to the CSI-driver to confirm that it can respond to requests from the CSI-Addons CO plugin.
func (*ProbeRequest) Descriptor
deprecated
func (*ProbeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ProbeRequest.ProtoReflect.Descriptor instead.
func (*ProbeRequest) ProtoMessage ¶
func (*ProbeRequest) ProtoMessage()
func (*ProbeRequest) ProtoReflect ¶
func (x *ProbeRequest) ProtoReflect() protoreflect.Message
func (*ProbeRequest) Reset ¶
func (x *ProbeRequest) Reset()
func (*ProbeRequest) String ¶
func (x *ProbeRequest) String() string
type ProbeResponse ¶
type ProbeResponse struct { // Readiness allows a CSI-driver to report its initialization status back // to the CSI-Addons CO plugin. Initialization for some CSI-drivers MAY be // time consuming and it is important for a CO to distinguish between the // following cases: // // 1) The CSI-driver is in an unhealthy state and MAY need restarting. In // this case a gRPC error code SHALL be returned. // 2) The CSI-driver is still initializing, but is otherwise perfectly // healthy. In this case a successful response SHALL be returned // with a readiness value of `false`. Calls to the CSI-driver's // Controller and/or Node services MAY fail due to an incomplete // initialization state. // 3) The CSI-driver has finished initializing and is ready to service // calls to its Controller and/or Node services. A successful // response is returned with a readiness value of `true`. // // This field is OPTIONAL. If not present, the caller SHALL assume // that the CSI-driver is in a ready state and is accepting calls to its // Controller and/or Node services (according to the CSI-driver's reported // capabilities). Ready *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=ready,proto3" json:"ready,omitempty"` // contains filtered or unexported fields }
ProbeResponse is returned by the CSI-driver as a response to a ProbeRequest.
func (*ProbeResponse) Descriptor
deprecated
func (*ProbeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ProbeResponse.ProtoReflect.Descriptor instead.
func (*ProbeResponse) GetReady ¶
func (x *ProbeResponse) GetReady() *wrapperspb.BoolValue
func (*ProbeResponse) ProtoMessage ¶
func (*ProbeResponse) ProtoMessage()
func (*ProbeResponse) ProtoReflect ¶
func (x *ProbeResponse) ProtoReflect() protoreflect.Message
func (*ProbeResponse) Reset ¶
func (x *ProbeResponse) Reset()
func (*ProbeResponse) String ¶
func (x *ProbeResponse) String() string
type UnimplementedIdentityServer ¶
type UnimplementedIdentityServer struct { }
UnimplementedIdentityServer must be embedded to have forward compatible implementations.
func (UnimplementedIdentityServer) GetCapabilities ¶
func (UnimplementedIdentityServer) GetCapabilities(context.Context, *GetCapabilitiesRequest) (*GetCapabilitiesResponse, error)
func (UnimplementedIdentityServer) GetIdentity ¶
func (UnimplementedIdentityServer) GetIdentity(context.Context, *GetIdentityRequest) (*GetIdentityResponse, error)
func (UnimplementedIdentityServer) Probe ¶
func (UnimplementedIdentityServer) Probe(context.Context, *ProbeRequest) (*ProbeResponse, error)
type UnsafeIdentityServer ¶
type UnsafeIdentityServer interface {
// contains filtered or unexported methods
}
UnsafeIdentityServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IdentityServer will result in compilation errors.