client

package
v0.9.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 28, 2020 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func APIClient added in v0.8.0 

func APIClient(c *lc.HighLevelClient) func(*Linstor) error

APIClient the configured LINSTOR API client that will be used to communicate with the LINSTOR cluster.

func LogFmt added in v0.8.0 

func LogFmt(fmt logrus.Formatter) func(*Linstor) error

LogFmt sets the format of the log outpout via the provided logrus.Formatter.

func LogLevel added in v0.8.0 

func LogLevel(s string) func(*Linstor) error

LogLevel sets the logging intensity. Debug additionally reports the function from which the logger was called.

func LogOut added in v0.8.0 

func LogOut(out io.Writer) func(*Linstor) error

LogOut sets the Linstor client to write logs to the provided io.Writer instead of discarding logs.

Types

type Linstor 

type Linstor struct {
	// contains filtered or unexported fields
}

Linstor is a high-level client for use with CSI.

func NewLinstor 

func NewLinstor(options ...func(*Linstor) error) (*Linstor, error)

NewLinstor returns a high-level linstor client for CSI applications to interact with By default, it will try to connect with localhost:3370.

func (*Linstor) AccessibleTopologies added in v0.8.0 

func (s *Linstor) AccessibleTopologies(ctx context.Context, vol *volume.Info) ([]*csi.Topology, error)

AccessibleTopologies returns a list of pointers to csi.Topology from where the volume is reachable, based on the localStoragePolicy reported by the volume.

func (*Linstor) AllocationSizeKiB added in v0.3.0 

func (s *Linstor) AllocationSizeKiB(requiredBytes, limitBytes int64) (int64, error)

AllocationSizeKiB returns LINSTOR's smallest possible number of KiB that can satisfy the requiredBytes.

func (*Linstor) Attach 

func (s *Linstor) Attach(ctx context.Context, vol *volume.Info, node string) error

Attach idempotently creates a resource on the given node disklessly.

func (*Linstor) CanonicalizeSnapshotName added in v0.8.0 

func (s *Linstor) CanonicalizeSnapshotName(ctx context.Context, suggestedName string) string

CanonicalizeSnapshotName makes sure that the snapshot name meets LINSTOR's naming conventions.

func (*Linstor) CapacityBytes added in v0.8.0 

func (s *Linstor) CapacityBytes(ctx context.Context, parameters map[string]string) (int64, error)

CapacityBytes returns the amount of free space in the storage pool specified the the params.

func (*Linstor) ControllerExpand added in v0.9.0 

func (s *Linstor) ControllerExpand(ctx context.Context, vol *volume.Info) error

func (*Linstor) Create 

func (s *Linstor) Create(ctx context.Context, vol *volume.Info, req *csi.CreateVolumeRequest) error

Create creates the resource definition, volume definition, and assigns the resulting resource to LINSTOR nodes.

func (*Linstor) Delete 

func (s *Linstor) Delete(ctx context.Context, vol *volume.Info) error

Delete removes a resource, all of its volumes, and snapshots from LINSTOR.

func (*Linstor) Detach 

func (s *Linstor) Detach(ctx context.Context, vol *volume.Info, node string) error

Detach removes a volume from the node.

func (*Linstor) GetAssignmentOnNode 

func (s *Linstor) GetAssignmentOnNode(ctx context.Context, vol *volume.Info, node string) (*volume.Assignment, error)

GetAssignmentOnNode returns a pointer to a volume.Assignment for a given node.

func (*Linstor) GetByID 

func (s *Linstor) GetByID(ctx context.Context, id string) (*volume.Info, error)

GetByID retrives a volume.Info that has an id that matches the CSI volume id. Matches the LINSTOR resource name.

func (*Linstor) GetByName 

func (s *Linstor) GetByName(ctx context.Context, name string) (*volume.Info, error)

GetByName retrives a volume.Info that has a name that matches the CSI volume Name, not nessesarily the LINSTOR resource name or UUID.

func (*Linstor) GetSnapByID added in v0.8.0 

func (s *Linstor) GetSnapByID(ctx context.Context, id string) (*volume.SnapInfo, error)

GetSnapByID retrieves a pointer to a volume.SnapInfo by its id.

func (*Linstor) GetSnapByName added in v0.8.0 

func (s *Linstor) GetSnapByName(ctx context.Context, name string) (*volume.SnapInfo, error)

GetSnapByName retrieves a pointer to a volume.SnapInfo by its name.

func (*Linstor) GetVolumeStats added in v0.8.0 

func (s *Linstor) GetVolumeStats(path string) (volume.VolumeStats, error)

GetVolumeStats determines filesystem usage.

func (*Linstor) IsNotMountPoint added in v0.8.0 

func (s *Linstor) IsNotMountPoint(target string) (bool, error)

IsNotMountPoint determines if a directory is a mountpoint.

func (*Linstor) ListAll 

func (s *Linstor) ListAll(ctx context.Context) ([]*volume.Info, error)

ListAll returns a sorted list of pointers to volume.Info. Only the LINSTOR volumes that can be serialized into a volume.Info are included.

func (*Linstor) ListSnaps added in v0.8.0 

func (s *Linstor) ListSnaps(ctx context.Context) ([]*volume.SnapInfo, error)

ListSnaps returns list of pointers to volume.SnapInfo based off of the serialized snapshot info stored in resource definitions.

func (*Linstor) ListVolumes added in v0.8.0 

func (s *Linstor) ListVolumes(ctx context.Context) ([]*volume.Info, error)

ListVolumes returns all volumes that have metadata that is understandable by this plugin, so volumes from multiple compatible plugins may be returned.

func (*Linstor) Mount 

func (s *Linstor) Mount(vol *volume.Info, source, target, fsType string, options []string) error

Mount makes volumes consumable from the source to the target. Filesystems are formatted and block devices are bind mounted. Operates locally on the machines where it is called.

func (*Linstor) NodeAvailable 

func (s *Linstor) NodeAvailable(ctx context.Context, node string) error

NodeAvailable makes sure that LINSTOR considers that the node is in an ONLINE state.

func (*Linstor) NodeExpand added in v0.9.0 

func (s *Linstor) NodeExpand(source, target string) error

func (*Linstor) SnapCreate added in v0.8.0 

func (s *Linstor) SnapCreate(ctx context.Context, snap *volume.SnapInfo) (*volume.SnapInfo, error)

SnapCreate calls linstor to create a new snapshot on the volume indicated by the SourceVolumeId contained in the CSI Snapshot.

func (*Linstor) SnapDelete added in v0.8.0 

func (s *Linstor) SnapDelete(ctx context.Context, snap *volume.SnapInfo) error

SnapDelete calls LINSTOR to delete the snapshot based on the CSI Snapshot ID.

func (*Linstor) Unmount 

func (s *Linstor) Unmount(target string) error

Unmount unmounts the target. Operates locally on the machines where it is called.

func (*Linstor) VolFromSnap added in v0.8.0 

func (s *Linstor) VolFromSnap(ctx context.Context, snap *volume.SnapInfo, vol *volume.Info) error

VolFromSnap creates the volume using the data contained within the snapshot.

func (*Linstor) VolFromVol added in v0.8.0 

func (s *Linstor) VolFromVol(ctx context.Context, sourceVol, vol *volume.Info) error

VolFromVol creates the volume using the data contained within the source volume.

type MockStorage 

type MockStorage struct {
	// contains filtered or unexported fields
}

func (*MockStorage) AccessibleTopologies added in v0.8.0 

func (s *MockStorage) AccessibleTopologies(ctx context.Context, vol *volume.Info) ([]*csi.Topology, error)

func (*MockStorage) AllocationSizeKiB added in v0.3.0 

func (s *MockStorage) AllocationSizeKiB(requiredBytes, limitBytes int64) (int64, error)

func (*MockStorage) Attach 

func (s *MockStorage) Attach(ctx context.Context, vol *volume.Info, node string) error

func (*MockStorage) CanonicalizeSnapshotName added in v0.8.0 

func (s *MockStorage) CanonicalizeSnapshotName(ctx context.Context, suggestedName string) string

func (*MockStorage) CapacityBytes added in v0.8.0 

func (s *MockStorage) CapacityBytes(ctx context.Context, params map[string]string) (int64, error)

func (*MockStorage) ControllerExpand added in v0.9.0 

func (s *MockStorage) ControllerExpand(ctx context.Context, vol *volume.Info) error

func (*MockStorage) Create 

func (s *MockStorage) Create(ctx context.Context, vol *volume.Info, req *csi.CreateVolumeRequest) error

func (*MockStorage) Delete 

func (s *MockStorage) Delete(ctx context.Context, vol *volume.Info) error

func (*MockStorage) Detach 

func (s *MockStorage) Detach(ctx context.Context, vol *volume.Info, node string) error

func (*MockStorage) GetAssignmentOnNode 

func (s *MockStorage) GetAssignmentOnNode(ctx context.Context, vol *volume.Info, node string) (*volume.Assignment, error)

func (*MockStorage) GetByID 

func (s *MockStorage) GetByID(ctx context.Context, id string) (*volume.Info, error)

func (*MockStorage) GetByName 

func (s *MockStorage) GetByName(ctx context.Context, name string) (*volume.Info, error)

func (*MockStorage) GetSnapByID added in v0.8.0 

func (s *MockStorage) GetSnapByID(ctx context.Context, id string) (*volume.SnapInfo, error)

func (*MockStorage) GetSnapByName added in v0.8.0 

func (s *MockStorage) GetSnapByName(ctx context.Context, name string) (*volume.SnapInfo, error)

func (*MockStorage) GetVolumeStats added in v0.8.0 

func (s *MockStorage) GetVolumeStats(path string) (volume.VolumeStats, error)

func (*MockStorage) IsNotMountPoint added in v0.8.0 

func (s *MockStorage) IsNotMountPoint(target string) (bool, error)

func (*MockStorage) ListAll 

func (s *MockStorage) ListAll(ctx context.Context) ([]*volume.Info, error)

func (*MockStorage) ListSnaps added in v0.8.0 

func (s *MockStorage) ListSnaps(ctx context.Context) ([]*volume.SnapInfo, error)

func (*MockStorage) Mount 

func (s *MockStorage) Mount(vol *volume.Info, source, target, fsType string, options []string) error

func (*MockStorage) NodeAvailable 

func (s *MockStorage) NodeAvailable(ctx context.Context, node string) error

func (*MockStorage) NodeExpand added in v0.9.0 

func (s *MockStorage) NodeExpand(source, target string) error

func (*MockStorage) SnapCreate added in v0.8.0 

func (s *MockStorage) SnapCreate(ctx context.Context, snap *volume.SnapInfo) (*volume.SnapInfo, error)

func (*MockStorage) SnapDelete added in v0.8.0 

func (s *MockStorage) SnapDelete(ctx context.Context, snap *volume.SnapInfo) error

func (*MockStorage) Unmount 

func (s *MockStorage) Unmount(target string) error

func (*MockStorage) VolFromSnap added in v0.8.0 

func (s *MockStorage) VolFromSnap(ctx context.Context, snap *volume.SnapInfo, vol *volume.Info) error

func (*MockStorage) VolFromVol added in v0.8.0 

func (s *MockStorage) VolFromVol(ctx context.Context, sourceVol, vol *volume.Info) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.