flaps

package

v0.0.431 Latest Latest Go to latest Published: Nov 13, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

View Source

var NonceHeader = "fly-machine-lease-nonce"

func NewContext(ctx context.Context, c *Client) context.Context

NewContext derives a Context that carries c from ctx.

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

func FromContext(ctx context.Context) *Client

FromContext returns the Client ctx carries. It panics in case ctx carries no Client.

func New(ctx context.Context, app *api.AppCompact) (*Client, error)

func (f *Client) CreateApp(ctx context.Context, name string, org string) (err error)

func (f *Client) Destroy(ctx context.Context, input api.RemoveMachineInput) (err error)

func (f *Client) Get(ctx context.Context, machineID string) (*api.Machine, error)

func (f *Client) GetLease(ctx context.Context, machineID string, ttl *int) (*api.MachineLease, error)

func (f *Client) GetMany(ctx context.Context, machineIDs []string) ([]*api.Machine, error)

func (f *Client) Kill(ctx context.Context, machineID string) (err error)

func (f *Client) Launch(ctx context.Context, builder api.LaunchMachineInput) (*api.Machine, error)

func (f *Client) List(ctx context.Context, state string) ([]*api.Machine, error)

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

ListActive returns only non-destroyed that aren't in a reserved process group.

func (f *Client) NewRequest(ctx context.Context, method, path string, in interface{}, headers map[string][]string) (*http.Request, error)

func (f *Client) ReleaseLease(ctx context.Context, machineID, nonce string) error

func (f *Client) Restart(ctx context.Context, in api.RestartMachineInput) (err error)

func (f *Client) Start(ctx context.Context, machineID string) (*api.MachineStartResponse, error)

func (f *Client) Stop(ctx context.Context, in api.StopMachineInput) (err error)

func (f *Client) Update(ctx context.Context, builder api.LaunchMachineInput, nonce string) (*api.Machine, error)

func (f *Client) Wait(ctx context.Context, machine *api.Machine, state string) (err error)