db

package
v0.0.0-...-f818ad4 Latest Latest
Warning

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

Go to latest
Published: Jun 14, 2026 License: MIT Imports: 8 Imported by: 0

README

DB

All code in here is generated by sqlc from the files and config in the _sqlc subfolder

Installation

https://docs.sqlc.dev/en/latest/overview/install.html

Making Changes

DON'T MODIFY THE GO FILES DIRECTLY

DO:

  1. Modify schema.sql to update models
  2. Modify query.sql to specify queries you want to generate code for After doing 1 or 2, run sqlc generate in the _sqlc directory to regenerate the code

Loading Model Changes into the DB

  • BE CAREFUL NOT TO WIPE OUT EXISTING DATA * psql -h localhost -W -U [username] -d [db_name] -f schema.sql

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddPipelineParams

type AddPipelineParams struct {
	PipelineID    uuid.UUID
	NodesPerStage []int32
	Nodes         []uuid.UUID
}

type DBTX

type DBTX interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
	PrepareContext(context.Context, string) (*sql.Stmt, error)
	QueryContext(context.Context, string, ...interface{}) (*sql.Rows, error)
	QueryRowContext(context.Context, string, ...interface{}) *sql.Row
}

type Node

type Node struct {
	ID        uuid.UUID
	Type      sql.NullInt32
	CreatedAt time.Time
}

type NodeAlias

type NodeAlias struct {
	ID     int32
	NodeID uuid.NullUUID
	Alias  sql.NullString
}

type NodeDraft

type NodeDraft struct {
	ID        uuid.UUID
	Type      sql.NullInt32
	CreatedAt time.Time
}

type NodeHistory

type NodeHistory struct {
	ID        int32
	NodeID    uuid.NullUUID
	UpdatedAt time.Time
	Version   sql.NullInt32
	Body      pqtype.NullRawMessage
}

type Pipeline

type Pipeline struct {
	ID        uuid.UUID
	CreatedAt time.Time
}

type PipelineDraft

type PipelineDraft struct {
	ID        uuid.UUID
	CreatedAt time.Time
}

type PipelineHistory

type PipelineHistory struct {
	ID            int32
	PipelineID    uuid.UUID
	NodesPerStage []int32
	UpdatedAt     time.Time
	Nodes         []uuid.UUID
	NodeVersions  []int32
	Version       sql.NullInt32
}

type Queries

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

func InitDB

func InitDB(ctx context.Context) (*Queries, error)

func New

func New(db DBTX) *Queries

func (*Queries) AddPipeline

func (q *Queries) AddPipeline(ctx context.Context, arg AddPipelineParams) error

func (*Queries) GetLatestNode

func (q *Queries) GetLatestNode(ctx context.Context, id uuid.UUID) (Node, error)

func (*Queries) GetLatestNodes

func (q *Queries) GetLatestNodes(ctx context.Context, ids []uuid.UUID) ([]Node, error)

func (*Queries) GetLatestPipeline

func (q *Queries) GetLatestPipeline(ctx context.Context, pipelineID uuid.UUID) (PipelineHistory, error)

func (*Queries) GetNodeHistory

func (q *Queries) GetNodeHistory(ctx context.Context, nodeID uuid.NullUUID) (NodeHistory, error)

func (*Queries) GetNodesHistory

func (q *Queries) GetNodesHistory(ctx context.Context, ids []uuid.UUID) ([]NodeHistory, error)

func (*Queries) GetPipelineHistory

func (q *Queries) GetPipelineHistory(ctx context.Context, pipelineID uuid.UUID) ([]PipelineHistory, error)

func (*Queries) WithTx

func (q *Queries) WithTx(tx *sql.Tx) *Queries

Jump to

Keyboard shortcuts

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