Documentation
¶
Index ¶
- func RunMigration(databaseUrl string)
- type CountUploadedFilesParams
- type CreateSessionParams
- type CreateUploadedFileParams
- type CreateUserParams
- type DBTX
- type DecrementFileCountAndSizeAndMimetypeParams
- type DeleteDocumentsByIdsRow
- type FilterUploadParams
- type FilterUploadResult
- type FilterUploadedFilesParams
- type FindDuplicateFileNamesRow
- type FindDuplicateFilesByChecksumRow
- type GetMetricsByMimetypeParams
- type IncrementFileCountAndSizeAndMimetypeParams
- type InsertMetricsParams
- type ListSessionDetailsRow
- type Metadata
- type Metric
- type PaginateSessionsParams
- type PaginateUploadedFilesParams
- type PaginateUsersParams
- type Queries
- 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 (db *Queries) GetFilteredUploads(params FilterUploadParams) (*FilterUploadResult, 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
- type UpdateAllMetricsParams
- type UpdateAverageFileSizeParams
- type UpdateFileSizeAndCountParams
- type UpdateFileSizesParams
- type UpdateFilesByMimetypeParams
- type UpdateSessionParams
- type UpdateTotalDeletedFilesParams
- type UpdateUploadedFileMetadataParams
- type UploadedFile
- type User
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunMigration ¶
func RunMigration(databaseUrl string)
Types ¶
type CreateSessionParams ¶
type CreateUserParams ¶
type DeleteDocumentsByIdsRow ¶
type FilterUploadParams ¶
type FilterUploadResult ¶
type FilterUploadResult struct {
Files []UploadedFile
Meta Metadata
}
type InsertMetricsParams ¶
type ListSessionDetailsRow ¶
type PaginateSessionsParams ¶
type PaginateUsersParams ¶
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AverageChunkSize ¶
func (*Queries) CheckEmailExists ¶
func (*Queries) CountFilesByUser ¶
func (*Queries) CountTotalFiles ¶
func (*Queries) CountTotalUsers ¶
func (*Queries) CountUploadedFiles ¶
func (q *Queries) CountUploadedFiles(ctx context.Context, arg CountUploadedFilesParams) (int64, error)
Number of rows to skip
func (*Queries) CountUsersAfterDate ¶
func (*Queries) CreateSession ¶
func (*Queries) CreateUploadedFile ¶
func (q *Queries) CreateUploadedFile(ctx context.Context, arg CreateUploadedFileParams) (UploadedFile, error)
func (*Queries) CreateUser ¶
func (*Queries) DecrementFileCountAndSizeAndMimetype ¶
func (q *Queries) DecrementFileCountAndSizeAndMimetype(ctx context.Context, arg DecrementFileCountAndSizeAndMimetypeParams) error
func (*Queries) DeleteDocumentsByIds ¶
func (q *Queries) DeleteDocumentsByIds(ctx context.Context, dollar_1 []uuid.UUID) ([]DeleteDocumentsByIdsRow, error)
Use ANY to match an array of IDs
func (*Queries) DeleteMetrics ¶
func (*Queries) DeleteSession ¶
func (*Queries) DeleteUserByID ¶
func (*Queries) FilterUploadedFiles ¶
func (q *Queries) FilterUploadedFiles(ctx context.Context, arg FilterUploadedFilesParams) ([]UploadedFile, error)
func (*Queries) FindDuplicateFileNames ¶
func (q *Queries) FindDuplicateFileNames(ctx context.Context) ([]FindDuplicateFileNamesRow, error)
func (*Queries) FindDuplicateFilesByChecksum ¶
func (q *Queries) FindDuplicateFilesByChecksum(ctx context.Context) ([]FindDuplicateFilesByChecksumRow, error)
func (*Queries) FindFilesAfterDate ¶
func (*Queries) FindFilesByMetadataKey ¶
func (*Queries) FindFilesByProvider ¶
func (*Queries) FindFilesByUser ¶
func (*Queries) FindLargeSessions ¶
func (*Queries) FindMissingTempPaths ¶
func (*Queries) FindSessionById ¶
func (*Queries) FindSessionsAfterDate ¶
func (*Queries) FindSessionsByDate ¶
func (q *Queries) FindSessionsByDate(ctx context.Context, createdAt pgtype.Timestamp) ([]Session, error)
Adjusted to work with PostgreSQL arrays
func (*Queries) FindSessionsByOwner ¶
func (*Queries) FindSessionsByOwnerIndexed ¶
func (*Queries) FindSessionsByOwners ¶
func (*Queries) FindUsersAfterDate ¶
func (*Queries) GetFilteredUploads ¶
func (db *Queries) GetFilteredUploads(params FilterUploadParams) (*FilterUploadResult, error)
func (*Queries) GetFirstCreatedMetrics ¶
func (*Queries) GetInactiveUsers ¶
func (*Queries) GetLargestFile ¶
func (q *Queries) GetLargestFile(ctx context.Context) (UploadedFile, error)
func (*Queries) GetMetrics ¶
func (*Queries) GetMetricsByMimetype ¶
func (q *Queries) GetMetricsByMimetype(ctx context.Context, arg GetMetricsByMimetypeParams) (interface{}, error)
func (*Queries) GetRecentUsers ¶
func (*Queries) GetUploadedFileByID ¶
func (*Queries) GetUserByEmail ¶
func (*Queries) GetUserByID ¶
func (*Queries) HardDeleteUploadedFile ¶
func (*Queries) IncrementFileCountAndSizeAndMimetype ¶
func (q *Queries) IncrementFileCountAndSizeAndMimetype(ctx context.Context, arg IncrementFileCountAndSizeAndMimetypeParams) error
func (*Queries) InsertMetrics ¶
func (*Queries) ListActiveFiles ¶
func (q *Queries) ListActiveFiles(ctx context.Context) ([]UploadedFile, error)
func (*Queries) ListDeletedFiles ¶
func (q *Queries) ListDeletedFiles(ctx context.Context) ([]UploadedFile, error)
func (*Queries) ListSessionDetails ¶
func (q *Queries) ListSessionDetails(ctx context.Context) ([]ListSessionDetailsRow, error)
func (*Queries) ListSessions ¶
func (*Queries) ListUploadedFiles ¶
func (q *Queries) ListUploadedFiles(ctx context.Context) ([]UploadedFile, error)
func (*Queries) ListUploadedFilesByIds ¶
func (*Queries) PaginateSessions ¶
func (*Queries) PaginateUploadedFiles ¶
func (q *Queries) PaginateUploadedFiles(ctx context.Context, arg PaginateUploadedFilesParams) ([]UploadedFile, error)
func (*Queries) PaginateUsers ¶
func (*Queries) SearchProviderMetadata ¶
func (*Queries) SoftDeleteUploadedFile ¶
func (*Queries) TotalUploadFileSize ¶
func (*Queries) UpdateAllMetrics ¶
func (q *Queries) UpdateAllMetrics(ctx context.Context, arg UpdateAllMetricsParams) error
func (*Queries) UpdateAverageFileSize ¶
func (q *Queries) UpdateAverageFileSize(ctx context.Context, arg UpdateAverageFileSizeParams) error
func (*Queries) UpdateFileSizeAndCount ¶
func (q *Queries) UpdateFileSizeAndCount(ctx context.Context, arg UpdateFileSizeAndCountParams) error
func (*Queries) UpdateFileSizes ¶
func (q *Queries) UpdateFileSizes(ctx context.Context, arg UpdateFileSizesParams) error
func (*Queries) UpdateFilesByMimetype ¶
func (q *Queries) UpdateFilesByMimetype(ctx context.Context, arg UpdateFilesByMimetypeParams) error
func (*Queries) UpdateLastLogin ¶
func (*Queries) UpdateSession ¶
func (q *Queries) UpdateSession(ctx context.Context, arg UpdateSessionParams) error
func (*Queries) UpdateTotalDeletedFiles ¶
func (q *Queries) UpdateTotalDeletedFiles(ctx context.Context, arg UpdateTotalDeletedFilesParams) error
func (*Queries) UpdateUploadedFileMetadata ¶
func (q *Queries) UpdateUploadedFileMetadata(ctx context.Context, arg UpdateUploadedFileMetadataParams) error
type UpdateAllMetricsParams ¶
type UpdateFileSizesParams ¶
type UpdateSessionParams ¶
type UploadedFile ¶
Click to show internal directories.
Click to hide internal directories.