database

package
v1.3.4 Latest Latest
Warning

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

Go to latest
Published: Feb 9, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetAccessorForTests

func GetAccessorForTests() *sql.DB

func IsPurpose

func IsPurpose(purpose Purpose) bool

func IsSynStatUserOrderBy

func IsSynStatUserOrderBy(orderBy SynStatUserOrderBy) bool

func Reload

func Reload()

Types

type AnonymousJson

type AnonymousJson map[string]interface{}

func (*AnonymousJson) ApplyFrom

func (a *AnonymousJson) ApplyFrom(val interface{}) error

func (*AnonymousJson) ApplyTo

func (a *AnonymousJson) ApplyTo(val interface{}) error

func (*AnonymousJson) Scan

func (a *AnonymousJson) Scan(value interface{}) error

Scan implements sql.Scanner

func (*AnonymousJson) Value

func (a *AnonymousJson) Value() (driver.Value, error)

Value implements driver.Valuer

type Database

type Database struct {
	Media           *mediaTableStatements
	ExpiringMedia   *expiringMediaTableStatements
	UserStats       *userStatsTableStatements
	ReservedMedia   *reservedMediaTableStatements
	MetadataView    *metadataVirtualTableStatements
	HeldMedia       *heldMediaTableStatements
	Thumbnails      *thumbnailsTableStatements
	LastAccess      *lastAccessTableStatements
	UrlPreviews     *urlPreviewsTableStatements
	MediaAttributes *mediaAttributesTableStatements
	Tasks           *tasksTableStatements
	Exports         *exportsTableStatements
	ExportParts     *exportPartsTableStatements
	// contains filtered or unexported fields
}

func GetInstance

func GetInstance() *Database

type DbExpiringMedia

type DbExpiringMedia struct {
	Origin    string
	MediaId   string
	UserId    string
	ExpiresTs int64
}

func (*DbExpiringMedia) IsExpired

func (r *DbExpiringMedia) IsExpired() bool

type DbExportPart

type DbExportPart struct {
	ExportId    string
	PartNum     int
	SizeBytes   int64
	FileName    string
	DatastoreId string
	Location    string
}

type DbHeldMedia

type DbHeldMedia struct {
	Origin  string
	MediaId string
	Reason  string
}

type DbLastAccess

type DbLastAccess struct {
	Sha256Hash   string
	LastAccessTs int64
}

type DbMedia

type DbMedia struct {
	*Locatable
	Origin      string
	MediaId     string
	UploadName  string
	ContentType string
	UserId      string
	//Sha256Hash  string
	SizeBytes   int64
	CreationTs  int64
	Quarantined bool
}

type DbMediaAttributes

type DbMediaAttributes struct {
	Origin  string
	MediaId string
	Purpose Purpose
}

type DbMethod

type DbMethod string

type DbReservedMedia

type DbReservedMedia struct {
	Origin  string
	MediaId string
	Reason  string
}

type DbSynUserStat

type DbSynUserStat struct {
	UserId      string
	MediaCount  int64
	MediaLength int64
}

type DbTask

type DbTask struct {
	TaskId  int
	Name    string
	Params  *AnonymousJson
	StartTs int64
	EndTs   int64
	Error   string
}

type DbThumbnail

type DbThumbnail struct {
	*Locatable
	Origin      string
	MediaId     string
	ContentType string
	Width       int
	Height      int
	Method      string
	Animated    bool
	//Sha256Hash  string
	SizeBytes  int64
	CreationTs int64
}

type DbUrlPreview

type DbUrlPreview struct {
	Url            string
	ErrorCode      string
	BucketTs       int64
	SiteUrl        string
	SiteName       string
	ResourceType   string
	Description    string
	Title          string
	ImageMxc       string
	ImageType      string
	ImageSize      int64
	ImageWidth     int
	ImageHeight    int
	LanguageHeader string
}

type DbUserStats

type DbUserStats struct {
	UserId        string
	UploadedBytes int64
}

type HeldReason

type HeldReason string
const (
	ForCreateHeldReason HeldReason = "media_create"
)

type Locatable

type Locatable struct {
	Sha256Hash  string
	DatastoreId string
	Location    string
}

type MediaTableWithContext

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

func (*MediaTableWithContext) ByUserCount

func (s *MediaTableWithContext) ByUserCount(userId string) (int64, error)

func (*MediaTableWithContext) Delete

func (s *MediaTableWithContext) Delete(origin string, mediaId string) error

func (*MediaTableWithContext) GetByHash

func (s *MediaTableWithContext) GetByHash(sha256hash string) ([]*DbMedia, error)

func (*MediaTableWithContext) GetById

func (s *MediaTableWithContext) GetById(origin string, mediaId string) (*DbMedia, error)

func (*MediaTableWithContext) GetByIds

func (s *MediaTableWithContext) GetByIds(origin string, mediaIds []string) ([]*DbMedia, error)

func (*MediaTableWithContext) GetByLocation

func (s *MediaTableWithContext) GetByLocation(datastoreId string, location string) ([]*DbMedia, error)

func (*MediaTableWithContext) GetByOrigin

func (s *MediaTableWithContext) GetByOrigin(origin string) ([]*DbMedia, error)

func (*MediaTableWithContext) GetByOriginQuarantine

func (s *MediaTableWithContext) GetByOriginQuarantine(origin string) ([]*DbMedia, error)

func (*MediaTableWithContext) GetByOriginUsers

func (s *MediaTableWithContext) GetByOriginUsers(origin string, userIds []string) ([]*DbMedia, error)

func (*MediaTableWithContext) GetByQuarantine

func (s *MediaTableWithContext) GetByQuarantine() ([]*DbMedia, error)

func (*MediaTableWithContext) GetByUserId

func (s *MediaTableWithContext) GetByUserId(userId string) ([]*DbMedia, error)

func (*MediaTableWithContext) GetDistinctDatastoreIds

func (s *MediaTableWithContext) GetDistinctDatastoreIds() ([]string, error)

func (*MediaTableWithContext) GetOldByOrigin

func (s *MediaTableWithContext) GetOldByOrigin(origin string, beforeTs int64) ([]*DbMedia, error)

func (*MediaTableWithContext) GetOldByUserId

func (s *MediaTableWithContext) GetOldByUserId(userId string, beforeTs int64) ([]*DbMedia, error)

func (*MediaTableWithContext) GetOldExcluding

func (s *MediaTableWithContext) GetOldExcluding(origins []string, beforeTs int64) ([]*DbMedia, error)

func (*MediaTableWithContext) IdExists

func (s *MediaTableWithContext) IdExists(origin string, mediaId string) (bool, error)

func (*MediaTableWithContext) Insert

func (s *MediaTableWithContext) Insert(record *DbMedia) error

func (*MediaTableWithContext) IsHashQuarantined

func (s *MediaTableWithContext) IsHashQuarantined(sha256hash string) (bool, error)

func (*MediaTableWithContext) LocationExists

func (s *MediaTableWithContext) LocationExists(datastoreId string, location string) (bool, error)

func (*MediaTableWithContext) UpdateLocation

func (s *MediaTableWithContext) UpdateLocation(sourceDsId string, sourceLocation string, targetDsId string, targetLocation string) error

type Purpose

type Purpose string
const (
	PurposeNone   Purpose = "none"
	PurposePinned Purpose = "pinned"
)

type SynStatUserOrderBy

type SynStatUserOrderBy string
const (
	SynStatUserOrderByMediaCount  SynStatUserOrderBy = "media_count"
	SynStatUserOrderByMediaLength SynStatUserOrderBy = "media_length"
	SynStatUserOrderByUserId      SynStatUserOrderBy = "user_id"

	DefaultSynStatUserOrderBy = SynStatUserOrderByUserId
)

type VirtLastAccess

type VirtLastAccess struct {
	*Locatable
	SizeBytes    int64
	CreationTs   int64
	LastAccessTs int64
	ContentType  string
}

Jump to

Keyboard shortcuts

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