cluster

package

Go to main page

Versions in this module

v0

v0.7.2

Jan 21, 2025

Changes in this version

type Queries

+ ListRegions func(ctx context.Context) ([]string, error)

v0.7.1

Jan 19, 2025

v0.7.0

Jan 18, 2025

v0.6.1

Jan 15, 2025

v0.6.0

Jan 15, 2025

Changes in this version

type Agent

+ WaitForMachineStatus func(ctx context.Context, id string, status api.MachineStatus, timeout uint) error

v0.5.0

Jan 11, 2025

Changes in this version

type Agent

+ DisableMachineGateway func(ctx context.Context, id string) error

+ EnableMachineGateway func(ctx context.Context, id string) error

type MachineInstance

+ EnableMachineGateway bool

type PutMachineOptions

+ EnableGateway bool

v0.4.2

Jan 11, 2025

v0.4.1

Jan 11, 2025

v0.4.0

Jan 11, 2025

Changes in this version

type ClusterState

+ BeginTx func(ctx context.Context) (TX, error)

+ type Queries interface

+ CreateGateway func(ctx context.Context, gateway api.Gateway) error

+ CreateMachine func(ctx context.Context, m Machine, mv api.MachineVersion) error

+ CreateMachineVersion func(ctx context.Context, mv api.MachineVersion) error

+ DeleteFleetGateways func(ctx context.Context, fleetId string) error

+ DeleteGateway func(ctx context.Context, id string) error

+ DestroyMachine func(ctx context.Context, id string) error

+ DestroyNamespaceData func(ctx context.Context, namespace string) error

+ GetAPIMachine func(ctx context.Context, namespace string, fleetId string, machineId string) (*api.Machine, error)

+ GetNode func(ctx context.Context, id string) (api.Node, error)

+ ListAPIMachines func(ctx context.Context, namespace string, fleetId string, includeDestroyed bool) ([]api.Machine, error)

+ ListNodes func(ctx context.Context) ([]api.Node, error)

+ ListNodesInRegion func(ctx context.Context, region string) ([]api.Node, error)

+ UpdateMachine func(ctx context.Context, m Machine) error

+ UpsertInstance func(ctx context.Context, i MachineInstance) error

+ UpsertNode func(ctx context.Context, node api.Node) error

+ type TX interface

+ Commit func(context.Context) error

+ Rollback func(context.Context) error

v0.3.0

Jan 6, 2025

v0.2.0

Dec 19, 2024

v0.2.0-alpha.1

Dec 19, 2024

v0.2.0-alpha

Dec 19, 2024

v0.1.4-alpha.0

Dec 4, 2024

v0.1.3

Dec 3, 2024

v0.1.3-alpha.0

Dec 3, 2024

v0.1.2

Dec 3, 2024

v0.1.1

Dec 3, 2024

v0.1.0

Dec 3, 2024

Changes in this version

+ type Agent interface

+ DestroyMachine func(ctx context.Context, machineId string, force bool) error

+ GetMachineLogs func(ctx context.Context, id string) ([]*api.LogEntry, error)

+ MachineExec func(ctx context.Context, machineId string, cmd []string, timeout time.Duration) (*api.ExecResult, error)

+ PutMachine func(ctx context.Context, opt PutMachineOptions) (*MachineInstance, error)

+ StartMachine func(ctx context.Context, machineId string) error

+ StopMachine func(ctx context.Context, machineId string, opt *api.StopConfig) error

+ SubscribeToMachineLogs func(ctx context.Context, id string) ([]*api.LogEntry, <-chan *api.LogEntry, error)

+ type ClusterState interface

+ CreateGateway func(ctx context.Context, gateway api.Gateway) error

+ CreateMachine func(ctx context.Context, m Machine, mv api.MachineVersion) error

+ DeleteFleetGateways func(ctx context.Context, fleetId string) error

+ DeleteGateway func(ctx context.Context, id string) error

+ DestroyMachine func(ctx context.Context, id string) error

+ DestroyNamespaceData func(ctx context.Context, namespace string) error

+ GetAPIMachine func(ctx context.Context, namespace string, fleetId string, machineId string) (*api.Machine, error)

+ GetNode func(ctx context.Context, id string) (api.Node, error)

+ ListAPIMachines func(ctx context.Context, namespace string, fleetId string, includeDestroyed bool) ([]api.Machine, error)

+ ListNodes func(ctx context.Context) ([]api.Node, error)

+ ListNodesInRegion func(ctx context.Context, region string) ([]api.Node, error)

+ UpdateMachine func(ctx context.Context, m Machine) error

+ UpsertInstance func(ctx context.Context, i MachineInstance) error

+ UpsertNode func(ctx context.Context, node api.Node) error

+ WatchInstanceStatus func(ctx context.Context, machineId string, instanceId string) (context.CancelFunc, <-chan string, error)

+ type Machine struct

+ CreatedAt time.Time

+ DestroyedAt *time.Time

+ FleetId string

+ Id string

+ InstanceId string

+ MachineVersion string

+ Namespace string

+ Node string

+ Region string

+ UpdatedAt time.Time

+ type MachineInstance struct

+ CreatedAt time.Time

+ Events []api.MachineEvent

+ Id string

+ LocalIPV4 string

+ MachineId string

+ MachineVersion string

+ Namespace string

+ Node string

+ Status api.MachineStatus

+ UpdatedAt time.Time

+ type PutMachineOptions struct

+ AllocationId string

+ Machine Machine

+ Start bool

+ Version api.MachineVersion

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