db

package
v1.2.3 Latest Latest
Warning

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

Go to latest
Published: Apr 16, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Provider

func Provider() embed.FS

Provider returns the embedded project migrations for registration with schemaf. Wire up in go/main.go: app.AddDb(db.Provider)

Types

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 Edge

type Edge struct {
	ID           string          `json:"id"`
	SourceNodeID string          `json:"source_node_id"`
	TargetNodeID string          `json:"target_node_id"`
	Type         string          `json:"type"`
	Confidence   sql.NullFloat64 `json:"confidence"`
	RunID        sql.NullString  `json:"run_id"`
	CreatedAt    time.Time       `json:"created_at"`
}

type GetEdgesBySourceAndTypeParams

type GetEdgesBySourceAndTypeParams struct {
	SourceNodeID string `json:"source_node_id"`
	Type         string `json:"type"`
}

type GetEdgesByTargetAndTypeParams

type GetEdgesByTargetAndTypeParams struct {
	TargetNodeID string `json:"target_node_id"`
	Type         string `json:"type"`
}

type InsertEdgeParams

type InsertEdgeParams struct {
	ID           string          `json:"id"`
	SourceNodeID string          `json:"source_node_id"`
	TargetNodeID string          `json:"target_node_id"`
	Type         string          `json:"type"`
	Confidence   sql.NullFloat64 `json:"confidence"`
	RunID        sql.NullString  `json:"run_id"`
}

type InsertNodeParams

type InsertNodeParams struct {
	ID                    string          `json:"id"`
	Level                 int16           `json:"level"`
	ContentClass          string          `json:"content_class"`
	ContentType           string          `json:"content_type"`
	EncodingClass         string          `json:"encoding_class"`
	EncodingFormat        string          `json:"encoding_format"`
	ContentSha256         string          `json:"content_sha256"`
	ContentLen            int64           `json:"content_len"`
	ContentCached         sql.NullString  `json:"content_cached"`
	ArtifactCreatedAt     sql.NullTime    `json:"artifact_created_at"`
	ArtifactCreatedAtBlur sql.NullString  `json:"artifact_created_at_blur"`
	Origin                sql.NullString  `json:"origin"`
	OriginalName          sql.NullString  `json:"original_name"`
	ValidFrom             sql.NullTime    `json:"valid_from"`
	ValidFromBlur         sql.NullString  `json:"valid_from_blur"`
	ValidUntil            sql.NullTime    `json:"valid_until"`
	ValidUntilBlur        sql.NullString  `json:"valid_until_blur"`
	Confidence            sql.NullFloat64 `json:"confidence"`
}

type InsertRunParams

type InsertRunParams struct {
	ID             string `json:"id"`
	WorkerConfigID string `json:"worker_config_id"`
}

type ListEdgesByTypeParams

type ListEdgesByTypeParams struct {
	Type   string `json:"type"`
	Limit  int32  `json:"limit"`
	Offset int32  `json:"offset"`
}

type ListEdgesParams

type ListEdgesParams struct {
	Limit  int32 `json:"limit"`
	Offset int32 `json:"offset"`
}

type ListNodesByContentClassAndTypeParams

type ListNodesByContentClassAndTypeParams struct {
	ContentClass string `json:"content_class"`
	ContentType  string `json:"content_type"`
	Limit        int32  `json:"limit"`
	Offset       int32  `json:"offset"`
}

type ListNodesByContentClassParams

type ListNodesByContentClassParams struct {
	ContentClass string `json:"content_class"`
	Limit        int32  `json:"limit"`
	Offset       int32  `json:"offset"`
}

type ListNodesByLevelParams

type ListNodesByLevelParams struct {
	Level  int16 `json:"level"`
	Limit  int32 `json:"limit"`
	Offset int32 `json:"offset"`
}

type ListNodesParams

type ListNodesParams struct {
	Limit  int32 `json:"limit"`
	Offset int32 `json:"offset"`
}

type Node

type Node struct {
	ID                    string          `json:"id"`
	Level                 int16           `json:"level"`
	ContentClass          string          `json:"content_class"`
	ContentType           string          `json:"content_type"`
	EncodingClass         string          `json:"encoding_class"`
	EncodingFormat        string          `json:"encoding_format"`
	ContentSha256         string          `json:"content_sha256"`
	ContentLen            int64           `json:"content_len"`
	ContentCached         sql.NullString  `json:"content_cached"`
	CreatedAt             time.Time       `json:"created_at"`
	ArtifactCreatedAt     sql.NullTime    `json:"artifact_created_at"`
	ArtifactCreatedAtBlur sql.NullString  `json:"artifact_created_at_blur"`
	Origin                sql.NullString  `json:"origin"`
	OriginalName          sql.NullString  `json:"original_name"`
	ValidFrom             sql.NullTime    `json:"valid_from"`
	ValidFromBlur         sql.NullString  `json:"valid_from_blur"`
	ValidUntil            sql.NullTime    `json:"valid_until"`
	ValidUntilBlur        sql.NullString  `json:"valid_until_blur"`
	Confidence            sql.NullFloat64 `json:"confidence"`
}

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) GetEdge

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

func (*Queries) GetEdgesByRun

func (q *Queries) GetEdgesByRun(ctx context.Context, runID sql.NullString) ([]Edge, error)

func (*Queries) GetEdgesBySource

func (q *Queries) GetEdgesBySource(ctx context.Context, sourceNodeID string) ([]Edge, error)

func (*Queries) GetEdgesBySourceAndType

func (q *Queries) GetEdgesBySourceAndType(ctx context.Context, arg GetEdgesBySourceAndTypeParams) ([]Edge, error)

func (*Queries) GetEdgesByTarget

func (q *Queries) GetEdgesByTarget(ctx context.Context, targetNodeID string) ([]Edge, error)

func (*Queries) GetEdgesByTargetAndType

func (q *Queries) GetEdgesByTargetAndType(ctx context.Context, arg GetEdgesByTargetAndTypeParams) ([]Edge, error)

func (*Queries) GetNode

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

func (*Queries) GetRun

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

func (*Queries) InsertEdge

func (q *Queries) InsertEdge(ctx context.Context, arg InsertEdgeParams) error

func (*Queries) InsertNode

func (q *Queries) InsertNode(ctx context.Context, arg InsertNodeParams) error

func (*Queries) InsertRun

func (q *Queries) InsertRun(ctx context.Context, arg InsertRunParams) error

func (*Queries) ListEdges

func (q *Queries) ListEdges(ctx context.Context, arg ListEdgesParams) ([]Edge, error)

func (*Queries) ListEdgesByType

func (q *Queries) ListEdgesByType(ctx context.Context, arg ListEdgesByTypeParams) ([]Edge, error)

func (*Queries) ListNodes

func (q *Queries) ListNodes(ctx context.Context, arg ListNodesParams) ([]Node, error)

func (*Queries) ListNodesByContentClass

func (q *Queries) ListNodesByContentClass(ctx context.Context, arg ListNodesByContentClassParams) ([]Node, error)

func (*Queries) ListNodesByContentClassAndType

func (q *Queries) ListNodesByContentClassAndType(ctx context.Context, arg ListNodesByContentClassAndTypeParams) ([]Node, error)

func (*Queries) ListNodesByLevel

func (q *Queries) ListNodesByLevel(ctx context.Context, arg ListNodesByLevelParams) ([]Node, error)

func (*Queries) NodeExistsBySha256

func (q *Queries) NodeExistsBySha256(ctx context.Context, contentSha256 string) (string, error)

func (*Queries) SearchNodesByContent

func (q *Queries) SearchNodesByContent(ctx context.Context, arg SearchNodesByContentParams) ([]Node, error)

func (*Queries) WithTx

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

type Run

type Run struct {
	ID             string    `json:"id"`
	WorkerConfigID string    `json:"worker_config_id"`
	CreatedAt      time.Time `json:"created_at"`
}

type SearchNodesByContentParams

type SearchNodesByContentParams struct {
	PlaintoTsquery string `json:"plainto_tsquery"`
	Limit          int32  `json:"limit"`
	Offset         int32  `json:"offset"`
}

Jump to

Keyboard shortcuts

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