virtual

package

v0.0.0-...-87f46c2 Latest Latest Go to latest Published: May 28, 2026 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation ¶

Index ¶

Constants
Variables
func BuildReadyConditions(readyConditionStatus corev1.ConditionStatus) []corev1.NodeCondition
func FileExists(filepath string) bool
func NewDriver(ctx context.Context, kubeconfig string, shootNamespace string) (driver.Driver, error)
type DriverImpl
type InstanceDelays
type Quota
- func (q Quota) String() string
type QuotaLookup
type SimulationConfig

Constants ¶

const (
	// ProviderAWS string const to identify AWS provider
	ProviderAWS         = "AWS"
	QuotaPrefixFmt      = "QUOTA_%d"
	QuotaMachineTypeFmt = QuotaPrefixFmt + "_MACHINE_TYPE"
	QuotaRegionFmt      = QuotaPrefixFmt + "_REGION"
	QuotaAmountFmt      = QuotaPrefixFmt + "_AMOUNT"
)

Variables ¶

View Source

var SimulationConfigPath = "gen/simulation-config.json"

Functions ¶

func BuildReadyConditions ¶

func BuildReadyConditions(readyConditionStatus corev1.ConditionStatus) []corev1.NodeCondition

func FileExists ¶

func FileExists(filepath string) bool

func NewDriver ¶

func NewDriver(ctx context.Context, kubeconfig string, shootNamespace string) (driver.Driver, error)

Types ¶

type DriverImpl ¶

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

DriverImpl is the struct that implements the MCM driver.Driver interface

func (*DriverImpl) CreateMachine ¶

func (d *DriverImpl) CreateMachine(ctx context.Context, req *driver.CreateMachineRequest) (resp *driver.CreateMachineResponse, err error)

func (*DriverImpl) DeleteMachine ¶

func (d *DriverImpl) DeleteMachine(ctx context.Context, request *driver.DeleteMachineRequest) (response *driver.DeleteMachineResponse, err error)

func (*DriverImpl) GetMachineStatus ¶

func (d *DriverImpl) GetMachineStatus(ctx context.Context, request *driver.GetMachineStatusRequest) (response *driver.GetMachineStatusResponse, err error)

func (*DriverImpl) GetVolumeIDs ¶

func (d *DriverImpl) GetVolumeIDs(ctx context.Context, request *driver.GetVolumeIDsRequest) (response *driver.GetVolumeIDsResponse, err error)

func (*DriverImpl) InitializeMachine ¶

func (d *DriverImpl) InitializeMachine(ctx context.Context, request *driver.InitializeMachineRequest) (*driver.InitializeMachineResponse, error)

func (*DriverImpl) ListMachines ¶

func (d *DriverImpl) ListMachines(ctx context.Context, request *driver.ListMachinesRequest) (response *driver.ListMachinesResponse, err error)

type InstanceDelays ¶

type InstanceDelays struct {
	CreateMin     int64
	CreateMax     int64
	InitializeMin int64
	InitializeMax int64
	JoinMin       int64
	JoinMax       int64
	DeleteMin     int64
	DeleteMax     int64
}

InstanceDelays represents the minimum and maximum delays in seconds taken to create, initialize or join instance to cluster. The real value will be randomized between minimum and maximum

type Quota ¶

type Quota struct {
	MachineType string
	Region      string
	Amount      int
}

func (Quota) String ¶

func (q Quota) String() string

type QuotaLookup ¶

type QuotaLookup struct {
	MachineType string
	RegionName  string
}

type SimulationConfig ¶

type SimulationConfig struct {
	Quotas         []Quota
	InstanceDelays InstanceDelays
}

Source Files ¶

View all Source files

virtual.go

Directories ¶

Path	Synopsis
awsfake

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