vsock

package
v0.0.0-...-f662469 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 19, 2024 License: AGPL-3.0 Imports: 15 Imported by: 2

Documentation

Index

Constants

View Source
const (
	CIDHost  = 2
	CIDGuest = 3
)

Variables

View Source
var (
	ErrCouldNotConnectToVSock = errors.New("could not connect to VSock")
	ErrRemoteNotFound         = errors.New("remote not found")
)

Functions

func Dial

func Dial(cid uint32, port uint32) (io.ReadWriteCloser, error)

func SendLivenessPing

func SendLivenessPing(
	vsockCID uint32,
	vsockPort uint32,
) error

Types

type Handler

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

func NewHandler

func NewHandler(
	vsockPath string,
	vsockPort uint32,
) *Handler

func (*Handler) Close

func (s *Handler) Close() error

func (*Handler) Open

func (s *Handler) Open(
	ctx context.Context,
	connectDeadline time.Duration,
	retryDeadline time.Duration,
) (remotes.AgentRemote, error)

func (*Handler) Wait

func (s *Handler) Wait() error

type Listener

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

func Listen

func Listen(cid uint32, port uint32, backlog int) (*Listener, error)

func (*Listener) Accept

func (l *Listener) Accept() (io.ReadWriteCloser, error)

func (*Listener) Close

func (l *Listener) Close() error

type LivenessPingReceiver

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

func NewLivenessPingReceiver

func NewLivenessPingReceiver(
	vsockPath string,
	vsockPort uint32,
) *LivenessPingReceiver

func (*LivenessPingReceiver) Close

func (l *LivenessPingReceiver) Close()

func (*LivenessPingReceiver) Open

func (l *LivenessPingReceiver) Open() (string, error)

func (*LivenessPingReceiver) Receive

func (l *LivenessPingReceiver) Receive() error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL