db

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Oct 16, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

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) CreateFleet

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

func (Queries) CreateGateway

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

func (*Queries) CreateMachine

func (q *Queries) CreateMachine(ctx context.Context, machine core.Machine) error

func (*Queries) CreateMachineVersion

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

func (*Queries) CreateNamespace

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

func (Queries) DeleteGateway

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

func (*Queries) DestroyFleet

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

func (*Queries) DestroyMachine

func (q *Queries) DestroyMachine(ctx context.Context, namespace, fleetId, 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) (*core.Fleet, error)

func (*Queries) GetFleetByName

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

func (Queries) GetGatewayById

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

func (Queries) GetGatewayByName

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

func (*Queries) GetMachine

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

func (*Queries) GetNamespace

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

func (*Queries) ListFleets

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

func (Queries) ListGateways

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

func (*Queries) ListMachineVersions

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

func (*Queries) ListMachines

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

func (*Queries) ListNamespaces

func (q *Queries) ListNamespaces(ctx context.Context) ([]core.Namespace, 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 core.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

Jump to

Keyboard shortcuts

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