Versions in this module Expand all Collapse all v0 v0.2.0 May 11, 2018 Changes in this version + const PluginName + const PluginVersion + var ErrBlockVolNoRO = status.Error(codes.InvalidArgument, "Cannot publish block volume as readonly.") + var ErrCallNotImplemented = status.Error(codes.Unimplemented, "That RPC is not implemented.") + var ErrCapacityRangeInvalidSize = status.Error(codes.InvalidArgument, "The required_bytes cannot exceed the limit_bytes.") + var ErrCapacityRangeUnspecified = status.Error(codes.InvalidArgument, ...) + var ErrInsufficientCapacity = status.Error(codes.OutOfRange, "Not enough free space") + var ErrInvalidAccessMode = status.Error(codes.InvalidArgument, "The volume_capability.access_mode.mode is invalid.") + var ErrMismatchedFilesystemType = status.Error(codes.InvalidArgument, ...) + var ErrMissingAccessMode = status.Error(codes.InvalidArgument, ...) + var ErrMissingAccessModeMode = status.Error(codes.InvalidArgument, ...) + var ErrMissingAccessType = status.Error(codes.InvalidArgument, ...) + var ErrMissingName = status.Error(codes.InvalidArgument, "The name field must be specified.") + var ErrMissingTargetPath = status.Error(codes.InvalidArgument, "The target_path field must be specified.") + var ErrMissingVolumeCapabilities = status.Error(codes.InvalidArgument, "The volume_capabilities field must be specified.") + var ErrMissingVolumeCapability = status.Error(codes.InvalidArgument, "The volume_capability field must be specified.") + var ErrMissingVolumeId = status.Error(codes.InvalidArgument, "The volume_id field must be specified.") + var ErrRemovingMode = status.Error(codes.FailedPrecondition, ...) + var ErrSpecifiedPublishInfo = status.Error(codes.InvalidArgument, "The publish_volume_info field must not be specified.") + var ErrTargetPathNotEmpty = status.Error(codes.InvalidArgument, "Unexpected device already mounted at targetPath.") + var ErrTargetPathRO = status.Error(codes.InvalidArgument, "The targetPath is already mounted readonly.") + var ErrTargetPathRW = status.Error(codes.InvalidArgument, "The targetPath is already mounted read-write.") + var ErrUnsupportedAccessMode = status.Error(codes.InvalidArgument, ...) + var ErrUnsupportedFilesystem = status.Error(codes.FailedPrecondition, "The requested filesystem type is unknown.") + var ErrVolumeAlreadyExists = status.Error(codes.AlreadyExists, "The volume already exists") + var ErrVolumeNotFound = status.Error(codes.NotFound, "The volume does not exist.") + func ChainStreamClient(interceptors ...grpc.StreamClientInterceptor) grpc.StreamClientInterceptor + func ChainStreamServer(interceptors ...grpc.StreamServerInterceptor) grpc.StreamServerInterceptor + func ChainUnaryClient(interceptors ...grpc.UnaryClientInterceptor) grpc.UnaryClientInterceptor + func ChainUnaryServer(interceptors ...grpc.UnaryServerInterceptor) grpc.UnaryServerInterceptor + func LoggingInterceptor() grpc.UnaryServerInterceptor + func SetLogger(l logger) + func WithStreamServerChain(interceptors ...grpc.StreamServerInterceptor) grpc.ServerOption + func WithUnaryServerChain(interceptors ...grpc.UnaryServerInterceptor) grpc.ServerOption + type Client struct + func NewClient(conn *grpc.ClientConn) *Client + type Server struct + func NewServer(vgname string, pvnames []string, defaultFs string, opts ...ServerOpt) *Server + func (s *Server) ControllerGetCapabilities(ctx context.Context, request *csi.ControllerGetCapabilitiesRequest) (*csi.ControllerGetCapabilitiesResponse, error) + func (s *Server) ControllerPublishVolume(ctx context.Context, request *csi.ControllerPublishVolumeRequest) (*csi.ControllerPublishVolumeResponse, error) + func (s *Server) ControllerUnpublishVolume(ctx context.Context, request *csi.ControllerUnpublishVolumeRequest) (*csi.ControllerUnpublishVolumeResponse, error) + func (s *Server) CreateVolume(ctx context.Context, request *csi.CreateVolumeRequest) (*csi.CreateVolumeResponse, error) + func (s *Server) DeleteVolume(ctx context.Context, request *csi.DeleteVolumeRequest) (*csi.DeleteVolumeResponse, error) + func (s *Server) GetCapacity(ctx context.Context, request *csi.GetCapacityRequest) (*csi.GetCapacityResponse, error) + func (s *Server) GetPluginCapabilities(ctx context.Context, request *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error) + func (s *Server) GetPluginInfo(ctx context.Context, request *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error) + func (s *Server) ListVolumes(ctx context.Context, request *csi.ListVolumesRequest) (*csi.ListVolumesResponse, error) + func (s *Server) NodeGetCapabilities(ctx context.Context, request *csi.NodeGetCapabilitiesRequest) (*csi.NodeGetCapabilitiesResponse, error) + func (s *Server) NodeGetId(ctx context.Context, request *csi.NodeGetIdRequest) (*csi.NodeGetIdResponse, error) + func (s *Server) NodePublishVolume(ctx context.Context, request *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error) + func (s *Server) NodeStageVolume(ctx context.Context, request *csi.NodeStageVolumeRequest) (*csi.NodeStageVolumeResponse, error) + func (s *Server) NodeUnpublishVolume(ctx context.Context, request *csi.NodeUnpublishVolumeRequest) (*csi.NodeUnpublishVolumeResponse, error) + func (s *Server) NodeUnstageVolume(ctx context.Context, request *csi.NodeUnstageVolumeRequest) (*csi.NodeUnstageVolumeResponse, error) + func (s *Server) Probe(ctx context.Context, request *csi.ProbeRequest) (*csi.ProbeResponse, error) + func (s *Server) Setup() error + func (s *Server) ValidateVolumeCapabilities(ctx context.Context, request *csi.ValidateVolumeCapabilitiesRequest) (*csi.ValidateVolumeCapabilitiesResponse, error) + type ServerOpt func(*Server) + func DefaultVolumeSize(size uint64) ServerOpt + func RemoveVolumeGroup() ServerOpt + func SupportedFilesystem(fstype string) ServerOpt + func Tag(tag string) ServerOpt
Go to main page