cloudhub

Documentation

Index

• Constants
• func NewControllerServer(ephemeral bool) *controllerServer
• func NewIdentityServer(name, version string) *identityServer
• func NewNonBlockingGRPCServer() *nonBlockingGRPCServer
• type CloudHub
  • func NewCloudHubDriver(driverName, nodeID, endpoint, version string, ephemeral bool) (*CloudHub, error)
  • func (hp *CloudHub) Run()
• type UnixDomainSocket
  • func NewUnixDomainSocket(filename string, size ...int) *UnixDomainSocket
  • func (us *UnixDomainSocket) Connect() net.Conn
  • func (us *UnixDomainSocket) Send(c net.Conn, context string) string
  • func (us *UnixDomainSocket) SetContextHandler(f func(string) string)
  • func (us *UnixDomainSocket) StartServer()

Constants

const (
	CSIResourceTypeVolume                     = "volume"
	CSIOperationTypeCreateVolume              = "createvolume"
	CSIOperationTypeDeleteVolume              = "deletevolume"
	CSIOperationTypeControllerPublishVolume   = "controllerpublishvolume"
	CSIOperationTypeControllerUnpublishVolume = "controllerunpublishvolume"
	CSISyncMsgRespTimeout                     = 1 * time.Minute

	CSIGroupResource    = "resource"
	CSINamespaceDefault = "default"
)

Constant defines csi related parameters

Functions

func NewControllerServer

func NewControllerServer(ephemeral bool) *controllerServer

NewControllerServer creates controller server

func NewIdentityServer

func NewIdentityServer(name, version string) *identityServer

NewIdentityServer creates identity server

func NewNonBlockingGRPCServer

func NewNonBlockingGRPCServer() *nonBlockingGRPCServer

NewNonBlockingGRPCServer creates a new nonblocking server

Types

type CloudHub

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

func NewCloudHubDriver

func NewCloudHubDriver(driverName, nodeID, endpoint, version string, ephemeral bool) (*CloudHub, error)

NewCloudHubDriver creates a new cloudhub driver

func (*CloudHub) Run

func (hp *CloudHub) Run()

type UnixDomainSocket

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

UnixDomainSocket struct

func NewUnixDomainSocket

func NewUnixDomainSocket(filename string, size ...int) *UnixDomainSocket

NewUnixDomainSocket create new socket

func (*UnixDomainSocket) Connect

func (us *UnixDomainSocket) Connect() net.Conn

Connect connect for [Client]

func (*UnixDomainSocket) Send

func (us *UnixDomainSocket) Send(c net.Conn, context string) string

Send msg for [Client]

func (*UnixDomainSocket) SetContextHandler

func (us *UnixDomainSocket) SetContextHandler(f func(string) string)

SetContextHandler set handler for [Server]

func (*UnixDomainSocket) StartServer

func (us *UnixDomainSocket) StartServer()

StartServer start for [Server]