proxy

Documentation

Index

• type Controller
  • func GetController() (client Controller, err error)
  • func (c *Controller) ControllerGetCapabilities(ctx context.Context) (capabilties []*csi.ControllerServiceCapability, err error)
  • func (c *Controller) ControllerPublishVolume(ctx context.Context, volumeid string, nodeID string, ...) (map[string]string, error)
  • func (c *Controller) ControllerUnpublishVolume(ctx context.Context, volumeid string, nodeID string, ...) error
  • func (c *Controller) CreateVolume(ctx context.Context, name string, capacity *csi.CapacityRange, ...) (volume *csi.Volume, err error)
  • func (c *Controller) DeleteVolume(ctx context.Context, volumeid string, credentials map[string]string) error
  • func (c *Controller) GetCapacity(ctx context.Context, capabilities []*csi.VolumeCapability) (int64, error)
  • func (c *Controller) ListVolumes(ctx context.Context, maxentries int32, startingtoken string) (entries []*csi.ListVolumesResponse_Entry, nextToken string, err error)
  • func (c *Controller) ValidateVolumeCapabilities(ctx context.Context, volumeid string, capabilities []*csi.VolumeCapability, ...) (*csi.ValidateVolumeCapabilitiesResponse, error)
• type Identity
  • func GetIdentity() (client Identity, err error)
  • func (c *Identity) GetPluginCapabilities(ctx context.Context) (*csi.GetPluginCapabilitiesResponse, error)
  • func (c *Identity) GetPluginInfo(ctx context.Context) (*csi.GetPluginInfoResponse, error)
  • func (c *Identity) Probe(ctx context.Context) (*csi.ProbeResponse, error)
• type Node
  • func GetNode() (client Node, err error)
  • func (c *Node) NodeGetCapabilities(ctx context.Context) (capabilties []*csi.NodeServiceCapability, err error)
  • func (c *Node) NodeGetId(ctx context.Context) (string, error)
  • func (c *Node) NodePublishVolume(ctx context.Context, volumeid string, publicInfo map[string]string, ...) error
  • func (c *Node) NodeStageVolume(ctx context.Context, volumeid string, publicInfo map[string]string, ...) error
  • func (c *Node) NodeUnpublishVolume(ctx context.Context, volumeid string, targetPath string) error
  • func (c *Node) NodeUnstageVolume(ctx context.Context, volumeid string, stagingTargetPath string) error

Types

type Controller

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

Controller define

func GetController

func GetController() (client Controller, err error)

GetController return controller struct

func (*Controller) ControllerGetCapabilities

func (c *Controller) ControllerGetCapabilities(
	ctx context.Context) (capabilties []*csi.ControllerServiceCapability, err error)

ControllerGetCapabilities proxy

func (*Controller) ControllerPublishVolume

func (c *Controller) ControllerPublishVolume(
	ctx context.Context,
	volumeid string,
	nodeID string,
	capabilities *csi.VolumeCapability,
	readonly bool,
	credentials map[string]string,
	volumeattributes map[string]string) (map[string]string, error)

ControllerPublishVolume proxy

func (*Controller) ControllerUnpublishVolume

func (c *Controller) ControllerUnpublishVolume(
	ctx context.Context,
	volumeid string,
	nodeID string,
	credentials map[string]string) error

ControllerUnpublishVolume proxy

func (*Controller) CreateVolume

func (c *Controller) CreateVolume(
	ctx context.Context,
	name string,
	capacity *csi.CapacityRange,
	capabilities []*csi.VolumeCapability,
	params map[string]string,
	credentials map[string]string) (volume *csi.Volume, err error)

CreateVolume proxy

func (*Controller) DeleteVolume

func (c *Controller) DeleteVolume(
	ctx context.Context,
	volumeid string,
	credentials map[string]string) error

DeleteVolume proxy

func (*Controller) GetCapacity

func (c *Controller) GetCapacity(
	ctx context.Context,
	capabilities []*csi.VolumeCapability) (int64, error)

GetCapacity proxy

func (*Controller) ListVolumes

func (c *Controller) ListVolumes(
	ctx context.Context,
	maxentries int32,
	startingtoken string) (entries []*csi.ListVolumesResponse_Entry, nextToken string, err error)

ListVolumes proxy

func (*Controller) ValidateVolumeCapabilities

func (c *Controller) ValidateVolumeCapabilities(
	ctx context.Context,
	volumeid string,
	capabilities []*csi.VolumeCapability,
	volumeattributes map[string]string) (*csi.ValidateVolumeCapabilitiesResponse, error)

ValidateVolumeCapabilities proxy

type Identity

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

Identity define

func GetIdentity

func GetIdentity() (client Identity, err error)

GetIdentity return Identity struct

func (*Identity) GetPluginCapabilities

func (c *Identity) GetPluginCapabilities(
	ctx context.Context) (*csi.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities proxy

func (*Identity) GetPluginInfo

func (c *Identity) GetPluginInfo(
	ctx context.Context) (*csi.GetPluginInfoResponse, error)

GetPluginInfo proxy

func (*Identity) Probe

func (c *Identity) Probe(
	ctx context.Context) (*csi.ProbeResponse, error)

Probe proxy

type Node

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

Node define

func GetNode

func GetNode() (client Node, err error)

GetNode return Node struct

func (*Node) NodeGetCapabilities

func (c *Node) NodeGetCapabilities(
	ctx context.Context) (capabilties []*csi.NodeServiceCapability, err error)

NodeGetCapabilities proxy

func (*Node) NodeGetId

func (c *Node) NodeGetId(
	ctx context.Context) (string, error)

NodeGetId proxy

func (*Node) NodePublishVolume

func (c *Node) NodePublishVolume(
	ctx context.Context,
	volumeid string,
	publicInfo map[string]string,
	stagingTargetPath string,
	targetPath string,
	capability *csi.VolumeCapability,
	readonly bool,
	credentials map[string]string,
	volumeattributes map[string]string) error

NodePublishVolume proxy

func (*Node) NodeStageVolume

func (c *Node) NodeStageVolume(
	ctx context.Context,
	volumeid string,
	publicInfo map[string]string,
	stagingTargetPath string,
	capability *csi.VolumeCapability,
	credentials map[string]string,
	volumeattributes map[string]string) error

NodeStageVolume proxy

func (*Node) NodeUnpublishVolume

func (c *Node) NodeUnpublishVolume(
	ctx context.Context,
	volumeid string,
	targetPath string) error

NodeUnpublishVolume proxy

func (*Node) NodeUnstageVolume

func (c *Node) NodeUnstageVolume(
	ctx context.Context,
	volumeid string,
	stagingTargetPath string) error

NodeUnstageVolume proxy