katbox

Documentation

Index

• Constants
• func NewIdentityServer(name, version string) *identityServer
• func NewKatboxDriver(driverName, nodeID, endpoint, workdir string, maxVolumesPerNode int64, ...) (*katbox, error)
• func NewNode(id, workdir string, maxVolumes int64, afterLifespan time.Duration) *node
• func NewNonBlockingGRPCServer() *nonBlockingGRPCServer

Constants

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

Functions

func NewIdentityServer

func NewIdentityServer(name, version string) *identityServer

func NewKatboxDriver

func NewKatboxDriver(
	driverName, nodeID, endpoint, workdir string,
	maxVolumesPerNode int64,
	afterlifeSpan, deleteInterval time.Duration,
	headroom float64,
	version string) (*katbox, error)

func NewNode

func NewNode(id, workdir string, maxVolumes int64, afterLifespan time.Duration) *node

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() *nonBlockingGRPCServer