vlab

package
v0.16.2 Latest Latest
Warning

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

 Go to latest Published: May 30, 2024 License: Apache-2.0 Imports: 42 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	HHFabCfgPrefix             = ".hhfab.fabric.githedgehog.com"
	HHFabCfgType               = "type" + HHFabCfgPrefix
	HHFabCfgSerial             = "serial" + HHFabCfgPrefix
	HHFabCfgLinkPrefix         = "link" + HHFabCfgPrefix + "/"
	HHFabCfgPCIPrefix          = "pci@"
	HHFabCfgSerialSchemeSSH    = "ssh://"
	HHFabCfgSerialSchemeTelnet = "telnet://"
)
View Source 
const (
	VPCSetupTypeVPCPerServer       = "vpc-per-server"
	VPCSetupTypeSingleVPC          = "single-vpc"
	VPCSetupTypeVPCSubnetPerServer = "subnet-per-server"
)
View Source 
const (
	MACAddrTmpl      = "0c:20:12:fe:%02d:%02d" // if changing update onie-qcow2-eeprom-edit config too
	KubePort         = 6443
	RegistryPort     = 31000
	SSHPortBase      = 22000
	IfPortBase       = 30000
	IfPortNull       = IfPortBase + 9000
	IfPortVMIDMult   = 100
	IfPortPortIDMult = 1
)
View Source 
const (
	VMSelectorSSH = "ssh"
	VMSelectorAll = "all"
)
View Source 
const (
	VMSizeDefault = "default" // meaningful VM sizes for dev & testing
	VMSizeCompact = "compact" // minimal working setup, applied on top of default
	VMSizeFull    = "full"    // full setup as specified in requirements and more real switch resources, applied on top of default
	VMSizeHuge    = "huge"    // full setup with more resources for servers, applied on top of default

	VirtualEdgeAnnotation = "external.hhfab.fabric.githedgehog.com/dest" // HHFAB annotation to specify destination for external connection
)
View Source 
const (
	IfacesPerPCIBridge = 32
)

Variables

View Source 
var CompactControlVM = VMConfig{
	CPU:  4,
	RAM:  4096,
	Disk: 50,
}
View Source 
var CompactServerVM = VMConfig{
	CPU: 1,
}
View Source 
var CompactSwitchVM = VMConfig{
	CPU:  3,
	RAM:  3584,
	Disk: 30,
}
View Source 
var DefaultControlVM = VMConfig{
	CPU:  6,
	RAM:  6144,
	Disk: 100,
}
View Source 
var DefaultServerVM = VMConfig{
	CPU:  2,
	RAM:  768,
	Disk: 10,
}
View Source 
var DefaultSwitchVM = VMConfig{
	CPU:  4,
	RAM:  5120,
	Disk: 50,
}
View Source 
var FullControlVM = VMConfig{
	CPU:  8,
	RAM:  16384,
	Disk: 250,
}
View Source 
var FullServerVM = VMConfig{
	RAM: 2048,
}
View Source 
var FullSwitchVM = VMConfig{
	RAM: 8192,
}
View Source 
var HugeControlVM = VMConfig{
	CPU:  8,
	RAM:  16384,
	Disk: 250,
}
View Source 
var HugeServerVM = VMConfig{
	CPU: 4,
	RAM: 8192,
}
View Source 
var HugeSwitchVM = VMConfig{
	RAM: 8192,
}
View Source 
var RequiredCommands = []string{
	"qemu-system-x86_64",
	"qemu-img",
	"tpm2",
	"swtpm_setup",
	"ssh",
	"scp",
	"sudo",
}
View Source 
var SSHQuietFlags = []string{
	"-o", "GlobalKnownHostsFile=/dev/null",
	"-o", "UserKnownHostsFile=/dev/null",
	"-o", "StrictHostKeyChecking=no",
	"-o", "LogLevel=ERROR",
}
View Source 
var VMSizes = []string{VMSizeDefault, VMSizeCompact, VMSizeFull, VMSizeHuge}
View Source 
var VPCSetupTypes = []string{
	VPCSetupTypeVPCPerServer,
}

Functions

func InitTPMConfig 

func InitTPMConfig(ctx context.Context, svcCfg *ServiceConfig) error

Makes sure that swtpm config is initialized before we start VMs

func SetupCtrlRuntimeLogs added in v0.15.1 

func SetupCtrlRuntimeLogs()

TODO properly handle logging config for ctrl runtime

Types

type Config 

type Config struct {
	VMs      VMsConfig               `json:"vms,omitempty"`
	Switches map[string]SwitchConfig `json:"switches,omitempty"`
	Links    map[string]LinkConfig   `json:"links,omitempty"`
}

type ConfigSwitchType added in v0.6.0 

type ConfigSwitchType string
const (
	ConfigSwitchTypeVS ConfigSwitchType = "vs"
	ConfigSwitchTypeHW ConfigSwitchType = "hw"
)

type LinkConfig added in v0.6.0 

type LinkConfig struct {
	PCIAddress string `json:"pci,omitempty"`
}

type Server added in v0.6.18 

type Server struct {
	Name string
	VM   *VM

	ConnectedTo    []string
	ConnectionType string

	Server          *wiringapi.Server
	Connection      *wiringapi.Connection
	VPCAttachment   *vpcapi.VPCAttachment
	VPC             *vpcapi.VPC
	Subnet          string
	ExternalPeering *vpcapi.ExternalPeering

	InVPCPeers []string
	VPCPeers   []string
	Externals  []string

	IP string
}

type ServerConnectivityTestConfig added in v0.6.18 

type ServerConnectivityTestConfig struct {
	AgentCheck bool

	InVPC         bool
	VPC           bool
	VPCPing       uint
	VPCIperf      uint
	VPCIperfSpeed uint

	Ext     bool
	ExtCurl bool
}

type Service 

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

func Load 

func Load(cfg *ServiceConfig) (*Service, error)

func (*Service) List 

func (svc *Service) List() error

func (*Service) RunTests added in v0.15.1 

func (svc *Service) RunTests(ctx context.Context, cfg testing.RunnerConfig) error

func (*Service) SSH 

func (svc *Service) SSH(name string, args []string) error

func (*Service) Serial 

func (svc *Service) Serial(name string) error

func (*Service) SetupPeerings added in v0.7.1 

func (svc *Service) SetupPeerings(ctx context.Context, cfg SetupPeeringsConfig) error

TODO move vpc creation to here, just have flag --vpc-per-server

func (*Service) SetupVPCs added in v0.7.1 

func (svc *Service) SetupVPCs(ctx context.Context, cfg SetupVPCsConfig) error

func (*Service) StartServer 

func (svc *Service) StartServer(killStaleVMs bool, charNBDDev string, installComplete bool, runComplete string, onReady []string) error

func (*Service) TestConnectivity added in v0.7.1 

func (svc *Service) TestConnectivity(ctx context.Context, cfg ServerConnectivityTestConfig) error

func (*Service) VFIOPCIBindAll added in v0.6.0 

func (svc *Service) VFIOPCIBindAll() error

type ServiceConfig added in v0.6.0 

type ServiceConfig struct {
	DryRun            bool
	Size              string
	SudoSwtpm         bool
	CharNBDDev        string
	InstallComplete   bool
	RunComplete       string
	OnReady           []string
	RestrictServers   bool
	Basedir           string
	Wiring            *wiring.Data
	ControlIgnition   string
	ServerIgnitionDir string
	ControlInstaller  string
	ServerInstaller   string
	FilesDir          string
	SSHKey            string
}

type SetupPeeringsConfig added in v0.7.1 

type SetupPeeringsConfig struct {
	AgentCheck bool
	DryRun     bool
	CleanupAll bool
	Requests   []string
}

type SetupVPCsConfig added in v0.7.1 

type SetupVPCsConfig struct {
	Type string
}

type SwitchConfig added in v0.6.0 

type SwitchConfig struct {
	Type   ConfigSwitchType `json:"type,omitempty"`
	Serial string           `json:"serial,omitempty"`
}

type VM 

type VM struct {
	ID         int
	Name       string
	Type       VMType
	Basedir    string
	Config     VMConfig
	Interfaces map[int]VMInterface

	Ready     fileMarker
	Installed fileMarker
}

func (*VM) OnieEepromConfig added in v0.6.0 

func (vm *VM) OnieEepromConfig() (string, error)

func (*VM) Prepare 

func (vm *VM) Prepare(ctx context.Context, svcCfg *ServiceConfig) error

func (*VM) Run 

func (vm *VM) Run(ctx context.Context, eg *errgroup.Group, svc *Service)

func (*VM) RunInstall 

func (vm *VM) RunInstall(ctx context.Context, svc *Service) func() error

func (*VM) RunTPM 

func (vm *VM) RunTPM(ctx context.Context, svcCfg *ServiceConfig) func() error

func (*VM) RunVM 

func (vm *VM) RunVM(ctx context.Context, svcCfg *ServiceConfig) func() error

func (*VM) UUID 

func (vm *VM) UUID() string

type VMConfig added in v0.6.0 

type VMConfig struct {
	CPU  int `json:"cpu,omitempty"`  // in cores
	RAM  int `json:"ram,omitempty"`  // in MB
	Disk int `json:"disk,omitempty"` // in GB
}

func (VMConfig) DefaultsFrom added in v0.6.0 

func (cfg VMConfig) DefaultsFrom(def VMConfig) VMConfig

func (VMConfig) OverrideBy added in v0.6.0 

func (cfg VMConfig) OverrideBy(def VMConfig) VMConfig

type VMInterface added in v0.6.0 

type VMInterface struct {
	Connection  string
	Netdev      string
	Passthrough string
}

type VMManager added in v0.6.0 

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

func NewVMManager added in v0.6.0 

func NewVMManager(cfg *Config, data *wiring.Data, basedir string, size string, restrictServers bool) (*VMManager, error)
func (mngr *VMManager) AddLink(local wiringapi.IPort, dest wiringapi.IPort, conn string) error

func (*VMManager) LogOverview added in v0.6.0 

func (mngr *VMManager) LogOverview()

type VMType added in v0.6.0 

type VMType string
const (
	VMTypeControl  VMType = "control"
	VMTypeServer   VMType = "server"
	VMTypeSwitchVS VMType = "switch-vs"
	VMTypeSwitchHW VMType = "switch-hw" // fake VM to simplify calculations
)

type VMsConfig added in v0.6.0 

type VMsConfig struct {
	Control VMConfig `json:"control,omitempty"`
	Server  VMConfig `json:"server,omitempty"`
	Switch  VMConfig `json:"switch,omitempty"`
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.