corrosion

Documentation

Index

• func RunCorrosionMigrations(ctx context.Context, config corroclient.Config) error
• type CorrosionClusterState
  • func New(corroPgAddr string) (*CorrosionClusterState, error)
  • func (c *CorrosionClusterState) BeginTx(ctx context.Context) (cluster.TX, error)
• type Queries
  • func (c *Queries) CreateGateway(ctx context.Context, gateway api.Gateway) error
  • func (c *Queries) CreateMachine(ctx context.Context, m cluster.Machine, mv api.MachineVersion) error
  • func (c *Queries) CreateMachineVersion(ctx context.Context, mv api.MachineVersion) error
  • func (c *Queries) DeleteFleetGateways(ctx context.Context, id string) error
  • func (c *Queries) DeleteGateway(ctx context.Context, id string) error
  • func (c *Queries) DestroyMachine(ctx context.Context, id string) error
  • func (c *Queries) DestroyNamespaceData(ctx context.Context, namespace string) error
  • func (c *Queries) GetAPIMachine(ctx context.Context, namespace, fleetId, machineId string) (*api.Machine, error)
  • func (m *Queries) GetNode(ctx context.Context, id string) (api.Node, error)
  • func (c *Queries) ListAPIMachines(ctx context.Context, namespace string, fleetId string, includeDestroyed bool) ([]api.Machine, error)
  • func (m *Queries) ListNodes(ctx context.Context) ([]api.Node, error)
  • func (m *Queries) ListNodesInRegion(ctx context.Context, region string) ([]api.Node, error)
  • func (m *Queries) ListRegions(ctx context.Context) ([]string, error)
  • func (c *Queries) UpdateMachine(ctx context.Context, m cluster.Machine) error
  • func (c *Queries) UpsertInstance(ctx context.Context, i cluster.MachineInstance) error
  • func (m *Queries) UpsertNode(ctx context.Context, node api.Node) error
• type TX
  • func (t *TX) Commit(ctx context.Context) error
  • func (t *TX) Rollback(ctx context.Context) error

Functions

func RunCorrosionMigrations

func RunCorrosionMigrations(ctx context.Context, config corroclient.Config) error

Types

type CorrosionClusterState

type CorrosionClusterState struct {
	cluster.Queries
	// contains filtered or unexported fields
}

func New

func New(corroPgAddr string) (*CorrosionClusterState, error)

func (*CorrosionClusterState) BeginTx

func (c *CorrosionClusterState) BeginTx(ctx context.Context) (cluster.TX, error)

BeginTx implements cluster.ClusterState.

type Queries

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

func (*Queries) CreateGateway

func (c *Queries) CreateGateway(ctx context.Context, gateway api.Gateway) error

func (*Queries) CreateMachine

func (c *Queries) CreateMachine(ctx context.Context, m cluster.Machine, mv api.MachineVersion) error

func (*Queries) CreateMachineVersion

func (c *Queries) CreateMachineVersion(ctx context.Context, mv api.MachineVersion) error

func (*Queries) DeleteFleetGateways

func (c *Queries) DeleteFleetGateways(ctx context.Context, id string) error

func (*Queries) DeleteGateway

func (c *Queries) DeleteGateway(ctx context.Context, id string) error

func (*Queries) DestroyMachine

func (c *Queries) DestroyMachine(ctx context.Context, id string) error

func (*Queries) DestroyNamespaceData

func (c *Queries) DestroyNamespaceData(ctx context.Context, namespace string) error

DestroyNamespaceData implements cluster.ClusterState.

func (*Queries) GetAPIMachine

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

func (*Queries) GetNode

func (m *Queries) GetNode(ctx context.Context, id string) (api.Node, error)

func (*Queries) ListAPIMachines

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

func (*Queries) ListNodes

func (m *Queries) ListNodes(ctx context.Context) ([]api.Node, error)

func (*Queries) ListNodesInRegion

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

func (*Queries) ListRegions

func (m *Queries) ListRegions(ctx context.Context) ([]string, error)

func (*Queries) UpdateMachine

func (c *Queries) UpdateMachine(ctx context.Context, m cluster.Machine) error

func (*Queries) UpsertInstance

func (c *Queries) UpsertInstance(ctx context.Context, i cluster.MachineInstance) error

func (*Queries) UpsertNode

func (m *Queries) UpsertNode(ctx context.Context, node api.Node) error

type TX

type TX struct {
	*Queries
	// contains filtered or unexported fields
}

func (*TX) Commit

func (t *TX) Commit(ctx context.Context) error

func (*TX) Rollback

func (t *TX) Rollback(ctx context.Context) error