executor

package

v0.25.0 Latest Latest Go to latest Published: Jan 30, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation ¶

Index ¶

Constants
Variables
type CreateMachineResult
type ErrFlavorNotFound
- func (e ErrFlavorNotFound) Error() string
type Executor
- func NewExecutor(factory *client.Factory, config *api.MachineProviderConfig) (*Executor, error)

Constants ¶

const NoValidHost = "No valid host was found"

NoValidHost is a part of the error message returned when there is no valid host in the zone to deploy a VM. Matches:

"No valid host was found."
"No valid host was found. There are not enough hosts available."

Variables ¶

View Source

var (
	// ErrNotFound is returned when the requested resource could not be found.
	ErrNotFound = fmt.Errorf("resource not found")

	// ErrMultipleFound is returned when a resource that is expected to be unique has multiple matches.
	// For example, reverse lookups from names to IDs may yield multiple matches because names are not unique in most
	// OpenStack resources. In case this case, where a unique ID could not be determined an ErrMultipleFound is returned.
	ErrMultipleFound = fmt.Errorf("multiple resources found")
)

Functions ¶

This section is empty.

Types ¶

type CreateMachineResult ¶ added in v0.25.0

type CreateMachineResult struct {
	ProviderID  string
	InternalIPs []string
}

CreateMachineResult represents the result of a CreateMachine call (internal IP addresses + provider ID of VM).

type ErrFlavorNotFound ¶ added in v0.25.0

type ErrFlavorNotFound struct {
	Flavor string
}

ErrFlavorNotFound is returned when there is no flavor can be matched with the specified flavor name. It can happen when certain flavor is not available in specified region and needs to be treated as ResourceExhausted to allow fallback to other flavors.

func (ErrFlavorNotFound) Error ¶ added in v0.25.0

func (e ErrFlavorNotFound) Error() string

type Executor ¶

type Executor struct {
	Compute client.Compute
	Network client.Network
	Storage client.Storage
	Config  *api.MachineProviderConfig
}

Executor concretely handles the execution of requests to the machine controller. Executor is responsible for communicating with OpenStack services and orchestrates the operations.

func NewExecutor ¶

func NewExecutor(factory *client.Factory, config *api.MachineProviderConfig) (*Executor, error)

NewExecutor returns a new instance of Executor.

func (*Executor) CreateMachine ¶

func (ex *Executor) CreateMachine(ctx context.Context, machineName string, userData []byte) (*CreateMachineResult, error)

CreateMachine creates a new OpenStack server instance and waits until it reports "ACTIVE". If there is an error during the build process, or if the building phase timeouts, it will delete any artifacts created.

func (*Executor) DeleteMachine ¶

func (ex *Executor) DeleteMachine(ctx context.Context, machineName, providerID string) error

DeleteMachine deletes a server based on the supplied machineName. If a providerID is supplied it is used instead of the machineName to locate the server.

func (*Executor) ListMachines ¶

func (ex *Executor) ListMachines(ctx context.Context) (map[string]string, error)

ListMachines lists returns a map from the server's encoded provider ID to the server name.

Source Files ¶

View all Source files

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