host

package
v0.0.0-...-a733983 Latest Latest
Warning

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

Go to latest
Published: Apr 5, 2025 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const AppID = "railyard"
View Source
const Name = "railyard"
View Source
const Version = "0.1.0"

Variables

This section is empty.

Functions

func MonitorContainerd

func MonitorContainerd(ctx context.Context, vm *VirtualMachine, sl *StopLatch)

func MonitorDockerd

func MonitorDockerd(ctx context.Context, vm *VirtualMachine, futureListener func() (*Listener, error))

Types

type DaemonState

type DaemonState struct {
	Status        Status `json:"status,omitempty"`
	MACAddress    string `json:"mac-address,omitempty"`
	MachineID     []byte `json:"machine-id,omitempty"`
	ControlSocket string `json:"control-socket,omitempty"`
	IPv4Address   string `json:"ipv4-address,omitempty"`
}

VirtualMachineState... stores persistent information across VM restarts.

func OpenDaemonState

func OpenDaemonState(path string, status Status, ch <-chan DaemonState) (DaemonState, chan struct{}, error)

type GuestPort

type GuestPort struct {
	Proto ListenerProto
	Port  int
}

type Listener

type Listener struct {
	VM *VirtualMachine
	// contains filtered or unexported fields
}

func NewListener

func NewListener(bind string) (*Listener, error)

func (*Listener) Close

func (l *Listener) Close(id string)

func (*Listener) CloseAll

func (l *Listener) CloseAll()

func (*Listener) Forward

func (l *Listener) Forward(id string, guestIP net.IP, ports map[GuestPort]util.Set[int])

type ListenerProto

type ListenerProto string
const (
	ListenerProtoTCP ListenerProto = "tcp"
	ListenerProtoUDP ListenerProto = "udp"
)

type Status

type Status string
const (
	StatusStopped  Status = "stopped"
	StatusRunning  Status = "running"
	StatusStarting Status = "starting"
	StatusStopping Status = "stopping"
)

type StopLatch

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

func NewStopLatch

func NewStopLatch(delay time.Duration, stop func()) *StopLatch

func (*StopLatch) Add

func (s *StopLatch) Add(add int64)

func (*StopLatch) Close

func (s *StopLatch) Close()

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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