query

package
v0.0.0-...-ebb3a86 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2025 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrBatchAlreadyClosed = errors.New("batch already closed")
)

Functions

This section is empty.

Types

type Blob

type Blob struct {
	Hash      string
	Data      []byte
	CreatedAt time.Time
}

type BulkDeleteInstancesBatchResults

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

func (*BulkDeleteInstancesBatchResults) Close

func (*BulkDeleteInstancesBatchResults) Exec

func (b *BulkDeleteInstancesBatchResults) Exec(f func(int, error))

type BulkGetBlobDataBatchResults

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

func (*BulkGetBlobDataBatchResults) Close

func (*BulkGetBlobDataBatchResults) Query

func (b *BulkGetBlobDataBatchResults) Query(f func(int, []Blob, error))

type BulkInsertBlobDataBatchResults

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

func (*BulkInsertBlobDataBatchResults) Close

func (*BulkInsertBlobDataBatchResults) Exec

func (b *BulkInsertBlobDataBatchResults) Exec(f func(int, error))

type BulkInsertBlobDataParams

type BulkInsertBlobDataParams struct {
	Hash string
	Data []byte
}

type BulkInsertFlavorFileHashesBatchResults

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

func (*BulkInsertFlavorFileHashesBatchResults) Close

func (*BulkInsertFlavorFileHashesBatchResults) Exec

type BulkInsertFlavorFileHashesParams

type BulkInsertFlavorFileHashesParams struct {
	FlavorVersionID string
	FileHash        pgtype.Text
	FilePath        string
}

type BulkUpdateInstanceStateAndPortBatchResults

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

func (*BulkUpdateInstanceStateAndPortBatchResults) Close

func (*BulkUpdateInstanceStateAndPortBatchResults) Exec

type BulkUpdateInstanceStateAndPortParams

type BulkUpdateInstanceStateAndPortParams struct {
	State InstanceState
	Port  *int32
}

type Chunk

type Chunk struct {
	ID          string
	Name        string
	Description string
	Tags        []string
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type CreateChunkParams

type CreateChunkParams struct {
	ID          string
	Name        string
	Description string
	Tags        []string
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type CreateFlavorParams

type CreateFlavorParams struct {
	ID        string
	ChunkID   string
	Name      string
	CreatedAt time.Time
	UpdatedAt time.Time
}

type CreateFlavorVersionParams

type CreateFlavorVersionParams struct {
	ID            string
	FlavorID      string
	Hash          string
	ChangeHash    string
	Version       string
	PrevVersionID *string
	CreatedAt     time.Time
}

type CreateInstanceParams

type CreateInstanceParams struct {
	ID        string
	ChunkID   string
	FlavorID  string
	NodeID    string
	State     InstanceState
	CreatedAt time.Time
	UpdatedAt time.Time
}

type DBTX

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	SendBatch(context.Context, *pgx.Batch) pgx.BatchResults
}

type Flavor

type Flavor struct {
	ID        string
	ChunkID   string
	Name      string
	CreatedAt time.Time
	UpdatedAt time.Time
}

type FlavorNameExistsParams

type FlavorNameExistsParams struct {
	Name    string
	ChunkID string
}

type FlavorVersion

type FlavorVersion struct {
	ID            string
	FlavorID      string
	Hash          string
	ChangeHash    string
	Version       string
	FilesUploaded bool
	PrevVersionID *string
	CreatedAt     time.Time
}

type FlavorVersionByIDRow

type FlavorVersionByIDRow struct {
	ID              string
	FlavorID        string
	Hash            string
	ChangeHash      string
	Version         string
	FilesUploaded   bool
	PrevVersionID   *string
	CreatedAt       time.Time
	FlavorVersionID string
	FileHash        pgtype.Text
	FilePath        string
	CreatedAt_2     time.Time
}

type FlavorVersionExistsParams

type FlavorVersionExistsParams struct {
	Version  string
	FlavorID string
}

type FlavorVersionFile

type FlavorVersionFile struct {
	FlavorVersionID string
	FileHash        pgtype.Text
	FilePath        string
	CreatedAt       time.Time
}

type GetChunkByIDRow

type GetChunkByIDRow struct {
	ID          string
	Name        string
	Description string
	Tags        []string
	CreatedAt   time.Time
	UpdatedAt   time.Time
	ID_2        string
	ChunkID     string
	Name_2      string
	CreatedAt_2 time.Time
	UpdatedAt_2 time.Time
}

type GetInstanceRow

type GetInstanceRow struct {
	ID          string
	ChunkID     string
	FlavorID    string
	NodeID      string
	Port        *int32
	State       InstanceState
	CreatedAt   time.Time
	UpdatedAt   time.Time
	ID_2        string
	ChunkID_2   string
	Name        string
	CreatedAt_2 time.Time
	UpdatedAt_2 time.Time
	ID_3        string
	Name_2      string
	Description string
	Tags        []string
	CreatedAt_3 time.Time
	UpdatedAt_3 time.Time
	ID_4        string
	Address     netip.Addr
	CreatedAt_4 time.Time
}

type GetInstancesByNodeIDRow

type GetInstancesByNodeIDRow struct {
	ID          string
	ChunkID     string
	FlavorID    string
	NodeID      string
	Port        *int32
	State       InstanceState
	CreatedAt   time.Time
	UpdatedAt   time.Time
	ID_2        string
	ChunkID_2   string
	Name        string
	CreatedAt_2 time.Time
	UpdatedAt_2 time.Time
	ID_3        string
	Name_2      string
	Description string
	Tags        []string
	CreatedAt_3 time.Time
	UpdatedAt_3 time.Time
	ID_4        string
	Address     netip.Addr
	CreatedAt_4 time.Time
}

type Instance

type Instance struct {
	ID        string
	ChunkID   string
	FlavorID  string
	NodeID    string
	Port      *int32
	State     InstanceState
	CreatedAt time.Time
	UpdatedAt time.Time
}

type InstanceState

type InstanceState string
const (
	InstanceStatePENDING        InstanceState = "PENDING"
	InstanceStateCREATING       InstanceState = "CREATING"
	InstanceStateRUNNING        InstanceState = "RUNNING"
	InstanceStateDELETING       InstanceState = "DELETING"
	InstanceStateDELETED        InstanceState = "DELETED"
	InstanceStateCREATIONFAILED InstanceState = "CREATION_FAILED"
)

func (*InstanceState) Scan

func (e *InstanceState) Scan(src interface{}) error

type ListChunksRow

type ListChunksRow struct {
	ID          string
	Name        string
	Description string
	Tags        []string
	CreatedAt   time.Time
	UpdatedAt   time.Time
	ID_2        string
	ChunkID     string
	Name_2      string
	CreatedAt_2 time.Time
	UpdatedAt_2 time.Time
}

type ListInstancesRow

type ListInstancesRow struct {
	ID          string
	ChunkID     string
	FlavorID    string
	NodeID      string
	Port        *int32
	State       InstanceState
	CreatedAt   time.Time
	UpdatedAt   time.Time
	ID_2        string
	ChunkID_2   string
	Name        string
	CreatedAt_2 time.Time
	UpdatedAt_2 time.Time
	ID_3        string
	Name_2      string
	Description string
	Tags        []string
	CreatedAt_3 time.Time
	UpdatedAt_3 time.Time
	ID_4        string
	Address     netip.Addr
	CreatedAt_4 time.Time
}

type Node

type Node struct {
	ID        string
	Address   netip.Addr
	CreatedAt time.Time
}

type NullInstanceState

type NullInstanceState struct {
	InstanceState InstanceState
	Valid         bool // Valid is true if InstanceState is not NULL
}

func (*NullInstanceState) Scan

func (ns *NullInstanceState) Scan(value interface{}) error

Scan implements the Scanner interface.

func (NullInstanceState) Value

func (ns NullInstanceState) Value() (driver.Value, error)

Value implements the driver Valuer interface.

type Queries

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

func New

func New(db DBTX) *Queries

func (*Queries) BulkDeleteInstances

func (q *Queries) BulkDeleteInstances(ctx context.Context, id []string) *BulkDeleteInstancesBatchResults

func (*Queries) BulkGetBlobData

func (q *Queries) BulkGetBlobData(ctx context.Context, hash []string) *BulkGetBlobDataBatchResults

func (*Queries) BulkInsertBlobData

func (*Queries) ChunkExists

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

func (*Queries) CreateChunk

func (q *Queries) CreateChunk(ctx context.Context, arg CreateChunkParams) error

func (*Queries) CreateFlavor

func (q *Queries) CreateFlavor(ctx context.Context, arg CreateFlavorParams) error

TODO: insert multiple (aka :batchmany)

func (*Queries) CreateFlavorVersion

func (q *Queries) CreateFlavorVersion(ctx context.Context, arg CreateFlavorVersionParams) error

func (*Queries) CreateInstance

func (q *Queries) CreateInstance(ctx context.Context, arg CreateInstanceParams) error

func (*Queries) FlavorNameExists

func (q *Queries) FlavorNameExists(ctx context.Context, arg FlavorNameExistsParams) (bool, error)

func (*Queries) FlavorVersionByHash

func (q *Queries) FlavorVersionByHash(ctx context.Context, hash string) (string, error)

func (*Queries) FlavorVersionByID

func (q *Queries) FlavorVersionByID(ctx context.Context, id string) ([]FlavorVersionByIDRow, error)

func (*Queries) FlavorVersionExists

func (q *Queries) FlavorVersionExists(ctx context.Context, arg FlavorVersionExistsParams) (bool, error)

func (*Queries) FlavorVersionFileHashes

func (q *Queries) FlavorVersionFileHashes(ctx context.Context, flavorVersionID string) ([]FlavorVersionFile, error)

func (*Queries) FlavorVersionHashByID

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

func (*Queries) GetChunkByID

func (q *Queries) GetChunkByID(ctx context.Context, id string) ([]GetChunkByIDRow, error)

TODO: read multiple

func (*Queries) GetInstance

func (q *Queries) GetInstance(ctx context.Context, id string) ([]GetInstanceRow, error)

func (*Queries) GetInstancesByNodeID

func (q *Queries) GetInstancesByNodeID(ctx context.Context, nodeID string) ([]GetInstancesByNodeIDRow, error)

func (*Queries) LatestFlavorVersionByFlavorID

func (q *Queries) LatestFlavorVersionByFlavorID(ctx context.Context, flavorID string) (FlavorVersion, error)

func (*Queries) ListChunks

func (q *Queries) ListChunks(ctx context.Context) ([]ListChunksRow, error)

func (*Queries) ListFlavorsByChunkID

func (q *Queries) ListFlavorsByChunkID(ctx context.Context, chunkID string) ([]Flavor, error)

func (*Queries) ListInstances

func (q *Queries) ListInstances(ctx context.Context) ([]ListInstancesRow, error)

func (*Queries) MarkFlavorVersionFilesUploaded

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

func (*Queries) UpdateChunk

func (q *Queries) UpdateChunk(ctx context.Context, arg UpdateChunkParams) error

func (*Queries) WithTx

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

type SchemaMigration

type SchemaMigration struct {
	Version string
}

type UpdateChunkParams

type UpdateChunkParams struct {
	Name        string
	Description string
	Tags        []string
	ID          string
}

Jump to

Keyboard shortcuts

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