infrastructure

package

v0.0.0-...-4d6988e Latest Latest Go to latest Published: Jan 16, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func GetStats() map[string]interface{}

func InitializePostgresShards(connections []string) error

func ResolveShard(userID string, shardCount int) int

type PostgresStorage struct {
	Db *sql.DB
}

func GetPostgresForUser(userID string) *PostgresStorage

func (p *PostgresStorage) Connect(connectionString string) error

Connect establishes connection to PostgreSQL

func (p *PostgresStorage) DecrementUserFileStats(userID string) error

func (p *PostgresStorage) DeleteAllFilesForUser(userID string) int

func (p *PostgresStorage) DeleteFileMetadata(fileID, userID string) bool

func (p *PostgresStorage) DeleteUserFileStats(userID string) error

func (p *PostgresStorage) GetFileMetadata(fileID string) (models.FileMetadata, bool)

func (p *PostgresStorage) GetUserFileCount(userID string) (int64, error)

GetUserFileCount counts total files for a user

func (p *PostgresStorage) GetUserFileMetadata(userID string) []models.FileMetadata

func (p *PostgresStorage) GetUserFileMetadataPage(userID string, limit, offset int) ([]models.FileMetadata, error)

GetUserFileMetadataPage returns a page of files for a user

func (p *PostgresStorage) GetUserFileStats(userID string) (int, error)

func (p *PostgresStorage) IncrementUserFileStats(userID string) error

func (p *PostgresStorage) SaveFileMetadata(metadata models.FileMetadata) error

func (p *PostgresStorage) UpdateFileScanStatus(
	fileID, status string,
	scannedAt time.Time,
) error

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

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