db

package

v0.7.2 Latest Latest Go to latest Published: Jan 21, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/valyentdev/ravel

Documentation ¶

Index ¶

type DB
- func New(pool *pgxpool.Pool) *DB
- func (db *DB) BeginTx(ctx context.Context) (*Transaction, error)
type Queries
type Transaction
- func (tx *Transaction) Commit(ctx context.Context) error
- func (tx *Transaction) Rollback(ctx context.Context) error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DB ¶

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

func New ¶

func New(pool *pgxpool.Pool) *DB

func (*DB) BeginTx ¶

func (db *DB) BeginTx(ctx context.Context) (*Transaction, error)

type Queries ¶

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

func (*Queries) CountActiveFleets ¶

func (q *Queries) CountActiveFleets(ctx context.Context, namespace string) (int, error)

func (*Queries) CountExistingMachinesInFleet ¶

func (q *Queries) CountExistingMachinesInFleet(ctx context.Context, fleetId string) (int, error)

func (*Queries) CreateFleet ¶

func (q *Queries) CreateFleet(ctx context.Context, fleet api.Fleet) error

func (Queries) CreateGateway ¶

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

func (*Queries) CreateMachine ¶

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

func (*Queries) CreateMachineVersion ¶

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

func (*Queries) CreateNamespace ¶

func (q *Queries) CreateNamespace(ctx context.Context, namespace api.Namespace) error

func (Queries) DeleteFleetGateways ¶

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

func (Queries) DeleteGateway ¶

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

func (*Queries) DestroyFleet ¶

func (q *Queries) DestroyFleet(ctx context.Context, id string) error

func (*Queries) DestroyMachine ¶

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

func (*Queries) DestroyNamespace ¶

func (q *Queries) DestroyNamespace(ctx context.Context, name string) error

func (*Queries) GetFleetByID ¶

func (q *Queries) GetFleetByID(ctx context.Context, namespace string, id string) (*api.Fleet, error)

func (*Queries) GetFleetByName ¶

func (q *Queries) GetFleetByName(ctx context.Context, namespace string, name string) (*api.Fleet, error)

func (*Queries) GetFleetForShare ¶

func (q *Queries) GetFleetForShare(ctx context.Context, id string) (*api.Fleet, error)

func (*Queries) GetFleetForUpdate ¶

func (q *Queries) GetFleetForUpdate(ctx context.Context, id string) (*api.Fleet, error)

func (Queries) GetGatewayById ¶

func (q Queries) GetGatewayById(ctx context.Context, namespace, fleetId, id string) (gateway api.Gateway, err error)

func (Queries) GetGatewayByName ¶

func (q Queries) GetGatewayByName(ctx context.Context, namespace, fleet, name string) (gateway api.Gateway, err error)

func (*Queries) GetMachine ¶

func (q *Queries) GetMachine(ctx context.Context, namespace, fleetId, id string, showDestroyed bool) (cluster.Machine, error)

func (*Queries) GetNamespace ¶

func (q *Queries) GetNamespace(ctx context.Context, name string) (*api.Namespace, error)

func (*Queries) GetNamespaceForShare ¶

func (q *Queries) GetNamespaceForShare(ctx context.Context, name string) (*api.Namespace, error)

func (*Queries) GetNamespaceForUpdate ¶

func (q *Queries) GetNamespaceForUpdate(ctx context.Context, name string) (*api.Namespace, error)

func (*Queries) ListFleets ¶

func (q *Queries) ListFleets(ctx context.Context, namespace string) ([]api.Fleet, error)

func (Queries) ListGateways ¶

func (q Queries) ListGateways(ctx context.Context, namespace string) ([]api.Gateway, error)

func (Queries) ListGatewaysOnFleet ¶ added in v0.3.0

func (q Queries) ListGatewaysOnFleet(ctx context.Context, ns string, fleetId string) ([]api.Gateway, error)

func (*Queries) ListMachineEvents ¶

func (q *Queries) ListMachineEvents(ctx context.Context, machineId string) ([]api.MachineEvent, error)

func (*Queries) ListMachineVersions ¶

func (q *Queries) ListMachineVersions(ctx context.Context, machineId string) ([]api.MachineVersion, error)

func (*Queries) ListMachines ¶

func (q *Queries) ListMachines(ctx context.Context, fleetId string) ([]cluster.Machine, error)

func (*Queries) ListNamespaces ¶

func (q *Queries) ListNamespaces(ctx context.Context) ([]api.Namespace, error)

func (*Queries) PushMachineEvent ¶

func (q *Queries) PushMachineEvent(ctx context.Context, event api.MachineEvent) error

func (Queries) UpdateGatewayName ¶

func (q Queries) UpdateGatewayName(ctx context.Context, id string, name string) error

func (*Queries) UpdateMachine ¶

func (q *Queries) UpdateMachine(ctx context.Context, machine cluster.Machine) error

type Transaction ¶

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

func (*Transaction) Commit ¶

func (tx *Transaction) Commit(ctx context.Context) error

func (*Transaction) Rollback ¶

func (tx *Transaction) Rollback(ctx context.Context) error

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
schema

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