machine

Documentation

Index

• func AcquireAllLeases(ctx context.Context) ([]*api.Machine, releaseLeasesFunc, error)
• func AcquireLease(ctx context.Context, machine *api.Machine) (*api.Machine, releaseLeaseFunc, error)
• func AcquireLeases(ctx context.Context, machines []*api.Machine) ([]*api.Machine, releaseLeasesFunc, error)
• func CloneConfig(orig api.MachineConfig) (*api.MachineConfig, error)
• func ConfirmConfigChanges(ctx context.Context, machine *api.Machine, targetConfig api.MachineConfig, ...) (bool, error)
• func ListActive(ctx context.Context) ([]*api.Machine, error)
• func Restart(ctx context.Context, m *api.Machine, input *api.RestartMachineInput) error
• func RollingRestart(ctx context.Context, input *api.RestartMachineInput) error
• func Update(ctx context.Context, m *api.Machine, input *api.LaunchMachineInput) error
• func WaitForStartOrStop(ctx context.Context, machine *api.Machine, action string, ...) error
• type ErrNoConfigChangesFound
  • func (e *ErrNoConfigChangesFound) Error() string
• type LeasableMachine
  • func NewLeasableMachine(flapsClient *flaps.Client, io *iostreams.IOStreams, machine *api.Machine) LeasableMachine
• type MachineSet
  • func NewMachineSet(flapsClient *flaps.Client, io *iostreams.IOStreams, machines []*api.Machine) MachineSet

Functions

func AcquireAllLeases

func AcquireAllLeases(ctx context.Context) ([]*api.Machine, releaseLeasesFunc, error)

AcquireAllLeases works to acquire/attach a lease for each active machine.

func AcquireLease

func AcquireLease(ctx context.Context, machine *api.Machine) (*api.Machine, releaseLeaseFunc, error)

AcquireLease works to acquire/attach a lease for the specified machine. WARNING: Make sure you defer the lease release process.

func AcquireLeases

func AcquireLeases(ctx context.Context, machines []*api.Machine) ([]*api.Machine, releaseLeasesFunc, error)

AcquireLeases works to acquire/attach a lease for each machine specified.

func CloneConfig

func CloneConfig(orig api.MachineConfig) (*api.MachineConfig, error)

func ConfirmConfigChanges

func ConfirmConfigChanges(ctx context.Context, machine *api.Machine, targetConfig api.MachineConfig, customPrompt string) (bool, error)

func ListActive

func ListActive(ctx context.Context) ([]*api.Machine, error)

func Restart

func Restart(ctx context.Context, m *api.Machine, input *api.RestartMachineInput) error

func RollingRestart

func RollingRestart(ctx context.Context, input *api.RestartMachineInput) error

func Update

func Update(ctx context.Context, m *api.Machine, input *api.LaunchMachineInput) error

func WaitForStartOrStop

func WaitForStartOrStop(ctx context.Context, machine *api.Machine, action string, timeout time.Duration) error

Types

type ErrNoConfigChangesFound

type ErrNoConfigChangesFound struct{}

func (*ErrNoConfigChangesFound) Error

func (e *ErrNoConfigChangesFound) Error() string

type LeasableMachine

type LeasableMachine interface {
	Machine() *api.Machine
	HasLease() bool
	AcquireLease(context.Context, time.Duration) error
	ReleaseLease(context.Context) error
	Update(context.Context, api.LaunchMachineInput) error
	Start(context.Context) error
	Destroy(context.Context, bool) error
	WaitForState(context.Context, string, time.Duration) error
	WaitForHealthchecksToPass(context.Context, time.Duration) error
	WaitForEventTypeAfterType(context.Context, string, string, time.Duration) (*api.MachineEvent, error)
	FormattedMachineId() string
}

func NewLeasableMachine

func NewLeasableMachine(flapsClient *flaps.Client, io *iostreams.IOStreams, machine *api.Machine) LeasableMachine

type MachineSet

type MachineSet interface {
	AcquireLeases(context.Context, time.Duration) error
	ReleaseLeases(context.Context) error
	IsEmpty() bool
	GetMachines() []LeasableMachine
}

func NewMachineSet

func NewMachineSet(flapsClient *flaps.Client, io *iostreams.IOStreams, machines []*api.Machine) MachineSet