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.