types

type GormNetIPNet net.IPNet

type Machine struct {
	ID               string `gorm:"primaryKey"`
	State            MachineState
	DesiredState     MachineDesiredState
	RuntimePID       *int `gorm:"column:runtime_pid"`
	Spec             *MachineSpec
	Volume           *Volume
	NetworkInterface *NetworkInterface
	CreatedAt        time.Time
	TerminatedAt     *time.Time
}

type MachineDesiredState string

type MachineSpec struct {
	Image      string
	Cpus       uint32
	MemoryMB   uint64
	Env        map[string]string
	User       string
	WorkingDir string
	Command    []string
}

type MachineState string

type NetworkInterface struct {
	ID             string `gorm:"primaryKey"`
	Name           string
	MachineID      *string
	IPAddress      net.IP           `gorm:"type:text"`
	MacAddress     net.HardwareAddr `gorm:"type:text"`
	GatewayAddress net.IP           `gorm:"type:text"`
	NetworkCIDR    *GormNetIPNet    `gorm:"column:network_cidr"`
	CreatedAt      time.Time
	DeletedAt      *time.Time
}

type NetworkProvider interface {
	GetInterface(name string) (*NetworkInterface, error)

	AllocateInterface(ctx context.Context) (*NetworkInterface, error)

	ReleaseInterface(ctx context.Context, name string) error
}

type NodeCreateMachineOptions struct {
	MachineID    string
	DesiredState MachineDesiredState
	Spec         MachineSpec
}

type NodeServerConfig struct {
	ClusterID             string
	BootstrapToken        string
	IPAddr                string
	APIAddr               string
	GatewayAddr           string
	StorageDirectory      string
	InitBinary            string
	VMLinux               string
	CloudHypervisorBinary string
}

type NodeService interface {
	Start(ctx context.Context) error

	Stop(ctx context.Context) error

	AuthorityCertificate() *x509.Certificate

	TLSCertificate() *tls.Certificate

	ListMachines(ctx context.Context) ([]*Machine, error)

	FindMachine(ctx context.Context, machineID string) (*Machine, error)

	CreateMachine(ctx context.Context, opts NodeCreateMachineOptions) (*Machine, error)

	UpdateMachineDesiredState(ctx context.Context, opts NodeUpdateMachineDesiredStateOptions) (*Machine, error)
}

type NodeUpdateMachineDesiredStateOptions struct {
	MachineID    string
	DesiredState MachineDesiredState
}

type RuntimeCreateOptions struct {
	MachineID        string
	Spec             MachineSpec
	Volume           Volume
	NetworkInterface NetworkInterface
}

type RuntimeProvider interface {
	GC(ctx context.Context, getExpectedMachineIDs func() []string) error

	Create(ctx context.Context, opts RuntimeCreateOptions) (int, error)

	Boot(ctx context.Context, machineID string) error

	Terminate(ctx context.Context, machineID string) error

	Healthcheck(ctx context.Context, machineID string) error
}

type Volume struct {
	ID        string `gorm:"primaryKey"`
	MachineID *string
	Path      string
	ReadOnly  bool
	Size      uint64
	CreatedAt time.Time
	DeletedAt *time.Time
}

type VolumeProvider interface {
	CreateVolume(ctx context.Context, image v1.Image) (*Volume, error)

	DeleteVolume(ctx context.Context, volume *Volume) error
}