hostpath

Documentation

Index

• Constants
• func NewControllerServer(ephemeral bool, nodeID string) *controllerServer
• func NewHostPathDriver(driverName, nodeID, endpoint string, ephemeral bool, maxVolumesPerNode int64, ...) (*hostPath, error)
• func NewNodeServer(nodeId string, ephemeral bool, maxVolumesPerNode int64) *nodeServer
• func NewNonBlockingGRPCServer() *nonBlockingGRPCServer
• type IdentityServer
  • func NewIdentityServer(name, version string) *IdentityServer
  • func (ids *IdentityServer) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)
  • func (ids *IdentityServer) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)
  • func (ids *IdentityServer) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

Constants

const TopologyKeyNode = "topology.hostpath.csi/node"

Functions

func NewControllerServer

func NewControllerServer(ephemeral bool, nodeID string) *controllerServer

func NewHostPathDriver

func NewHostPathDriver(driverName, nodeID, endpoint string, ephemeral bool, maxVolumesPerNode int64, version string) (*hostPath, error)

func NewNodeServer

func NewNodeServer(nodeId string, ephemeral bool, maxVolumesPerNode int64) *nodeServer

NewNodeServer returns as helper object

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() *nonBlockingGRPCServer

Types

type IdentityServer

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

IdentityServer is object for identity server

func NewIdentityServer

func NewIdentityServer(name, version string) *IdentityServer

NewIdentityServer returns helper object of identiy server

func (*IdentityServer) GetPluginCapabilities

func (ids *IdentityServer) GetPluginCapabilities(ctx context.Context, req *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error)

GetPluginCapabilities returns the capabilities of the plugin. Currently it reports whether the plugin has the ability of server the Controller interface. The Container Orchestration(K8s...) calls the Controller interface methods depending on whether this method returns the capability or not.

func (*IdentityServer) GetPluginInfo

func (ids *IdentityServer) GetPluginInfo(ctx context.Context, req *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error)

GetPluginInfo need to return the version and name of the plugin

func (*IdentityServer) Probe

func (ids *IdentityServer) Probe(ctx context.Context, req *csi.ProbeRequest) (*csi.ProbeResponse, error)

Probe is called by the Container Orchestration(K8s...) just to check whether the plugin is running or not. This method doesn't need to return anything. Currently the spec doesn't dictate what you should return either. Hence return an empty response.