socket

Documentation

Index

• Constants
• type DataProcessorWrapper
  • func NewDataProcessorWrapper(rwu types.ReaderWriterUnmapperAt) DataProcessorWrapper
  • func (d DataProcessorWrapper) PingResponse() error
  • func (d DataProcessorWrapper) ReadAt(p []byte, off int64) (n int, err error)
  • func (d DataProcessorWrapper) UnmapAt(length uint32, off int64) (n int, err error)
  • func (d DataProcessorWrapper) WriteAt(p []byte, off int64) (n int, err error)
• type Socket
  • func New() *Socket
  • func (t *Socket) Endpoint() string
  • func (t *Socket) Expand(size int64) error
  • func (t *Socket) FrontendName() string
  • func (t *Socket) GetSocketPath() string
  • func (t *Socket) Init(name string, size, sectorSize int64) error
  • func (t *Socket) Shutdown() error
  • func (t *Socket) Startup(rwu types.ReaderWriterUnmapperAt) error
  • func (t *Socket) State() types.State
  • func (t *Socket) Upgrade(name string, size, sectorSize int64, rwu types.ReaderWriterUnmapperAt) error

Constants

const (
	SocketDirectory = "/var/run"
	DevPath         = "/dev/longhorn/"
)

Types

type DataProcessorWrapper

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

func NewDataProcessorWrapper

func NewDataProcessorWrapper(rwu types.ReaderWriterUnmapperAt) DataProcessorWrapper

func (DataProcessorWrapper) PingResponse

func (d DataProcessorWrapper) PingResponse() error

func (DataProcessorWrapper) ReadAt

func (d DataProcessorWrapper) ReadAt(p []byte, off int64) (n int, err error)

func (DataProcessorWrapper) UnmapAt

func (d DataProcessorWrapper) UnmapAt(length uint32, off int64) (n int, err error)

func (DataProcessorWrapper) WriteAt

func (d DataProcessorWrapper) WriteAt(p []byte, off int64) (n int, err error)

type Socket

type Socket struct {
	Volume      string
	Size        int64
	SectorSize  int
	ScsiTimeout int
	// contains filtered or unexported fields
}

func New

func New() *Socket

func (*Socket) Endpoint

func (t *Socket) Endpoint() string

func (*Socket) Expand

func (t *Socket) Expand(size int64) error

func (*Socket) FrontendName

func (t *Socket) FrontendName() string

func (*Socket) GetSocketPath

func (t *Socket) GetSocketPath() string

func (*Socket) Init

func (t *Socket) Init(name string, size, sectorSize int64) error

func (*Socket) Shutdown

func (t *Socket) Shutdown() error

func (*Socket) Startup

func (t *Socket) Startup(rwu types.ReaderWriterUnmapperAt) error

func (*Socket) State

func (t *Socket) State() types.State

func (*Socket) Upgrade

func (t *Socket) Upgrade(name string, size, sectorSize int64, rwu types.ReaderWriterUnmapperAt) error