Documentation
¶
Index ¶
- type MockDatabase
- func (m *MockDatabase) BulkDeleteObjects(ctx context.Context, ids []string) error
- func (m *MockDatabase) BulkUpdateAccessMethods(ctx context.Context, updates map[string][]drs.AccessMethod) error
- func (m *MockDatabase) CreateBucketScope(ctx context.Context, scope *core.BucketScope) error
- func (m *MockDatabase) CreateObject(ctx context.Context, obj *core.InternalObject) error
- func (m *MockDatabase) CreateObjectAlias(ctx context.Context, aliasID, canonicalObjectID string) error
- func (m *MockDatabase) DeleteObject(ctx context.Context, id string) error
- func (m *MockDatabase) DeleteS3Credential(ctx context.Context, bucket string) error
- func (m *MockDatabase) GetBucketScope(ctx context.Context, organization, projectID string) (*core.BucketScope, error)
- func (m *MockDatabase) GetBulkObjects(ctx context.Context, ids []string) ([]core.InternalObject, error)
- func (m *MockDatabase) GetFileUsage(ctx context.Context, objectID string) (*core.FileUsage, error)
- func (m *MockDatabase) GetFileUsageSummary(ctx context.Context, inactiveSince *time.Time) (core.FileUsageSummary, error)
- func (m *MockDatabase) GetObject(ctx context.Context, id string) (*core.InternalObject, error)
- func (m *MockDatabase) GetObjectsByChecksum(ctx context.Context, checksum string) ([]core.InternalObject, error)
- func (m *MockDatabase) GetObjectsByChecksums(ctx context.Context, checksums []string) (map[string][]core.InternalObject, error)
- func (m *MockDatabase) GetPendingLFSMeta(ctx context.Context, oid string) (*core.PendingLFSMeta, error)
- func (m *MockDatabase) GetS3Credential(ctx context.Context, bucket string) (*core.S3Credential, error)
- func (m *MockDatabase) GetServiceInfo(ctx context.Context) (*drs.Service, error)
- func (m *MockDatabase) ListBucketScopes(ctx context.Context) ([]core.BucketScope, error)
- func (m *MockDatabase) ListFileUsage(ctx context.Context, limit, offset int, inactiveSince *time.Time) ([]core.FileUsage, error)
- func (m *MockDatabase) ListObjectIDsByResourcePrefix(ctx context.Context, resourcePrefix string) ([]string, error)
- func (m *MockDatabase) ListS3Credentials(ctx context.Context) ([]core.S3Credential, error)
- func (m *MockDatabase) PopPendingLFSMeta(ctx context.Context, oid string) (*core.PendingLFSMeta, error)
- func (m *MockDatabase) RecordFileDownload(ctx context.Context, objectID string) error
- func (m *MockDatabase) RecordFileUpload(ctx context.Context, objectID string) error
- func (m *MockDatabase) RegisterObjects(ctx context.Context, objects []core.InternalObject) error
- func (m *MockDatabase) ResolveObjectAlias(ctx context.Context, aliasID string) (string, error)
- func (m *MockDatabase) SavePendingLFSMeta(ctx context.Context, entries []core.PendingLFSMeta) error
- func (m *MockDatabase) SaveS3Credential(ctx context.Context, cred *core.S3Credential) error
- func (m *MockDatabase) UpdateObjectAccessMethods(ctx context.Context, objectID string, accessMethods []drs.AccessMethod) error
- type MockUrlManager
- func (m *MockUrlManager) CompleteMultipartUpload(ctx context.Context, bucket string, key string, uploadId string, ...) error
- func (m *MockUrlManager) InitMultipartUpload(ctx context.Context, bucket string, key string) (string, error)
- func (m *MockUrlManager) SignDownloadPart(ctx context.Context, accessId string, url string, start int64, end int64, ...) (string, error)
- func (m *MockUrlManager) SignMultipartPart(ctx context.Context, bucket string, key string, uploadId string, ...) (string, error)
- func (m *MockUrlManager) SignURL(ctx context.Context, accessId string, url string, opts urlmanager.SignOptions) (string, error)
- func (m *MockUrlManager) SignUploadURL(ctx context.Context, accessId string, url string, opts urlmanager.SignOptions) (string, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockDatabase ¶
type MockDatabase struct {
Objects map[string]*drs.DrsObject
ObjectAuthz map[string][]string
Credentials map[string]core.S3Credential
BucketScopes map[string]core.BucketScope
PendingMeta map[string]core.PendingLFSMeta
Usage map[string]core.FileUsage
NoDefaultCreds bool
GetObjectErr error
}
MockDatabase implements core.DatabaseInterface for testing
func (*MockDatabase) BulkDeleteObjects ¶
func (m *MockDatabase) BulkDeleteObjects(ctx context.Context, ids []string) error
func (*MockDatabase) BulkUpdateAccessMethods ¶
func (m *MockDatabase) BulkUpdateAccessMethods(ctx context.Context, updates map[string][]drs.AccessMethod) error
func (*MockDatabase) CreateBucketScope ¶
func (m *MockDatabase) CreateBucketScope(ctx context.Context, scope *core.BucketScope) error
func (*MockDatabase) CreateObject ¶
func (m *MockDatabase) CreateObject(ctx context.Context, obj *core.InternalObject) error
func (*MockDatabase) CreateObjectAlias ¶
func (m *MockDatabase) CreateObjectAlias(ctx context.Context, aliasID, canonicalObjectID string) error
func (*MockDatabase) DeleteObject ¶
func (m *MockDatabase) DeleteObject(ctx context.Context, id string) error
func (*MockDatabase) DeleteS3Credential ¶
func (m *MockDatabase) DeleteS3Credential(ctx context.Context, bucket string) error
func (*MockDatabase) GetBucketScope ¶
func (m *MockDatabase) GetBucketScope(ctx context.Context, organization, projectID string) (*core.BucketScope, error)
func (*MockDatabase) GetBulkObjects ¶
func (m *MockDatabase) GetBulkObjects(ctx context.Context, ids []string) ([]core.InternalObject, error)
func (*MockDatabase) GetFileUsage ¶
func (*MockDatabase) GetFileUsageSummary ¶
func (m *MockDatabase) GetFileUsageSummary(ctx context.Context, inactiveSince *time.Time) (core.FileUsageSummary, error)
func (*MockDatabase) GetObject ¶
func (m *MockDatabase) GetObject(ctx context.Context, id string) (*core.InternalObject, error)
func (*MockDatabase) GetObjectsByChecksum ¶
func (m *MockDatabase) GetObjectsByChecksum(ctx context.Context, checksum string) ([]core.InternalObject, error)
func (*MockDatabase) GetObjectsByChecksums ¶
func (m *MockDatabase) GetObjectsByChecksums(ctx context.Context, checksums []string) (map[string][]core.InternalObject, error)
func (*MockDatabase) GetPendingLFSMeta ¶
func (m *MockDatabase) GetPendingLFSMeta(ctx context.Context, oid string) (*core.PendingLFSMeta, error)
func (*MockDatabase) GetS3Credential ¶
func (m *MockDatabase) GetS3Credential(ctx context.Context, bucket string) (*core.S3Credential, error)
func (*MockDatabase) GetServiceInfo ¶
func (*MockDatabase) ListBucketScopes ¶
func (m *MockDatabase) ListBucketScopes(ctx context.Context) ([]core.BucketScope, error)
func (*MockDatabase) ListFileUsage ¶
func (*MockDatabase) ListObjectIDsByResourcePrefix ¶
func (*MockDatabase) ListS3Credentials ¶
func (m *MockDatabase) ListS3Credentials(ctx context.Context) ([]core.S3Credential, error)
func (*MockDatabase) PopPendingLFSMeta ¶
func (m *MockDatabase) PopPendingLFSMeta(ctx context.Context, oid string) (*core.PendingLFSMeta, error)
func (*MockDatabase) RecordFileDownload ¶
func (m *MockDatabase) RecordFileDownload(ctx context.Context, objectID string) error
func (*MockDatabase) RecordFileUpload ¶
func (m *MockDatabase) RecordFileUpload(ctx context.Context, objectID string) error
func (*MockDatabase) RegisterObjects ¶
func (m *MockDatabase) RegisterObjects(ctx context.Context, objects []core.InternalObject) error
func (*MockDatabase) ResolveObjectAlias ¶
func (*MockDatabase) SavePendingLFSMeta ¶
func (m *MockDatabase) SavePendingLFSMeta(ctx context.Context, entries []core.PendingLFSMeta) error
func (*MockDatabase) SaveS3Credential ¶
func (m *MockDatabase) SaveS3Credential(ctx context.Context, cred *core.S3Credential) error
func (*MockDatabase) UpdateObjectAccessMethods ¶
func (m *MockDatabase) UpdateObjectAccessMethods(ctx context.Context, objectID string, accessMethods []drs.AccessMethod) error
type MockUrlManager ¶
type MockUrlManager struct{}
MockUrlManager implements urlmanager.UrlManager for testing
func (*MockUrlManager) CompleteMultipartUpload ¶
func (m *MockUrlManager) CompleteMultipartUpload(ctx context.Context, bucket string, key string, uploadId string, parts []urlmanager.MultipartPart) error
func (*MockUrlManager) InitMultipartUpload ¶
func (*MockUrlManager) SignDownloadPart ¶
func (m *MockUrlManager) SignDownloadPart(ctx context.Context, accessId string, url string, start int64, end int64, opts urlmanager.SignOptions) (string, error)
func (*MockUrlManager) SignMultipartPart ¶
func (*MockUrlManager) SignURL ¶
func (m *MockUrlManager) SignURL(ctx context.Context, accessId string, url string, opts urlmanager.SignOptions) (string, error)
func (*MockUrlManager) SignUploadURL ¶
func (m *MockUrlManager) SignUploadURL(ctx context.Context, accessId string, url string, opts urlmanager.SignOptions) (string, error)
Click to show internal directories.
Click to hide internal directories.