Versions in this module Expand all Collapse all v1 v1.0.1 Mar 12, 2025 v1.0.0 Mar 11, 2025 Changes in this version + func RunMigration(databaseUrl string) + type CountUploadedFilesParams struct + Column1 *int64 + Column2 *int64 + Column3 *string + Column4 *string + Column5 *string + Column6 *string + type CreateSessionParams struct + ChunkSize int64 + FileName pgtype.Text + FileSize int64 + MaxChunk int64 + OwnerID pgtype.Text + Provider pgtype.Text + TempPath pgtype.Text + type CreateUploadedFileParams struct + Checksum pgtype.Text + Description pgtype.Text + FileName string + FilePath string + FileSize int64 + FileType pgtype.Text + Provider string + ProviderMetadata []byte + UploadedBy string + type CreateUserParams struct + Email string + Password string + type DBTX interface + Exec func(context.Context, string, ...interface{}) (pgconn.CommandTag, error) + Query func(context.Context, string, ...interface{}) (pgx.Rows, error) + QueryRow func(context.Context, string, ...interface{}) pgx.Row + type DecrementFileCountAndSizeAndMimetypeParams struct + FilesByMimetype []byte + ID uuid.UUID + TotalFileCount int64 + TotalFileSize int64 + type DeleteDocumentsByIdsRow struct + Checksum pgtype.Text + Description pgtype.Text + FileName string + FilePath string + FileSize int64 + FileType pgtype.Text + ID uuid.UUID + IsDeleted pgtype.Bool + Provider string + ProviderMetadata []byte + UploadedAt pgtype.Timestamp + UploadedBy string + type FilterUploadParams struct + Checksum *string + FileType *string + Limit *int32 + MaxFileSize *int64 + MinFileSize *int64 + Offset *int32 + Provider *string + UploadedBy *string + type FilterUploadResult struct + Files []UploadedFile + Meta Metadata + type FilterUploadedFilesParams struct + Column1 *int64 + Column2 *int64 + Column3 *string + Column4 *string + Column5 *string + Column6 *string + Limit *int32 + Offset *int32 + type FindDuplicateFileNamesRow struct + DuplicateCount int64 + FileName pgtype.Text + type FindDuplicateFilesByChecksumRow struct + Checksum pgtype.Text + DuplicateCount int64 + type GetMetricsByMimetypeParams struct + FilesByMimetype []byte + ID uuid.UUID + type IncrementFileCountAndSizeAndMimetypeParams struct + Column4 interface{} + ID uuid.UUID + TotalFileCount int64 + TotalFileSize int64 + type InsertMetricsParams struct + AverageFileSize pgtype.Numeric + FilesByMimetype []byte + LargestFileSize int64 + SmallestFileSize int64 + TotalDeletedFiles int64 + TotalFileCount int64 + TotalFileSize int64 + type ListSessionDetailsRow struct + CreatedAt pgtype.Timestamp + FileName pgtype.Text + ID pgtype.UUID + OwnerID pgtype.Text + Provider pgtype.Text + type Metadata struct + Page int32 + Size int32 + TotalCount int + TotalPage int + type Metric struct + AverageFileSize pgtype.Numeric + FilesByMimetype []byte + ID uuid.UUID + LargestFileSize int64 + LastUpdated pgtype.Timestamp + SmallestFileSize int64 + TotalDeletedFiles int64 + TotalFileCount int64 + TotalFileSize int64 + type PaginateSessionsParams struct + Limit int32 + Offset int32 + type PaginateUploadedFilesParams struct + Limit int32 + Offset int32 + type PaginateUsersParams struct + Limit int32 + Offset int32 + type Queries struct + func New(db DBTX) *Queries + func (db *Queries) GetFilteredUploads(params FilterUploadParams) (*FilterUploadResult, error) + func (q *Queries) AverageChunkSize(ctx context.Context) (float64, error) + func (q *Queries) CheckEmailExists(ctx context.Context, email string) (bool, error) + func (q *Queries) CountFilesByUser(ctx context.Context, uploadedBy string) (int64, error) + func (q *Queries) CountSessions(ctx context.Context) (int64, error) + func (q *Queries) CountTotalFiles(ctx context.Context) (int64, error) + func (q *Queries) CountTotalUsers(ctx context.Context) (int64, error) + func (q *Queries) CountUploadedFiles(ctx context.Context, arg CountUploadedFilesParams) (int64, error) + func (q *Queries) CountUsersAfterDate(ctx context.Context, createdAt pgtype.Timestamp) (int64, error) + func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) (Session, error) + func (q *Queries) CreateUploadedFile(ctx context.Context, arg CreateUploadedFileParams) (UploadedFile, error) + func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (User, error) + func (q *Queries) DecrementFileCountAndSizeAndMimetype(ctx context.Context, arg DecrementFileCountAndSizeAndMimetypeParams) error + func (q *Queries) DeleteDocumentsByIds(ctx context.Context, dollar_1 []uuid.UUID) ([]DeleteDocumentsByIdsRow, error) + func (q *Queries) DeleteMetrics(ctx context.Context, id uuid.UUID) error + func (q *Queries) DeleteSession(ctx context.Context, id pgtype.UUID) error + func (q *Queries) DeleteUserByID(ctx context.Context, id pgtype.UUID) error + func (q *Queries) FilterUploadedFiles(ctx context.Context, arg FilterUploadedFilesParams) ([]UploadedFile, error) + func (q *Queries) FindDuplicateFileNames(ctx context.Context) ([]FindDuplicateFileNamesRow, error) + func (q *Queries) FindDuplicateFilesByChecksum(ctx context.Context) ([]FindDuplicateFilesByChecksumRow, error) + func (q *Queries) FindFilesAfterDate(ctx context.Context, uploadedAt pgtype.Timestamp) ([]UploadedFile, error) + func (q *Queries) FindFilesByMetadataKey(ctx context.Context, providerMetadata []byte) ([]UploadedFile, error) + func (q *Queries) FindFilesByProvider(ctx context.Context, provider string) ([]UploadedFile, error) + func (q *Queries) FindFilesByUser(ctx context.Context, uploadedBy string) ([]UploadedFile, error) + func (q *Queries) FindLargeSessions(ctx context.Context, fileSize int64) ([]Session, error) + func (q *Queries) FindMissingTempPaths(ctx context.Context) ([]Session, error) + func (q *Queries) FindSessionById(ctx context.Context, id pgtype.UUID) (Session, error) + func (q *Queries) FindSessionsAfterDate(ctx context.Context, createdAt pgtype.Timestamp) ([]Session, error) + func (q *Queries) FindSessionsByDate(ctx context.Context, createdAt pgtype.Timestamp) ([]Session, error) + func (q *Queries) FindSessionsByOwner(ctx context.Context, ownerID pgtype.Text) ([]Session, error) + func (q *Queries) FindSessionsByOwnerIndexed(ctx context.Context, ownerID pgtype.Text) ([]Session, error) + func (q *Queries) FindSessionsByOwners(ctx context.Context, ownerID pgtype.Text) ([]Session, error) + func (q *Queries) FindUsersAfterDate(ctx context.Context, createdAt pgtype.Timestamp) ([]User, error) + func (q *Queries) GetFirstCreatedMetrics(ctx context.Context) (Metric, error) + func (q *Queries) GetInactiveUsers(ctx context.Context, lastLogin pgtype.Timestamp) ([]User, error) + func (q *Queries) GetLargestFile(ctx context.Context) (UploadedFile, error) + func (q *Queries) GetMetrics(ctx context.Context, id uuid.UUID) (Metric, error) + func (q *Queries) GetMetricsByMimetype(ctx context.Context, arg GetMetricsByMimetypeParams) (interface{}, error) + func (q *Queries) GetRecentUsers(ctx context.Context, limit int32) ([]User, error) + func (q *Queries) GetUploadedFileByID(ctx context.Context, id uuid.UUID) (UploadedFile, error) + func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error) + func (q *Queries) GetUserByID(ctx context.Context, id pgtype.UUID) (User, error) + func (q *Queries) HardDeleteUploadedFile(ctx context.Context, id uuid.UUID) error + func (q *Queries) IncrementFileCountAndSizeAndMimetype(ctx context.Context, arg IncrementFileCountAndSizeAndMimetypeParams) error + func (q *Queries) InsertMetrics(ctx context.Context, arg InsertMetricsParams) (Metric, error) + func (q *Queries) ListActiveFiles(ctx context.Context) ([]UploadedFile, error) + func (q *Queries) ListDeletedFiles(ctx context.Context) ([]UploadedFile, error) + func (q *Queries) ListSessionDetails(ctx context.Context) ([]ListSessionDetailsRow, error) + func (q *Queries) ListSessions(ctx context.Context) ([]Session, error) + func (q *Queries) ListUploadedFiles(ctx context.Context) ([]UploadedFile, error) + func (q *Queries) ListUploadedFilesByIds(ctx context.Context, dollar_1 []uuid.UUID) ([]UploadedFile, error) + func (q *Queries) ListUsers(ctx context.Context) ([]User, error) + func (q *Queries) PaginateSessions(ctx context.Context, arg PaginateSessionsParams) ([]Session, error) + func (q *Queries) PaginateUploadedFiles(ctx context.Context, arg PaginateUploadedFilesParams) ([]UploadedFile, error) + func (q *Queries) PaginateUsers(ctx context.Context, arg PaginateUsersParams) ([]User, error) + func (q *Queries) SearchProviderMetadata(ctx context.Context, providerMetadata []byte) ([]UploadedFile, error) + func (q *Queries) SoftDeleteUploadedFile(ctx context.Context, id uuid.UUID) error + func (q *Queries) TotalFileSize(ctx context.Context) (int64, error) + func (q *Queries) TotalUploadFileSize(ctx context.Context) (int64, error) + func (q *Queries) UpdateAllMetrics(ctx context.Context, arg UpdateAllMetricsParams) error + func (q *Queries) UpdateAverageFileSize(ctx context.Context, arg UpdateAverageFileSizeParams) error + func (q *Queries) UpdateFileSizeAndCount(ctx context.Context, arg UpdateFileSizeAndCountParams) error + func (q *Queries) UpdateFileSizes(ctx context.Context, arg UpdateFileSizesParams) error + func (q *Queries) UpdateFilesByMimetype(ctx context.Context, arg UpdateFilesByMimetypeParams) error + func (q *Queries) UpdateLastLogin(ctx context.Context, id pgtype.UUID) error + func (q *Queries) UpdateSession(ctx context.Context, arg UpdateSessionParams) error + func (q *Queries) UpdateTotalDeletedFiles(ctx context.Context, arg UpdateTotalDeletedFilesParams) error + func (q *Queries) UpdateUploadedFileMetadata(ctx context.Context, arg UpdateUploadedFileMetadataParams) error + func (q *Queries) WithTx(tx pgx.Tx) *Queries + type Session struct + ChunkSize int64 + CreatedAt pgtype.Timestamp + CurrentChunk pgtype.Int8 + FileName pgtype.Text + FileSize int64 + ID pgtype.UUID + MaxChunk int64 + OwnerID pgtype.Text + Provider pgtype.Text + TempPath pgtype.Text + type UpdateAllMetricsParams struct + AverageFileSize pgtype.Numeric + FilesByMimetype []byte + ID uuid.UUID + LargestFileSize int64 + SmallestFileSize int64 + TotalDeletedFiles int64 + TotalFileCount int64 + TotalFileSize int64 + type UpdateAverageFileSizeParams struct + AverageFileSize pgtype.Numeric + ID uuid.UUID + type UpdateFileSizeAndCountParams struct + ID uuid.UUID + TotalFileCount int64 + TotalFileSize int64 + type UpdateFileSizesParams struct + ID uuid.UUID + LargestFileSize int64 + SmallestFileSize int64 + type UpdateFilesByMimetypeParams struct + FilesByMimetype []byte + ID uuid.UUID + type UpdateSessionParams struct + CurrentChunk pgtype.Int8 + FileName pgtype.Text + ID pgtype.UUID + Provider pgtype.Text + TempPath pgtype.Text + type UpdateTotalDeletedFilesParams struct + ID uuid.UUID + TotalDeletedFiles int64 + type UpdateUploadedFileMetadataParams struct + Description pgtype.Text + ID uuid.UUID + ProviderMetadata []byte + type UploadedFile struct + Checksum pgtype.Text + Description pgtype.Text + FileName string + FilePath string + FileSize int64 + FileType pgtype.Text + ID uuid.UUID + IsDeleted pgtype.Bool + Provider string + ProviderMetadata []byte + UploadedAt pgtype.Timestamp + UploadedBy string + type User struct + CreatedAt pgtype.Timestamp + Email string + ID pgtype.UUID + LastLogin pgtype.Timestamp + Password string
Go to main page