controllers

type AttachVolume struct {
	Name   string
	Device string
	Spec   providervolume.Volume
}

type DomainExecutor interface {
	AttachDisk(disk *libvirtxml.DomainDisk) error
	DetachDisk(disk *libvirtxml.DomainDisk) error
	ResizeDisk(device string, size int64) error

	ApplySecret(secret *libvirtxml.Secret, data []byte) error
	DeleteSecret(secretUUID string) error
}

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

type MachineReconcilerOptions struct {
	GuestCapabilities              guest.Capabilities
	TCMallocLibPath                string
	ImageCache                     providerimage.Cache
	Raw                            raw.Raw
	Host                           providerhost.Host
	VolumePluginManager            *providervolume.PluginManager
	NetworkInterfacePlugin         providernetworkinterface.Plugin
	VolumeEvents                   event.Source[*api.Machine]
	ResyncIntervalVolumeSize       time.Duration
	ResyncIntervalGarbageCollector time.Duration
	EnableHugepages                bool
	GCVMGracefulShutdownTimeout    time.Duration
}

type MountVolume = providerhost.MachineVolume

type VolumeAttacher interface {
	ListVolumes() ([]AttachVolume, error)
	ForEachVolume(f func(*AttachVolume) bool) error
	GetVolume(name string) (*AttachVolume, error)
	AttachVolume(volume *AttachVolume) error
	DetachVolume(name string) error
	ResizeVolume(volume *AttachVolume) error
}

type VolumeMounter interface {
	PluginManager() *providervolume.PluginManager

	ForEachVolume(f func(*MountVolume) bool) error
	ListVolumes() ([]MountVolume, error)
	GetVolume(computeVolumeName string) (*MountVolume, error)
	ApplyVolume(ctx context.Context, spec *api.VolumeSpec, onDelete func(*MountVolume) error) (string, *providervolume.Volume, error)
	DeleteVolume(ctx context.Context, computeVolumeName string) error
}