utils

Documentation

Index

• Constants
• Variables
• func DiskId2Name(id int) string
• func Mount(src, dst string) error
• func RandStr(strSize int, randType string) string
• func SetReadonly(path string) error
• func SocketConnect(addr string) (net.Conn, error)
• func Umount(root string)
• func UnixSocketConnect(addr string) (conn net.Conn, err error)
• type BytesPipe
  • func NewBytesPipe() *BytesPipe
  • func (bp *BytesPipe) Close() error
  • func (bp *BytesPipe) CloseWithError(err error) error
  • func (bp *BytesPipe) Read(p []byte) (n int, err error)
  • func (bp *BytesPipe) Write(p []byte) (int, error)

Constants

const (
	UNIX_SOCKET_PREFIX  = "unix://"
	VSOCK_SOCKET_PREFIX = "vsock://"
)

Variables

var (
	// ErrClosed is returned when Write is called on a closed BytesPipe.
	ErrClosed = errors.New("write to closed BytesPipe")
)

Functions

func DiskId2Name

func DiskId2Name(id int) string

func Mount

func Mount(src, dst string) error

func RandStr

func RandStr(strSize int, randType string) string

func SetReadonly

func SetReadonly(path string) error

func SocketConnect

func SocketConnect(addr string) (net.Conn, error)

func Umount

func Umount(root string)

func UnixSocketConnect

func UnixSocketConnect(addr string) (conn net.Conn, err error)

Types

type BytesPipe

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

BytesPipe is io.ReadWriteCloser which works similarly to pipe(queue). All written data may be read at most once. Also, BytesPipe allocates and releases new byte slices to adjust to current needs, so the buffer won't be overgrown after peak loads.

func NewBytesPipe

func NewBytesPipe() *BytesPipe

NewBytesPipe creates new BytesPipe, initialized by specified slice. If buf is nil, then it will be initialized with slice which cap is 64. buf will be adjusted in a way that len(buf) == 0, cap(buf) == cap(buf).

func (*BytesPipe) Close

func (bp *BytesPipe) Close() error

Close causes further reads from a BytesPipe to return immediately.

func (*BytesPipe) CloseWithError

func (bp *BytesPipe) CloseWithError(err error) error

CloseWithError causes further reads from a BytesPipe to return immediately.

func (*BytesPipe) Read

func (bp *BytesPipe) Read(p []byte) (n int, err error)

Read reads bytes from BytesPipe. Data could be read only once.

func (*BytesPipe) Write

func (bp *BytesPipe) Write(p []byte) (int, error)

Write writes p to BytesPipe. It can allocate new []byte slices in a process of writing.