csidriver

Documentation

Index

• Constants
• type CSIDriver
  • func NewCSIDriver(opts *options.CSIDriverOptions) (*CSIDriver, error)
  • func (cd *CSIDriver) Run()
• type UnixDomainSocket
  • func NewUnixDomainSocket(filename string, buffersize ...int) *UnixDomainSocket
  • func (us *UnixDomainSocket) Connect() (net.Conn, error)
  • func (us *UnixDomainSocket) Send(c net.Conn, context string) (string, error)

Constants

const (
	GroupResource            = "resource"
	DefaultNamespace         = "default"
	DefaultReceiveModuleName = "cloudhub"
)

Constant defines csi related parameters

const (
	// DefaultBufferSize represents default buffer size
	DefaultBufferSize = 10480
)

Types

type CSIDriver

type CSIDriver struct {
	options.CSIDriverOptions
	// contains filtered or unexported fields
}

func NewCSIDriver

func NewCSIDriver(opts *options.CSIDriverOptions) (*CSIDriver, error)

func (*CSIDriver) Run

func (cd *CSIDriver) Run()

type UnixDomainSocket

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

UnixDomainSocket struct

func NewUnixDomainSocket

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

NewUnixDomainSocket create new socket

func (*UnixDomainSocket) Connect

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

Connect for client

func (*UnixDomainSocket) Send

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

Send msg for client