pmemcsidriver

Jul 16, 2021

Changes in this version

type DriverMode

+ const ForceConvertRawNamespaces

Mar 16, 2021

Changes in this version

type Config

+ KubeAPIBurst int

+ KubeAPIQPS float64

type DriverMode

+ const Webhooks

Oct 7, 2020

Changes in this version

+ var DriverTopologyKey = ""

+ func GetCSIDriver(cfg Config) (*csiDriver, error)

type Config

+ PmemPercentage uint

Jun 11, 2020

Changes in this version

+ func GenerateVolumeID(caller string, name string) string

type DriverMode

+ func (mode *DriverMode) Set(value string) error

+ func (mode *DriverMode) String() string

Aug 2, 2019

Changes in this version

+ func Main() int

type Config

+ StateBasePath string

+ TestEndpoint bool

+ Version string

Mar 6, 2019

Changes in this version

+ func GetPMEMDriver(cfg Config) (*pmemDriver, error)

+ func NewIdentityServer(name, version string) (*identityServer, error)

+ func NewMasterControllerServer(rs *registryServer) *masterController

+ func NewNodeControllerServer(nodeID string, dm pmdmanager.PmemDeviceManager) *nodeControllerServer

+ func NewNodeServer(nodeId string, dm pmdmanager.PmemDeviceManager) *nodeServer

+ func NewRegistryServer(tlsConfig *tls.Config) *registryServer

+ type Config struct

+ CAFile string

+ CertFile string

+ ClientCertFile string

+ ClientKeyFile string

+ ControllerEndpoint string

+ DeviceManager string

+ DriverName string

+ Endpoint string

+ KeyFile string

+ Mode DriverMode

+ NodeID string

+ RegistryEndpoint string

+ type DefaultControllerServer struct

+ func NewDefaultControllerServer(caps []csi.ControllerServiceCapability_RPC_Type) *DefaultControllerServer

+ func (cs *DefaultControllerServer) ControllerGetCapabilities(ctx context.Context, req *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error)

+ func (cs *DefaultControllerServer) ControllerPublishVolume(ctx context.Context, req *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error)

+ func (cs *DefaultControllerServer) ControllerUnpublishVolume(ctx context.Context, req *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error)

+ func (cs *DefaultControllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error)

+ func (cs *DefaultControllerServer) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error)

+ func (cs *DefaultControllerServer) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error)

+ func (cs *DefaultControllerServer) DeleteVolume(ctx context.Context, req *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error)

+ func (cs *DefaultControllerServer) GetCapacity(ctx context.Context, req *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error)

+ func (cs *DefaultControllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error)

+ func (cs *DefaultControllerServer) ListVolumes(ctx context.Context, req *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error)

+ func (cs *DefaultControllerServer) ValidateControllerServiceRequest(c csi.ControllerServiceCapability_RPC_Type) error

+ type DriverMode string

+ const Controller

+ const Node

+ const PmemDriverTopologyKey

+ const Unified

+ type NodeInfo struct

+ Endpoint string

+ NodeID string

+ type NonBlockingGRPCServer struct

+ func NewNonBlockingGRPCServer() *NonBlockingGRPCServer

+ func (s *NonBlockingGRPCServer) ForceStop()

+ func (s *NonBlockingGRPCServer) Start(endpoint string, tlsConfig *tls.Config, services ...PmemService) error

+ func (s *NonBlockingGRPCServer) Stop()

+ func (s *NonBlockingGRPCServer) Wait()

+ type PmemPersistencyModel string

+ type PmemService interface

+ RegisterService func(s *grpc.Server)

+ type VolumeStatus int

+ const Attached

+ const Created

+ const Deleted

+ const Unattached