metadata

package
v0.5.1 Latest Latest
Warning

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

Go to latest
Published: Apr 4, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source
const (
	COMPRESSION_THRESHOLD = 0 // files above this size are stored compressed. The chi Compress middleware does not have a threshold,
	// so the threshold is set to zero here
	BROTLI_COMPRESSION_LEVEL = 9 // https://paulcalvano.com/2018-07-25-brotli-compression-how-much-will-it-reduce-your-content/ seems

)
View Source
const CURRENT_DB_VERSION = 3

Variables

This section is empty.

Functions

This section is empty.

Types

type DbFile added in v0.2.0

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

func NewDBFile added in v0.2.0

func NewDBFile(name string, compressionType string, data []byte, fi DbFileInfo) *DbFile

func (*DbFile) Close added in v0.2.0

func (f *DbFile) Close() error

func (*DbFile) Name added in v0.2.0

func (f *DbFile) Name() string

func (*DbFile) Read added in v0.2.0

func (f *DbFile) Read(dst []byte) (int, error)

func (*DbFile) ReadCompressed added in v0.3.0

func (f *DbFile) ReadCompressed() ([]byte, string, error)

func (*DbFile) Seek added in v0.2.0

func (f *DbFile) Seek(offset int64, whence int) (int64, error)

func (*DbFile) Stat added in v0.2.0

func (f *DbFile) Stat() (fs.FileInfo, error)

type DbFileInfo added in v0.2.0

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

func (*DbFileInfo) IsDir added in v0.2.0

func (fi *DbFileInfo) IsDir() bool

func (*DbFileInfo) ModTime added in v0.2.0

func (fi *DbFileInfo) ModTime() time.Time

func (*DbFileInfo) Mode added in v0.2.0

func (fi *DbFileInfo) Mode() fs.FileMode

func (*DbFileInfo) Name added in v0.2.0

func (fi *DbFileInfo) Name() string

func (*DbFileInfo) Size added in v0.2.0

func (fi *DbFileInfo) Size() int64

func (*DbFileInfo) Sys added in v0.2.0

func (fi *DbFileInfo) Sys() any

type DbFileReader added in v0.3.0

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

func NewbFileReader added in v0.3.0

func NewbFileReader(compressionType string, data []byte) *DbFileReader

func (*DbFileReader) Read added in v0.3.0

func (f *DbFileReader) Read(dst []byte) (int, error)

func (*DbFileReader) ReadCompressed added in v0.3.0

func (f *DbFileReader) ReadCompressed() ([]byte, string, error)

func (*DbFileReader) Seek added in v0.3.0

func (f *DbFileReader) Seek(offset int64, whence int) (int64, error)

type DbFs added in v0.2.0

type DbFs struct {
	*utils.Logger
	// contains filtered or unexported fields
}

func NewDbFs added in v0.2.0

func NewDbFs(logger *utils.Logger, fileStore *FileStore) (*DbFs, error)

func (*DbFs) Glob added in v0.2.0

func (d *DbFs) Glob(pattern string) (matches []string, err error)

func (*DbFs) Open added in v0.2.0

func (d *DbFs) Open(name string) (fs.File, error)

func (*DbFs) ReadFile added in v0.2.0

func (d *DbFs) ReadFile(name string) ([]byte, error)

func (*DbFs) Reset added in v0.3.0

func (d *DbFs) Reset()

func (*DbFs) Stat added in v0.2.0

func (d *DbFs) Stat(name string) (fs.FileInfo, error)

func (*DbFs) StaticFiles added in v0.3.0

func (d *DbFs) StaticFiles() []string

type FileStore added in v0.2.0

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

func NewFileStore added in v0.2.0

func NewFileStore(appId utils.AppId, version int, metadata *Metadata, tx Transaction) *FileStore

func (*FileStore) AddAppVersionDisk added in v0.4.1

func (f *FileStore) AddAppVersionDisk(ctx context.Context, tx Transaction, metadata utils.AppMetadata, checkoutDir string) error

func (*FileStore) GetAppFiles added in v0.4.1

func (f *FileStore) GetAppFiles(ctx context.Context, tx Transaction) ([]utils.AppFile, error)

func (*FileStore) GetAppVersion added in v0.4.1

func (f *FileStore) GetAppVersion(ctx context.Context, tx Transaction, version int) (*utils.AppVersion, error)

func (*FileStore) GetAppVersions added in v0.4.1

func (f *FileStore) GetAppVersions(ctx context.Context, tx Transaction) ([]utils.AppVersion, error)

func (*FileStore) GetFileBySha added in v0.2.0

func (f *FileStore) GetFileBySha(ctx context.Context, tx Transaction, sha string) ([]byte, string, error)

func (*FileStore) GetFileByShaTx added in v0.3.0

func (f *FileStore) GetFileByShaTx(sha string) ([]byte, string, error)

func (*FileStore) GetHighestVersion added in v0.3.0

func (f *FileStore) GetHighestVersion(ctx context.Context, tx Transaction, appId utils.AppId) (int, error)

func (*FileStore) IncrementAppVersion added in v0.4.1

func (f *FileStore) IncrementAppVersion(ctx context.Context, tx Transaction, metadata *utils.AppMetadata) error

func (*FileStore) PromoteApp added in v0.3.0

func (f *FileStore) PromoteApp(ctx context.Context, tx Transaction, prodAppId utils.AppId, metadata *utils.AppMetadata) error

func (*FileStore) Reset added in v0.3.0

func (f *FileStore) Reset()

type Metadata

type Metadata struct {
	*utils.Logger
	// contains filtered or unexported fields
}

Metadata is the metadata persistence layer

func NewMetadata

func NewMetadata(logger *utils.Logger, config *utils.ServerConfig) (*Metadata, error)

NewMetadata creates a new metadata persistence layer

func (*Metadata) BeginTransaction added in v0.3.0

func (m *Metadata) BeginTransaction(ctx context.Context) (Transaction, error)

BeginTransaction starts a new transaction

func (*Metadata) CommitTransaction added in v0.3.0

func (m *Metadata) CommitTransaction(tx Transaction) error

CommitTransaction commits a transaction

func (*Metadata) CreateApp added in v0.2.0

func (m *Metadata) CreateApp(ctx context.Context, tx Transaction, app *utils.AppEntry) error

func (*Metadata) DeleteApp

func (m *Metadata) DeleteApp(ctx context.Context, tx Transaction, id utils.AppId) error

func (*Metadata) GetAllApps

func (m *Metadata) GetAllApps(includeInternal bool) ([]utils.AppInfo, error)

func (*Metadata) GetApp

func (m *Metadata) GetApp(pathDomain utils.AppPathDomain) (*utils.AppEntry, error)

func (*Metadata) GetAppTx added in v0.3.0

func (m *Metadata) GetAppTx(ctx context.Context, tx Transaction, pathDomain utils.AppPathDomain) (*utils.AppEntry, error)

func (*Metadata) GetAppsForDomain

func (m *Metadata) GetAppsForDomain(domain string) ([]string, error)

func (*Metadata) GetLinkedApps added in v0.3.0

func (m *Metadata) GetLinkedApps(ctx context.Context, tx Transaction, mainAppId utils.AppId) ([]*utils.AppEntry, error)

GetLinkedApps gets all the apps linked to the given main app (staging and preview apps)

func (*Metadata) RollbackTransaction added in v0.3.0

func (m *Metadata) RollbackTransaction(tx Transaction) error

RollbackTransaction rolls back a transaction

func (*Metadata) UpdateAppMetadata

func (m *Metadata) UpdateAppMetadata(ctx context.Context, tx Transaction, app *utils.AppEntry) error

func (*Metadata) UpdateAppSettings added in v0.3.0

func (m *Metadata) UpdateAppSettings(ctx context.Context, tx Transaction, app *utils.AppEntry) error

func (*Metadata) VersionUpgrade

func (m *Metadata) VersionUpgrade() error

type Transaction added in v0.3.0

type Transaction struct {
	*sql.Tx
}

Transaction is a wrapper around sql.Tx

func (*Transaction) IsInitialized added in v0.3.0

func (t *Transaction) IsInitialized() bool

Jump to

Keyboard shortcuts

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