postgres

package

v0.0.0-...-ebb3a86 Latest Latest Go to latest Published: Apr 23, 2025 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var ErrNotFound = errors.New("not found")

This section is empty.

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

func NewDB(logger *slog.Logger, pool *pgxpool.Pool) *DB

func (db *DB) ApplyStatusReports(ctx context.Context, reports []instance.StatusReport) error

ApplyStatusReports updates instances rows that are not in instance.StateDeleted state. all other instances will be removed from the table.

func (db *DB) BulkGetBlobs(ctx context.Context, hashes []string) ([]blob.Object, error)

func (db *DB) BulkWriteBlobs(ctx context.Context, objects []blob.Object) error

func (db *DB) ChunkExists(ctx context.Context, id string) (bool, error)

func (db *DB) CreateChunk(ctx context.Context, c chunk.Chunk) (chunk.Chunk, error)

func (db *DB) CreateFlavor(ctx context.Context, chunkID string, flavor chunk.Flavor) (chunk.Flavor, error)

func (db *DB) CreateFlavorVersion(
	ctx context.Context,
	version chunk.FlavorVersion,
	prevVersionID string,
) (chunk.FlavorVersion, error)

func (db *DB) CreateInstance(ctx context.Context, ins instance.Instance, nodeID string) (instance.Instance, error)

func (db *DB) FlavorNameExists(ctx context.Context, chunkID string, name string) (bool, error)

func (db *DB) FlavorVersionByHash(ctx context.Context, hash string) (string, error)

func (db *DB) FlavorVersionByID(ctx context.Context, id string) (chunk.FlavorVersion, error)

func (db *DB) FlavorVersionExists(ctx context.Context, flavorID string, version string) (bool, error)

func (db *DB) FlavorVersionHashByID(ctx context.Context, id string) (string, error)

func (db *DB) GetChunkByID(ctx context.Context, id string) (chunk.Chunk, error)

func (db *DB) GetInstanceByID(ctx context.Context, id string) (instance.Instance, error)

func (db *DB) GetInstancesByNodeID(ctx context.Context, nodeID string) ([]instance.Instance, error)

func (db *DB) LatestFlavorVersion(ctx context.Context, flavorID string) (chunk.FlavorVersion, error)

func (db *DB) ListChunks(ctx context.Context) ([]chunk.Chunk, error)

func (db *DB) ListFlavorsByChunkID(ctx context.Context, chunkID string) ([]chunk.Flavor, error)

func (db *DB) ListInstances(ctx context.Context) ([]instance.Instance, error)

func (db *DB) MarkFlavorVersionFilesUploaded(ctx context.Context, flavorVersionID string) error

func (db *DB) UpdateChunk(ctx context.Context, c chunk.Chunk) (chunk.Chunk, error)

Path	Synopsis
migrations
query