Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNoNegativeRequestBytes = errors.New("required capacity must not be negative") ErrNoNegativeLimitBytes = errors.New("capacity limit must not be negative") ErrRequestedExceedsLimit = errors.New("requested capacity exceeds limit capacity") ErrResultingRequestIsZero = errors.New("requested capacity is 0") )
Functions ¶
func NewControllerServer ¶
func NewControllerServer(mgr manager.Manager) (csi.ControllerServer, error)
NewControllerServer returns a new ControllerServer.
func NewIdentityServer ¶
func NewIdentityServer(ready func() (bool, error)) csi.IdentityServer
NewIdentityServer returns a new IdentityServer.
ready is a function to check the plugin status. It should return non-nil error if the plugin is not healthy. If the plugin is not yet ready, it should return (false, nil). Otherwise, return (true, nil).
func NewNodeServer ¶
NewNodeServer returns a new NodeServer.
Types ¶
type LockByID ¶
type LockByID struct {
// contains filtered or unexported fields
}
LockByID is a mutex which takes lock with a given ID. If same id is given, only one process can take lock. If different id is given, each process can take lock separately.
func NewLockWithID ¶
func NewLockWithID() *LockByID
func (*LockByID) UnlockByID ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.