db

Documentation

Index

• type DB
  • func New(pool *pgxpool.Pool) *DB
  • func (db *DB) BeginTx(ctx context.Context) (*Transaction, error)
• type Queries
  • func (q *Queries) CreateFleet(ctx context.Context, fleet core.Fleet) error
  • func (q Queries) CreateGateway(ctx context.Context, gateway core.Gateway) error
  • func (q *Queries) CreateMachine(ctx context.Context, machine core.Machine) error
  • func (q *Queries) CreateMachineVersion(ctx context.Context, mv core.MachineVersion) error
  • func (q *Queries) CreateNamespace(ctx context.Context, namespace core.Namespace) error
  • func (q Queries) DeleteGateway(ctx context.Context, id string) error
  • func (q *Queries) DestroyFleet(ctx context.Context, namespace string, id string) error
  • func (q *Queries) DestroyMachine(ctx context.Context, namespace, fleetId, id string) error
  • func (q *Queries) DestroyNamespace(ctx context.Context, name string) error
  • func (q *Queries) GetFleetByID(ctx context.Context, namespace string, id string) (*core.Fleet, error)
  • func (q *Queries) GetFleetByName(ctx context.Context, namespace string, name string) (*core.Fleet, error)
  • func (q Queries) GetGatewayById(ctx context.Context, namespace, fleet, id string) (gateway core.Gateway, err error)
  • func (q Queries) GetGatewayByName(ctx context.Context, namespace, fleetId, name string) (gateway core.Gateway, err error)
  • func (q *Queries) GetMachine(ctx context.Context, namespace, fleetId, id string) (core.Machine, error)
  • func (q *Queries) GetNamespace(ctx context.Context, name string) (*core.Namespace, error)
  • func (q *Queries) ListFleets(ctx context.Context, namespace string) ([]core.Fleet, error)
  • func (q Queries) ListGateways(ctx context.Context, namespace string, fleetId string) ([]core.Gateway, error)
  • func (q *Queries) ListMachineEvents(ctx context.Context, machineId string) ([]core.InstanceEvent, error)
  • func (q *Queries) ListMachineVersions(ctx context.Context, machineId string) ([]core.MachineVersion, error)
  • func (q *Queries) ListMachines(ctx context.Context, fleetId string) ([]core.Machine, error)
  • func (q *Queries) ListNamespaces(ctx context.Context) ([]core.Namespace, error)
  • func (q *Queries) PushMachineEvent(ctx context.Context, event core.InstanceEvent) error
  • func (q Queries) UpdateGatewayName(ctx context.Context, id string, name string) error
  • func (q *Queries) UpdateMachine(ctx context.Context, machine core.Machine) error
• type Transaction
  • func (tx *Transaction) Commit(ctx context.Context) error
  • func (tx *Transaction) Rollback(ctx context.Context) error

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

func (q *Queries) ListMachineEvents(ctx context.Context, machineId string) ([]core.InstanceEvent, 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) PushMachineEvent

func (q *Queries) PushMachineEvent(ctx context.Context, event core.InstanceEvent) 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