sqlite

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2026 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SqliteDB 

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

func NewSqliteDB 

func NewSqliteDB(dsn string) (*SqliteDB, error)

func (*SqliteDB) BulkDeleteObjects 

func (db *SqliteDB) BulkDeleteObjects(ctx context.Context, ids []string) error

func (*SqliteDB) BulkUpdateAccessMethods 

func (db *SqliteDB) BulkUpdateAccessMethods(ctx context.Context, updates map[string][]drs.AccessMethod) error

func (*SqliteDB) CreateBucketScope 

func (db *SqliteDB) CreateBucketScope(ctx context.Context, scope *models.BucketScope) error

func (*SqliteDB) CreateObject 

func (db *SqliteDB) CreateObject(ctx context.Context, obj *models.InternalObject) error

func (*SqliteDB) CreateObjectAlias 

func (db *SqliteDB) CreateObjectAlias(ctx context.Context, aliasID, canonicalObjectID string) error

func (*SqliteDB) DeleteBucketScope added in v0.3.1 

func (db *SqliteDB) DeleteBucketScope(ctx context.Context, organization, projectID, credentialID string) error

func (*SqliteDB) DeleteObject 

func (db *SqliteDB) DeleteObject(ctx context.Context, id string) error

func (*SqliteDB) DeleteObjectAlias 

func (db *SqliteDB) DeleteObjectAlias(ctx context.Context, aliasID string) error

func (*SqliteDB) DeleteS3Credential 

func (db *SqliteDB) DeleteS3Credential(ctx context.Context, credentialID string) error

func (*SqliteDB) GetBucketScope 

func (db *SqliteDB) GetBucketScope(ctx context.Context, organization, projectID string) (*models.BucketScope, error)

func (*SqliteDB) GetBulkObjects 

func (db *SqliteDB) GetBulkObjects(ctx context.Context, ids []string) ([]models.InternalObject, error)

func (*SqliteDB) GetFileUsage 

func (db *SqliteDB) GetFileUsage(ctx context.Context, objectID string) (*models.FileUsage, error)

func (*SqliteDB) GetFileUsageSummary 

func (db *SqliteDB) GetFileUsageSummary(ctx context.Context, inactiveSince *time.Time) (models.FileUsageSummary, error)

func (*SqliteDB) GetFileUsageSummaryByResources added in v0.2.8 

func (db *SqliteDB) GetFileUsageSummaryByResources(ctx context.Context, resources []string, includeUnscoped bool, inactiveSince *time.Time) (models.FileUsageSummary, error)

func (*SqliteDB) GetFileUsageSummaryByScope added in v0.2.8 

func (db *SqliteDB) GetFileUsageSummaryByScope(ctx context.Context, organization, project string, inactiveSince *time.Time) (models.FileUsageSummary, error)

func (*SqliteDB) GetObject 

func (db *SqliteDB) GetObject(ctx context.Context, id string) (*models.InternalObject, error)

func (*SqliteDB) GetObjectsByChecksum 

func (db *SqliteDB) GetObjectsByChecksum(ctx context.Context, checksum string) ([]models.InternalObject, error)

func (*SqliteDB) GetObjectsByChecksums 

func (db *SqliteDB) GetObjectsByChecksums(ctx context.Context, checksums []string) (map[string][]models.InternalObject, error)

func (*SqliteDB) GetPendingLFSMeta 

func (db *SqliteDB) GetPendingLFSMeta(ctx context.Context, oid string) (*models.PendingLFSMeta, error)

func (*SqliteDB) GetS3Credential 

func (db *SqliteDB) GetS3Credential(ctx context.Context, credentialID string) (*models.S3Credential, error)

func (*SqliteDB) GetServiceInfo 

func (db *SqliteDB) GetServiceInfo(ctx context.Context) (*drs.Service, error)

func (*SqliteDB) GetTransferAttributionBreakdown added in v0.2.5 

func (db *SqliteDB) GetTransferAttributionBreakdown(ctx context.Context, filter models.TransferAttributionFilter, groupBy string) ([]models.TransferAttributionBreakdown, error)

func (*SqliteDB) GetTransferAttributionBreakdownByResources added in v0.2.8 

func (db *SqliteDB) GetTransferAttributionBreakdownByResources(ctx context.Context, filter models.TransferAttributionFilter, groupBy string, resources []string) ([]models.TransferAttributionBreakdown, error)

func (*SqliteDB) GetTransferAttributionSummary added in v0.2.5 

func (db *SqliteDB) GetTransferAttributionSummary(ctx context.Context, filter models.TransferAttributionFilter) (models.TransferAttributionSummary, error)

func (*SqliteDB) GetTransferAttributionSummaryByResources added in v0.2.8 

func (db *SqliteDB) GetTransferAttributionSummaryByResources(ctx context.Context, filter models.TransferAttributionFilter, resources []string) (models.TransferAttributionSummary, error)

func (*SqliteDB) ListBucketScopes 

func (db *SqliteDB) ListBucketScopes(ctx context.Context) ([]models.BucketScope, error)

func (*SqliteDB) ListBucketVisibilityRows added in v0.2.8 

func (db *SqliteDB) ListBucketVisibilityRows(ctx context.Context, resources []string, includeUnscoped, restrictToResources bool) ([]models.BucketVisibilityRow, error)

func (*SqliteDB) ListFileUsage 

func (db *SqliteDB) ListFileUsage(ctx context.Context, limit, offset int, inactiveSince *time.Time) ([]models.FileUsage, error)

func (*SqliteDB) ListFileUsageByObjectIDs added in v0.2.8 

func (db *SqliteDB) ListFileUsageByObjectIDs(ctx context.Context, ids []string) ([]models.FileUsage, error)

func (*SqliteDB) ListFileUsagePageByResources added in v0.2.8 

func (db *SqliteDB) ListFileUsagePageByResources(ctx context.Context, resources []string, includeUnscoped bool, limit, offset int, inactiveSince *time.Time) ([]models.FileUsage, error)

func (*SqliteDB) ListFileUsagePageByScope added in v0.2.8 

func (db *SqliteDB) ListFileUsagePageByScope(ctx context.Context, organization, project string, limit, offset int, inactiveSince *time.Time) ([]models.FileUsage, error)

func (*SqliteDB) ListObjectIDsByChecksumsAndResources added in v0.2.8 

func (db *SqliteDB) ListObjectIDsByChecksumsAndResources(ctx context.Context, checksums []string, resources []string, includeUnscoped, restrictToResources bool) (map[string][]string, error)

func (*SqliteDB) ListObjectIDsByResources added in v0.2.8 

func (db *SqliteDB) ListObjectIDsByResources(ctx context.Context, resources []string, includeUnscoped bool) ([]string, error)

func (*SqliteDB) ListObjectIDsByScope added in v0.2.5 

func (db *SqliteDB) ListObjectIDsByScope(ctx context.Context, organization, project string) ([]string, error)

func (*SqliteDB) ListObjectIDsByScopeAndResources added in v0.2.8 

func (db *SqliteDB) ListObjectIDsByScopeAndResources(ctx context.Context, organization, project string, resources []string, restrictToResources bool) ([]string, error)

func (*SqliteDB) ListObjectIDsPageByChecksum added in v0.2.8 

func (db *SqliteDB) ListObjectIDsPageByChecksum(ctx context.Context, checksum, checksumType, organization, project, startAfter string, limit, offset int, resources []string, includeUnscoped, restrictToResources bool) ([]string, error)

func (*SqliteDB) ListObjectIDsPageByPath added in v0.3.1 

func (db *SqliteDB) ListObjectIDsPageByPath(ctx context.Context, organization, project, path, startAfter string, limit, offset int) ([]string, []models.BrowseDirectory, error)

func (*SqliteDB) ListObjectIDsPageByResources added in v0.2.8 

func (db *SqliteDB) ListObjectIDsPageByResources(ctx context.Context, resources []string, includeUnscoped bool, startAfter string, limit, offset int) ([]string, error)

func (*SqliteDB) ListObjectIDsPageByScope added in v0.2.8 

func (db *SqliteDB) ListObjectIDsPageByScope(ctx context.Context, organization, project, startAfter string, limit, offset int) ([]string, error)

func (*SqliteDB) ListObjectIDsPageByURL added in v0.2.8 

func (db *SqliteDB) ListObjectIDsPageByURL(ctx context.Context, objectURL, organization, project, startAfter string, limit, offset int, resources []string, includeUnscoped, restrictToResources bool) ([]string, error)

func (*SqliteDB) ListS3Credentials 

func (db *SqliteDB) ListS3Credentials(ctx context.Context) ([]models.S3Credential, error)

func (*SqliteDB) PopPendingLFSMeta 

func (db *SqliteDB) PopPendingLFSMeta(ctx context.Context, oid string) (*models.PendingLFSMeta, error)

func (*SqliteDB) RecordFileDownload 

func (db *SqliteDB) RecordFileDownload(ctx context.Context, objectID string) error

func (*SqliteDB) RecordFileUpload 

func (db *SqliteDB) RecordFileUpload(ctx context.Context, objectID string) error

func (*SqliteDB) RecordProviderTransferEvents added in v0.2.5 

func (db *SqliteDB) RecordProviderTransferEvents(ctx context.Context, events []models.ProviderTransferEvent) error

func (*SqliteDB) RecordTransferAttributionEvents added in v0.2.5 

func (db *SqliteDB) RecordTransferAttributionEvents(ctx context.Context, events []models.TransferAttributionEvent) error

func (*SqliteDB) RegisterObjects 

func (db *SqliteDB) RegisterObjects(ctx context.Context, objects []models.InternalObject) error

func (*SqliteDB) RemoveObjectControlledAccess added in v0.2.9 

func (db *SqliteDB) RemoveObjectControlledAccess(ctx context.Context, objectID, resource string) error

func (*SqliteDB) ResolveObjectAlias 

func (db *SqliteDB) ResolveObjectAlias(ctx context.Context, aliasID string) (string, error)

func (*SqliteDB) SavePendingLFSMeta 

func (db *SqliteDB) SavePendingLFSMeta(ctx context.Context, entries []models.PendingLFSMeta) error

func (*SqliteDB) SaveS3Credential 

func (db *SqliteDB) SaveS3Credential(ctx context.Context, cred *models.S3Credential) error

func (*SqliteDB) UpdateObjectAccessMethods 

func (db *SqliteDB) UpdateObjectAccessMethods(ctx context.Context, objectID string, accessMethods []drs.AccessMethod) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.