Help us shape the future of Go! Take the 2026 Go Developer Survey

flaps

package
v0.1.60 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 19, 2023 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FlapsErrorNotFound = &FlapsError{ResponseStatusCode: http.StatusNotFound}
)
View Source 
var NonceHeader = "fly-machine-lease-nonce"

Functions

func NewContext added in v0.0.349 

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

NewContext derives a Context that carries c from ctx.

Types

type Client 

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

func FromContext added in v0.0.349 

func FromContext(ctx context.Context) *Client

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

func New 

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

func NewFromAppName added in v0.0.489 

func NewFromAppName(ctx context.Context, appName string) (*Client, error)

func NewWithOptions added in v0.0.545 

func NewWithOptions(ctx context.Context, opts NewClientOpts) (*Client, error)

func (*Client) AcquireLease added in v0.0.434 

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

func (*Client) Cordon added in v0.1.40 

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

func (*Client) CreateApp 

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

func (*Client) Destroy 

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

func (*Client) Exec added in v0.0.451 

func (f *Client) Exec(ctx context.Context, machineID string, in *api.MachineExecRequest) (*api.MachineExecResponse, error)

func (*Client) FindLease added in v0.0.434 

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

func (*Client) Get 

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

func (*Client) GetMany added in v0.0.416 

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

func (*Client) GetProcesses added in v0.1.1 

func (f *Client) GetProcesses(ctx context.Context, machineID string) (api.MachinePsResponse, error)

func (*Client) Kill 

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

func (*Client) Launch 

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

func (*Client) List 

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

func (*Client) ListActive added in v0.0.376 

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

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

func (*Client) ListFlyAppsMachines added in v0.0.452 

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

ListFlyAppsMachines returns apps that are part of the Fly apps platform. Destroyed machines and console machines are excluded. Unlike other List functions, this function retries multiple times.

func (*Client) NewRequest 

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

func (*Client) RefreshLease added in v0.0.466 

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

func (*Client) ReleaseLease 

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

func (*Client) Restart added in v0.0.404 

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

func (*Client) Start 

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

func (*Client) Stop 

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

func (*Client) UnCordon added in v0.1.40 

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

func (*Client) Update 

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

func (*Client) Wait 

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

type FlapsError added in v0.0.459 

type FlapsError struct {
	OriginalError      error
	ResponseStatusCode int
	ResponseBody       []byte
	FlyRequestId       string
}

func (*FlapsError) Error added in v0.0.459 

func (fe *FlapsError) Error() string

func (*FlapsError) Is added in v0.1.24 

func (fe *FlapsError) Is(target error) bool

func (*FlapsError) ResponseBodyString added in v0.0.459 

func (fe *FlapsError) ResponseBodyString() string

func (*FlapsError) Unwrap added in v0.0.459 

func (fe *FlapsError) Unwrap() error

type NewClientOpts added in v0.0.545 

type NewClientOpts struct {
	// required:
	AppName string

	// optional, avoids API roundtrip when connecting to flaps by wireguard:
	AppCompact *api.AppCompact

	// optional:
	Logger api.Logger
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.