machine

Documentation

Index

• func AcquireLease(ctx context.Context, machine *api.Machine) (*api.Machine, error)
• func AcquireLeases(ctx context.Context) ([]*api.Machine, 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 WaitForStartOrStop(ctx context.Context, machine *api.Machine, action string, ...) error

Functions

func AcquireLease

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

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

func AcquireLeases

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

AcquireLeases works to acquire a leases for each active machine. WARNING: Make sure you defer the lease release process.

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 WaitForStartOrStop

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