sockets

Documentation

Index

• func DialSocketWithBackoffs(maxBackoffs int, backoff time.Duration, socketPath string) (conn net.Conn, err error)
• func DialSocketWithBackoffsAndProcCheck(maxBackoffs int, backoff time.Duration, socketPath string, ...) (conn net.Conn, err error)
• func ListenAndWaitOnSocket(errChan chan<- error, listener net.Listener)
• func ReadySocketPath(runtimeDir, machineName string) string
• func SetSocket(socketLoc *define.VMFile, path string, symlink *string) error
• func WaitForSocketWithBackoffs(maxBackoffs int, backoff time.Duration, socketPath string, name string) error

Functions

func DialSocketWithBackoffs

func DialSocketWithBackoffs(maxBackoffs int, backoff time.Duration, socketPath string) (conn net.Conn, err error)

DialSocketWithBackoffs attempts to connect to the socket in maxBackoffs attempts

func DialSocketWithBackoffsAndProcCheck

func DialSocketWithBackoffsAndProcCheck(
	maxBackoffs int,
	backoff time.Duration,
	socketPath string,
	checkProccessStatus func(string, int, *bytes.Buffer) error,
	procHint string,
	procPid int,
	errBuf *bytes.Buffer,
) (conn net.Conn, err error)

DialSocketWithBackoffsAndProcCheck attempts to connect to the socket in maxBackoffs attempts. After every failure to connect, it makes sure the specified process is alive

func ListenAndWaitOnSocket

func ListenAndWaitOnSocket(errChan chan<- error, listener net.Listener)

ListenAndWaitOnSocket waits for a new connection to the listener and sends any error back through the channel. ListenAndWaitOnSocket is intended to be used as a goroutine

func ReadySocketPath

func ReadySocketPath(runtimeDir, machineName string) string

ReadySocketPath returns the filepath for the ready socket

func SetSocket

func SetSocket(socketLoc *define.VMFile, path string, symlink *string) error

SetSocket creates a new machine file for the socket and assigns it to `socketLoc`

func WaitForSocketWithBackoffs

func WaitForSocketWithBackoffs(maxBackoffs int, backoff time.Duration, socketPath string, name string) error

WaitForSocketWithBackoffs attempts to discover listening socket in maxBackoffs attempts