metabase

Dec 18, 2024

Changes in this version

type ObjectEntry

+ IsLatest bool

Dec 9, 2024

Changes in this version

type Adapter

+ DeleteObjectsAndSegmentsNoVerify func(ctx context.Context, objects []ObjectStream) (objectsDeleted, segmentsDeleted int64, err error)

type PostgresAdapter

+ func (p *PostgresAdapter) DeleteObjectsAndSegmentsNoVerify(ctx context.Context, objects []ObjectStream) (objectsDeleted, segmentsDeleted int64, err error)

type SpannerAdapter

+ func (s *SpannerAdapter) DeleteObjectsAndSegmentsNoVerify(ctx context.Context, objects []ObjectStream) (objectsDeleted, segmentsDeleted int64, err error)

Oct 29, 2024

Changes in this version

type Adapter

+ DeleteAllBucketObjects func(ctx context.Context, opts DeleteAllBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

type CockroachAdapter

+ func (c *CockroachAdapter) DeleteAllBucketObjects(ctx context.Context, opts DeleteAllBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

type DB

+ func (db *DB) DeleteAllBucketObjects(ctx context.Context, opts DeleteAllBucketObjects) (deletedObjectCount int64, err error)

+ type DeleteAllBucketObjects struct

+ BatchSize int

+ Bucket BucketLocation

type PostgresAdapter

+ func (p *PostgresAdapter) DeleteAllBucketObjects(ctx context.Context, opts DeleteAllBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

type SpannerAdapter

+ func (s *SpannerAdapter) DeleteAllBucketObjects(ctx context.Context, opts DeleteAllBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

Oct 2, 2024

Changes in this version

type CockroachAdapter

+ func (c *CockroachAdapter) IterateLoopSegments(ctx context.Context, aliasCache *NodeAliasCache, opts IterateLoopSegments, ...) (err error)

type IterateLoopSegments

+ SpannerReadTimestamp time.Time

type LoopSegmentEntry

+ Source string

Sep 30, 2024

Changes in this version

type BeginObjectNextVersion

+ LegalHold bool

type CommitInlineObject

+ LegalHold bool

type SetObjectExactVersionRetention

+ BypassGovernance bool

type SetObjectLastCommittedRetention

+ BypassGovernance bool

type SpannerAdapter

+ func (s *SpannerAdapter) SpannerMigration() *migrate.Migration

Sep 16, 2024

Changes in this version

type Adapter

+ GetObjectExactVersionLegalHold func(ctx context.Context, opts GetObjectExactVersionLegalHold) (enabled bool, err error)

+ GetObjectLastCommittedLegalHold func(ctx context.Context, opts GetObjectLastCommittedLegalHold) (enabled bool, err error)

+ SetObjectExactVersionLegalHold func(ctx context.Context, opts SetObjectExactVersionLegalHold) error

+ SetObjectLastCommittedLegalHold func(ctx context.Context, opts SetObjectLastCommittedLegalHold) error

type BeginObjectExactVersion

+ LegalHold bool

type DB

+ func (db *DB) GetObjectExactVersionLegalHold(ctx context.Context, opts GetObjectExactVersionLegalHold) (enabled bool, err error)

+ func (db *DB) GetObjectLastCommittedLegalHold(ctx context.Context, opts GetObjectLastCommittedLegalHold) (enabled bool, err error)

+ func (db *DB) SetObjectExactVersionLegalHold(ctx context.Context, opts SetObjectExactVersionLegalHold) (err error)

+ func (db *DB) SetObjectLastCommittedLegalHold(ctx context.Context, opts SetObjectLastCommittedLegalHold) (err error)

type DeleteObjectExactVersion

+ ObjectLock ObjectLockDeleteOptions

type DeleteObjectLastCommitted

+ ObjectLock ObjectLockDeleteOptions

type FinishCopyObject

+ LegalHold bool

type FinishMoveObject

+ LegalHold bool

+ type GetObjectExactVersionLegalHold struct

+ Version Version

+ type GetObjectLastCommittedLegalHold struct

+ type ObjectLockDeleteOptions struct

+ BypassGovernance bool

+ Enabled bool

type PostgresAdapter

+ func (p *PostgresAdapter) GetObjectExactVersionLegalHold(ctx context.Context, opts GetObjectExactVersionLegalHold) (_ bool, err error)

+ func (p *PostgresAdapter) GetObjectLastCommittedLegalHold(ctx context.Context, opts GetObjectLastCommittedLegalHold) (_ bool, err error)

+ func (p *PostgresAdapter) SetObjectExactVersionLegalHold(ctx context.Context, opts SetObjectExactVersionLegalHold) (err error)

+ func (p *PostgresAdapter) SetObjectLastCommittedLegalHold(ctx context.Context, opts SetObjectLastCommittedLegalHold) (err error)

type PrecommitDeleteUnversionedWithNonPending

+ ObjectLock ObjectLockDeleteOptions

type RawObject

+ LegalHold bool

+ type SetObjectExactVersionLegalHold struct

+ Enabled bool

+ Version Version

+ func (opts *SetObjectExactVersionLegalHold) Verify() error

+ type SetObjectLastCommittedLegalHold struct

+ Enabled bool

+ func (opts SetObjectLastCommittedLegalHold) Verify() error

type SpannerAdapter

+ func (s *SpannerAdapter) GetObjectExactVersionLegalHold(ctx context.Context, opts GetObjectExactVersionLegalHold) (_ bool, err error)

+ func (s *SpannerAdapter) GetObjectLastCommittedLegalHold(ctx context.Context, opts GetObjectLastCommittedLegalHold) (_ bool, err error)

+ func (s *SpannerAdapter) SetObjectExactVersionLegalHold(ctx context.Context, opts SetObjectExactVersionLegalHold) (err error)

+ func (s *SpannerAdapter) SetObjectLastCommittedLegalHold(ctx context.Context, opts SetObjectLastCommittedLegalHold) (err error)

Sep 3, 2024

Changes in this version

type Adapter

+ CheckVersion func(ctx context.Context) error

+ Implementation func() dbutil.Implementation

+ MigrateToLatest func(ctx context.Context) error

+ TestingSetObjectVersion func(ctx context.Context, object ObjectStream, randomVersion Version) (rowsAffected int64, err error)

+ TestingSetPlacementAllSegments func(ctx context.Context, placement storj.PlacementConstraint) (err error)

type CockroachAdapter

+ func (c *CockroachAdapter) MigrateToLatest(ctx context.Context) error

type CommitObject

+ ObjectLockEnabledForProject bool

type Config

+ TestingSpannerProjects map[uuid.UUID]struct{}

type DB

+ func (db *DB) TestingSetObjectVersion(ctx context.Context, object ObjectStream, randomVersion Version) (rowsAffected int64, err error)

+ func (db *DB) TestingSetPlacementAllSegments(ctx context.Context, placement storj.PlacementConstraint) (err error)

type DeleteObjectExactVersion

+ ObjectLockEnabledForProject bool

type DeleteObjectLastCommitted

+ ObjectLockEnabledForProject bool

type FinishMoveObject

+ Retention Retention

type PostgresAdapter

+ func (p *PostgresAdapter) CheckVersion(ctx context.Context) error

+ func (p *PostgresAdapter) Implementation() dbutil.Implementation

+ func (p *PostgresAdapter) MigrateToLatest(ctx context.Context) error

+ func (p *PostgresAdapter) PostgresMigration() *migrate.Migration

+ func (p *PostgresAdapter) TestingSetObjectVersion(ctx context.Context, object ObjectStream, randomVersion Version) (rowsAffected int64, err error)

+ func (p *PostgresAdapter) TestingSetPlacementAllSegments(ctx context.Context, placement storj.PlacementConstraint) (err error)

type PrecommitDeleteUnversionedWithNonPending

+ ObjectLockEnabledForProject bool

type Retention

+ func (r *Retention) ActiveNow() bool

type SpannerAdapter

+ func (s *SpannerAdapter) CheckVersion(ctx context.Context) error

+ func (s *SpannerAdapter) Implementation() dbutil.Implementation

+ func (s *SpannerAdapter) MigrateToLatest(ctx context.Context) error

+ func (s *SpannerAdapter) TestingSetObjectVersion(ctx context.Context, object ObjectStream, randomVersion Version) (rowsAffected int64, err error)

+ func (s *SpannerAdapter) TestingSetPlacementAllSegments(ctx context.Context, placement storj.PlacementConstraint) (err error)

Aug 22, 2024

Changes in this version

type DeleteExpiredObjects

+ DeleteConcurrency int

Aug 19, 2024

Changes in this version

type PrecommitConstraint

+ TestingPrecommitDeleteMode TestingPrecommitDeleteMode

+ type TestingPrecommitDeleteMode int

Aug 6, 2024

Changes in this version

+ var ErrObjectExpiration = errs.Class("object expiration")

+ var ErrObjectLock = errs.Class("object lock")

+ var ErrObjectStatus = errs.Class("object status")

type Adapter

+ GetObjectExactVersionRetention func(ctx context.Context, opts GetObjectExactVersionRetention) (retention Retention, err error)

+ GetObjectLastCommittedRetention func(ctx context.Context, opts GetObjectLastCommittedRetention) (retention Retention, err error)

+ SetObjectExactVersionRetention func(ctx context.Context, opts SetObjectExactVersionRetention) error

+ SetObjectLastCommittedRetention func(ctx context.Context, opts SetObjectLastCommittedRetention) error

+ TestMigrateToLatest func(ctx context.Context) error

type BeginObjectExactVersion

+ TestingBypassVerify bool

type CockroachAdapter

+ func (c *CockroachAdapter) TestMigrateToLatest(ctx context.Context) error

type CommitInlineObject

+ Retention Retention

+ UseObjectLock bool

type CommitObject

+ UseObjectLock bool

type DB

+ func (db *DB) GetObjectExactVersionRetention(ctx context.Context, opts GetObjectExactVersionRetention) (retention Retention, err error)

+ func (db *DB) GetObjectLastCommittedRetention(ctx context.Context, opts GetObjectLastCommittedRetention) (retention Retention, err error)

+ func (db *DB) SetObjectExactVersionRetention(ctx context.Context, opts SetObjectExactVersionRetention) (err error)

+ func (db *DB) SetObjectLastCommittedRetention(ctx context.Context, opts SetObjectLastCommittedRetention) (err error)

type DeleteObjectExactVersion

+ UseObjectLock bool

type DeleteObjectLastCommitted

+ UseObjectLock bool

type FinishCopyObject

+ Retention Retention

+ type GetObjectExactVersionRetention struct

+ Version Version

+ type GetObjectLastCommittedRetention struct

type ObjectStatus

+ func (status ObjectStatus) IsCommitted() bool

+ func (status ObjectStatus) IsUnversioned() bool

type PostgresAdapter

+ func (p *PostgresAdapter) GetObjectExactVersionRetention(ctx context.Context, opts GetObjectExactVersionRetention) (retention Retention, err error)

+ func (p *PostgresAdapter) GetObjectLastCommittedRetention(ctx context.Context, opts GetObjectLastCommittedRetention) (retention Retention, err error)

+ func (p *PostgresAdapter) SetObjectExactVersionRetention(ctx context.Context, opts SetObjectExactVersionRetention) (err error)

+ func (p *PostgresAdapter) SetObjectLastCommittedRetention(ctx context.Context, opts SetObjectLastCommittedRetention) (err error)

+ func (p *PostgresAdapter) TestMigrateToLatest(ctx context.Context) error

+ type PrecommitDeleteMode int

+ const DefaultUnversionedPrecommitMode

+ const WithObjectLockUnversionedPrecommitMode

+ const WithPrecheckSQLUnversionedPrecommitMode

+ const WithVersionPrecheckUnversionedPrecommitMode

+ type PrecommitDeleteUnversionedWithNonPending struct

+ UseObjectLock bool

type Retention

+ func (r *Retention) Active() bool

+ type SetObjectExactVersionRetention struct

+ Retention Retention

+ Version Version

+ func (opts *SetObjectExactVersionRetention) Verify() (err error)

+ type SetObjectLastCommittedRetention struct

+ Retention Retention

+ func (opts SetObjectLastCommittedRetention) Verify() (err error)

type SpannerAdapter

+ func (s *SpannerAdapter) GetObjectExactVersionRetention(ctx context.Context, opts GetObjectExactVersionRetention) (retention Retention, err error)

+ func (s *SpannerAdapter) GetObjectLastCommittedRetention(ctx context.Context, opts GetObjectLastCommittedRetention) (retention Retention, err error)

+ func (s *SpannerAdapter) SetObjectExactVersionRetention(ctx context.Context, opts SetObjectExactVersionRetention) (err error)

+ func (s *SpannerAdapter) SetObjectLastCommittedRetention(ctx context.Context, opts SetObjectLastCommittedRetention) (err error)

+ func (s *SpannerAdapter) TestMigrateToLatest(ctx context.Context) error

type SpannerConfig

+ ApplicationName string

type StreamVersionID

+ func NewStreamVersionID(version Version, streamID uuid.UUID) StreamVersionID

Jul 22, 2024

Changes in this version

type BeginObjectExactVersion

+ Retention Retention

type BeginObjectNextVersion

+ Retention Retention

+ type BucketName string

+ func (b *BucketName) DecodeSpanner(value any) error

+ func (b *BucketName) Scan(value interface{}) error

+ func (b BucketName) Compare(x BucketName) int

+ func (b BucketName) EncodeSpanner() (any, error)

+ func (b BucketName) String() string

+ func (b BucketName) Value() (driver.Value, error)

type RawObject

+ Retention Retention

+ type Retention struct

+ Mode storj.RetentionMode

+ RetainUntil time.Time

+ func (r *Retention) Enabled() bool

+ func (r *Retention) Verify() error

Jul 8, 2024

Changes in this version

type Adapter

+ GetNodeAliasEntries func(ctx context.Context, opts GetNodeAliasEntries) (entries []NodeAliasEntry, err error)

type Config

+ NodeAliasCacheFullRefresh bool

type DB

+ func (db *DB) GetNodeAliasEntries(ctx context.Context, opts GetNodeAliasEntries) (entries []NodeAliasEntry, err error)

+ type GetNodeAliasEntries struct

+ Aliases []NodeAlias

+ Nodes []storj.NodeID

type NodeAliasDB

+ GetNodeAliasEntries func(ctx context.Context, opts GetNodeAliasEntries) (_ []NodeAliasEntry, err error)

type PostgresAdapter

+ func (p *PostgresAdapter) GetNodeAliasEntries(ctx context.Context, opts GetNodeAliasEntries) (_ []NodeAliasEntry, err error)

type SpannerAdapter

+ func (s *SpannerAdapter) GetNodeAliasEntries(ctx context.Context, opts GetNodeAliasEntries) (_ []NodeAliasEntry, err error)

Jun 25, 2024

Changes in this version

+ var PrecommitDeleteModes = []int

+ func TupleGreaterThanSQL(tup1, tup2 []string, orEqual bool) string

type Adapter

+ CollectBucketTallies func(ctx context.Context, opts CollectBucketTallies) (result []BucketTally, err error)

+ DeleteBucketObjects func(ctx context.Context, opts DeleteBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

+ GetStreamPieceCountByAlias func(ctx context.Context, opts GetStreamPieceCountByNodeID) (result map[NodeAlias]int64, err error)

+ ListBucketsStreamIDs func(ctx context.Context, opts ListBucketsStreamIDs, bucketNamesBytes [][]byte, ...) (result ListBucketsStreamIDsResult, err error)

+ ListVerifySegments func(ctx context.Context, opts ListVerifySegments) (segments []VerifySegment, err error)

+ Now func(ctx context.Context) (time.Time, error)

+ Ping func(ctx context.Context) error

+ UpdateTableStats func(ctx context.Context) error

type BucketLocation

+ func (loc BucketLocation) Compare(other BucketLocation) int

type CockroachAdapter

+ func (c *CockroachAdapter) DeleteBucketObjects(ctx context.Context, opts DeleteBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

+ func (c *CockroachAdapter) UpdateTableStats(ctx context.Context) error

type DB

+ func (db *DB) UpdateTableStats(ctx context.Context) (err error)

type GetStreamPieceCountByNodeID

+ ProjectID uuid.UUID

type PostgresAdapter

+ func (p *PostgresAdapter) CollectBucketTallies(ctx context.Context, opts CollectBucketTallies) (result []BucketTally, err error)

+ func (p *PostgresAdapter) DeleteBucketObjects(ctx context.Context, opts DeleteBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

+ func (p *PostgresAdapter) GetStreamPieceCountByAlias(ctx context.Context, opts GetStreamPieceCountByNodeID) (result map[NodeAlias]int64, err error)

+ func (p *PostgresAdapter) ListBucketsStreamIDs(ctx context.Context, opts ListBucketsStreamIDs, bucketNamesBytes [][]byte, ...) (result ListBucketsStreamIDsResult, err error)

+ func (p *PostgresAdapter) ListVerifySegments(ctx context.Context, opts ListVerifySegments) (segments []VerifySegment, err error)

+ func (p *PostgresAdapter) Now(ctx context.Context) (time.Time, error)

+ func (p *PostgresAdapter) Ping(ctx context.Context) error

+ func (p *PostgresAdapter) UnderlyingDB() tagsql.DB

+ func (p *PostgresAdapter) UpdateTableStats(ctx context.Context) error

type SpannerAdapter

+ func (s *SpannerAdapter) CollectBucketTallies(ctx context.Context, opts CollectBucketTallies) (result []BucketTally, err error)

+ func (s *SpannerAdapter) DeleteBucketObjects(ctx context.Context, opts DeleteBucketObjects) (deletedObjectCount, deletedSegmentCount int64, err error)

+ func (s *SpannerAdapter) GetStreamPieceCountByAlias(ctx context.Context, opts GetStreamPieceCountByNodeID) (result map[NodeAlias]int64, err error)

+ func (s *SpannerAdapter) ListBucketsStreamIDs(ctx context.Context, opts ListBucketsStreamIDs, bucketNamesBytes [][]byte, ...) (result ListBucketsStreamIDsResult, err error)

+ func (s *SpannerAdapter) ListVerifySegments(ctx context.Context, opts ListVerifySegments) (segments []VerifySegment, err error)

+ func (s *SpannerAdapter) Now(ctx context.Context) (time.Time, error)

+ func (s *SpannerAdapter) Ping(ctx context.Context) error

+ func (s *SpannerAdapter) UnderlyingDB() *spanner.Client

+ func (s *SpannerAdapter) UpdateTableStats(ctx context.Context) error

Jun 10, 2024

Changes in this version

+ const ValidatePlainSize

+ func LessObjectKey(a, b ObjectKey) bool

+ func LimitedAsOfSystemTime(impl dbutil.Implementation, now, baseline time.Time, maxInterval time.Duration) string

type Adapter

+ BucketEmpty func(ctx context.Context, opts BucketEmpty) (empty bool, err error)

+ DeleteInactiveObjectsAndSegments func(ctx context.Context, objects []ObjectStream, opts DeleteZombieObjects) (objectsDeleted, segmentsDeleted int64, err error)

+ DeleteObjectExactVersion func(ctx context.Context, opts DeleteObjectExactVersion) (result DeleteObjectResult, err error)

+ DeleteObjectLastCommittedPlain func(ctx context.Context, opts DeleteObjectLastCommitted) (result DeleteObjectResult, err error)

+ DeleteObjectLastCommittedSuspended func(ctx context.Context, opts DeleteObjectLastCommitted, ...) (result DeleteObjectResult, err error)

+ DeleteObjectLastCommittedVersioned func(ctx context.Context, opts DeleteObjectLastCommitted, ...) (result DeleteObjectResult, err error)

+ DeleteObjectsAllVersions func(ctx context.Context, projectID uuid.UUID, bucketName string, ...) (result DeleteObjectResult, err error)

+ DeleteObjectsAndSegments func(ctx context.Context, objects []ObjectStream) (objectsDeleted, segmentsDeleted int64, err error)

+ DeletePendingObject func(ctx context.Context, opts DeletePendingObject) (result DeleteObjectResult, err error)

+ FindExpiredObjects func(ctx context.Context, opts DeleteExpiredObjects, startAfter ObjectStream, ...) (expiredObjects []ObjectStream, err error)

+ FindZombieObjects func(ctx context.Context, opts DeleteZombieObjects, startAfter ObjectStream, ...) (objects []ObjectStream, err error)

+ GetLatestObjectLastSegment func(ctx context.Context, opts GetLatestObjectLastSegment) (segment Segment, aliasPieces AliasPieces, err error)

+ GetObjectExactVersion func(ctx context.Context, opts GetObjectExactVersion) (_ Object, err error)

+ GetSegmentByPosition func(ctx context.Context, opts GetSegmentByPosition) (segment Segment, aliasPieces AliasPieces, err error)

+ GetSegmentPositionsAndKeys func(ctx context.Context, streamID uuid.UUID) (keysNonces []EncryptedKeyAndNonce, err error)

+ ListObjects func(ctx context.Context, opts ListObjects) (result ListObjectsResult, err error)

+ ListSegments func(ctx context.Context, opts ListSegments, aliasCache *NodeAliasCache) (result ListSegmentsResult, err error)

+ ListStreamPositions func(ctx context.Context, opts ListStreamPositions) (result ListStreamPositionsResult, err error)

+ Name func() string

+ TestingBatchInsertObjects func(ctx context.Context, objects []RawObject) (err error)

+ UpdateObjectLastCommittedMetadata func(ctx context.Context, opts UpdateObjectLastCommittedMetadata) (affected int64, err error)

+ UpdateSegmentPieces func(ctx context.Context, opts UpdateSegmentPieces, ...) (resultPieces AliasPieces, err error)

type CockroachAdapter

+ func (c *CockroachAdapter) Name() string

+ type CommitInlineObject struct

+ DisallowDelete bool

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ Encryption storj.EncryptionParameters

+ ExpiresAt *time.Time

+ Versioned bool

+ func (c *CommitInlineObject) Verify() error

type CommitInlineSegment

+ func (opts CommitInlineSegment) Verify() error

type Config

+ TestingPrecommitDeleteMode int

type DB

+ func (db *DB) CommitInlineObject(ctx context.Context, opts CommitInlineObject) (object Object, err error)

+ func (db *DB) PrecommitConstraint(ctx context.Context, opts PrecommitConstraint, ...) (result PrecommitConstraintResult, err error)

type ListObjects

+ func (opts *ListObjects) FirstVersion() Version

+ func (opts *ListObjects) StartCursor() ListObjectsCursor

type ListSegments

+ ProjectID uuid.UUID

type ListStreamPositions

+ ProjectID uuid.UUID

type ObjectKey

+ func PrefixLimit(a ObjectKey) ObjectKey

+ type ObjectsIteratorCursor struct

+ Inclusive bool

+ Key ObjectKey

+ StreamID uuid.UUID

+ Version Version

+ func FirstIterateCursor(recursive bool, cursor IterateCursor, prefix ObjectKey) ObjectsIteratorCursor

type PostgresAdapter

+ func (p *PostgresAdapter) BucketEmpty(ctx context.Context, opts BucketEmpty) (empty bool, err error)

+ func (p *PostgresAdapter) DeleteInactiveObjectsAndSegments(ctx context.Context, objects []ObjectStream, opts DeleteZombieObjects) (objectsDeleted, segmentsDeleted int64, err error)

+ func (p *PostgresAdapter) DeleteObjectExactVersion(ctx context.Context, opts DeleteObjectExactVersion) (result DeleteObjectResult, err error)

+ func (p *PostgresAdapter) DeleteObjectLastCommittedPlain(ctx context.Context, opts DeleteObjectLastCommitted) (result DeleteObjectResult, err error)

+ func (p *PostgresAdapter) DeleteObjectLastCommittedSuspended(ctx context.Context, opts DeleteObjectLastCommitted, ...) (result DeleteObjectResult, err error)

+ func (p *PostgresAdapter) DeleteObjectLastCommittedVersioned(ctx context.Context, opts DeleteObjectLastCommitted, ...) (result DeleteObjectResult, err error)

+ func (p *PostgresAdapter) DeleteObjectsAllVersions(ctx context.Context, projectID uuid.UUID, bucketName string, ...) (result DeleteObjectResult, err error)

+ func (p *PostgresAdapter) DeleteObjectsAndSegments(ctx context.Context, objects []ObjectStream) (objectsDeleted, segmentsDeleted int64, err error)

+ func (p *PostgresAdapter) DeletePendingObject(ctx context.Context, opts DeletePendingObject) (result DeleteObjectResult, err error)

+ func (p *PostgresAdapter) FindExpiredObjects(ctx context.Context, opts DeleteExpiredObjects, startAfter ObjectStream, ...) (expiredObjects []ObjectStream, err error)

+ func (p *PostgresAdapter) FindZombieObjects(ctx context.Context, opts DeleteZombieObjects, startAfter ObjectStream, ...) (objects []ObjectStream, err error)

+ func (p *PostgresAdapter) GetLatestObjectLastSegment(ctx context.Context, opts GetLatestObjectLastSegment) (segment Segment, aliasPieces AliasPieces, err error)

+ func (p *PostgresAdapter) GetObjectExactVersion(ctx context.Context, opts GetObjectExactVersion) (_ Object, err error)

+ func (p *PostgresAdapter) GetSegmentByPosition(ctx context.Context, opts GetSegmentByPosition) (segment Segment, aliasPieces AliasPieces, err error)

+ func (p *PostgresAdapter) GetSegmentPositionsAndKeys(ctx context.Context, streamID uuid.UUID) (keysNonces []EncryptedKeyAndNonce, err error)

+ func (p *PostgresAdapter) ListObjects(ctx context.Context, opts ListObjects) (result ListObjectsResult, err error)

+ func (p *PostgresAdapter) ListSegments(ctx context.Context, opts ListSegments, aliasCache *NodeAliasCache) (result ListSegmentsResult, err error)

+ func (p *PostgresAdapter) ListStreamPositions(ctx context.Context, opts ListStreamPositions) (result ListStreamPositionsResult, err error)

+ func (p *PostgresAdapter) Name() string

+ func (p *PostgresAdapter) TestingBatchInsertObjects(ctx context.Context, objects []RawObject) (err error)

+ func (p *PostgresAdapter) UpdateObjectLastCommittedMetadata(ctx context.Context, opts UpdateObjectLastCommittedMetadata) (affected int64, err error)

+ func (p *PostgresAdapter) UpdateSegmentPieces(ctx context.Context, opts UpdateSegmentPieces, ...) (resultPieces AliasPieces, err error)

+ type PrecommitConstraint struct

+ DisallowDelete bool

+ Location ObjectLocation

+ PrecommitDeleteMode int

+ Versioned bool

+ type PrecommitConstraintResult struct

+ Deleted []Object

+ DeletedObjectCount int

+ DeletedSegmentCount int

+ HighestVersion Version

+ type PrecommitConstraintWithNonPendingResult struct

+ Deleted []Object

+ DeletedObjectCount int

+ DeletedSegmentCount int

+ HighestNonPendingVersion Version

+ HighestVersion Version

type SpannerAdapter

+ func (s *SpannerAdapter) BucketEmpty(ctx context.Context, opts BucketEmpty) (empty bool, err error)

+ func (s *SpannerAdapter) DeleteInactiveObjectsAndSegments(ctx context.Context, objects []ObjectStream, opts DeleteZombieObjects) (objectsDeleted, segmentsDeleted int64, err error)

+ func (s *SpannerAdapter) DeleteObjectExactVersion(ctx context.Context, opts DeleteObjectExactVersion) (result DeleteObjectResult, err error)

+ func (s *SpannerAdapter) DeleteObjectLastCommittedPlain(ctx context.Context, opts DeleteObjectLastCommitted) (result DeleteObjectResult, err error)

+ func (s *SpannerAdapter) DeleteObjectLastCommittedSuspended(ctx context.Context, opts DeleteObjectLastCommitted, ...) (result DeleteObjectResult, err error)

+ func (s *SpannerAdapter) DeleteObjectLastCommittedVersioned(ctx context.Context, opts DeleteObjectLastCommitted, ...) (result DeleteObjectResult, err error)

+ func (s *SpannerAdapter) DeleteObjectsAllVersions(ctx context.Context, projectID uuid.UUID, bucketName string, ...) (result DeleteObjectResult, err error)

+ func (s *SpannerAdapter) DeleteObjectsAndSegments(ctx context.Context, objects []ObjectStream) (objectsDeleted, segmentsDeleted int64, err error)

+ func (s *SpannerAdapter) DeletePendingObject(ctx context.Context, opts DeletePendingObject) (result DeleteObjectResult, err error)

+ func (s *SpannerAdapter) FindExpiredObjects(ctx context.Context, opts DeleteExpiredObjects, startAfter ObjectStream, ...) (expiredObjects []ObjectStream, err error)

+ func (s *SpannerAdapter) FindZombieObjects(ctx context.Context, opts DeleteZombieObjects, startAfter ObjectStream, ...) (objects []ObjectStream, err error)

+ func (s *SpannerAdapter) GetLatestObjectLastSegment(ctx context.Context, opts GetLatestObjectLastSegment) (segment Segment, aliasPieces AliasPieces, err error)

+ func (s *SpannerAdapter) GetObjectExactVersion(ctx context.Context, opts GetObjectExactVersion) (object Object, err error)

+ func (s *SpannerAdapter) GetSegmentByPosition(ctx context.Context, opts GetSegmentByPosition) (segment Segment, aliasPieces AliasPieces, err error)

+ func (s *SpannerAdapter) GetSegmentPositionsAndKeys(ctx context.Context, streamID uuid.UUID) (keysNonces []EncryptedKeyAndNonce, err error)

+ func (s *SpannerAdapter) ListObjects(ctx context.Context, opts ListObjects) (result ListObjectsResult, err error)

+ func (s *SpannerAdapter) ListSegments(ctx context.Context, opts ListSegments, aliasCache *NodeAliasCache) (result ListSegmentsResult, err error)

+ func (s *SpannerAdapter) ListStreamPositions(ctx context.Context, opts ListStreamPositions) (result ListStreamPositionsResult, err error)

+ func (s *SpannerAdapter) Name() string

+ func (s *SpannerAdapter) TestingBatchInsertObjects(ctx context.Context, objects []RawObject) (err error)

+ func (s *SpannerAdapter) UpdateObjectLastCommittedMetadata(ctx context.Context, opts UpdateObjectLastCommittedMetadata) (affected int64, err error)

+ func (s *SpannerAdapter) UpdateSegmentPieces(ctx context.Context, opts UpdateSegmentPieces, ...) (resultPieces AliasPieces, err error)

type UpdateSegmentPieces

+ DBAdapterName string

May 28, 2024

Changes in this version

type CockroachAdapter

+ func (p *CockroachAdapter) CommitInlineSegment(ctx context.Context, opts CommitInlineSegment) (err error)

type Config

+ TestingCommitSegmentMode string

May 9, 2024

Changes in this version

type Adapter

+ CommitInlineSegment func(ctx context.Context, opts CommitInlineSegment) error

+ CommitPendingObjectSegment func(ctx context.Context, opts CommitSegment, aliasPieces AliasPieces) error

+ GetTableStats func(ctx context.Context, opts GetTableStats) (result TableStats, err error)

+ PendingObjectExists func(ctx context.Context, opts BeginSegment) (exists bool, err error)

+ TestingGetAllObjects func(ctx context.Context) (_ []RawObject, err error)

+ WithTx func(ctx context.Context, f func(context.Context, TransactionAdapter) error) error

type CockroachAdapter

+ func (c *CockroachAdapter) GetTableStats(ctx context.Context, opts GetTableStats) (result TableStats, err error)

+ func (p *CockroachAdapter) CommitPendingObjectSegment(ctx context.Context, opts CommitSegment, aliasPieces AliasPieces) (err error)

type ObjectKey

+ func (o *ObjectKey) DecodeSpanner(value any) error

+ func (o ObjectKey) EncodeSpanner() (any, error)

type ObjectStatus

+ func (status *ObjectStatus) DecodeSpanner(val any) (err error)

+ func (status ObjectStatus) EncodeSpanner() (any, error)

type PostgresAdapter

+ func (p *PostgresAdapter) CommitInlineSegment(ctx context.Context, opts CommitInlineSegment) (err error)

+ func (p *PostgresAdapter) CommitPendingObjectSegment(ctx context.Context, opts CommitSegment, aliasPieces AliasPieces) (err error)

+ func (p *PostgresAdapter) GetTableStats(ctx context.Context, opts GetTableStats) (result TableStats, err error)

+ func (p *PostgresAdapter) PendingObjectExists(ctx context.Context, opts BeginSegment) (exists bool, err error)

+ func (p *PostgresAdapter) TestingGetAllObjects(ctx context.Context) (_ []RawObject, err error)

+ func (p *PostgresAdapter) WithTx(ctx context.Context, f func(context.Context, TransactionAdapter) error) error

type SpannerAdapter

+ func (s *SpannerAdapter) CommitInlineSegment(ctx context.Context, opts CommitInlineSegment) error

+ func (s *SpannerAdapter) CommitPendingObjectSegment(ctx context.Context, opts CommitSegment, aliasPieces AliasPieces) error

+ func (s *SpannerAdapter) GetTableStats(ctx context.Context, opts GetTableStats) (result TableStats, err error)

+ func (s *SpannerAdapter) PendingObjectExists(ctx context.Context, opts BeginSegment) (exists bool, err error)

+ func (s *SpannerAdapter) TestingGetAllObjects(ctx context.Context) (_ []RawObject, err error)

+ func (s *SpannerAdapter) WithTx(ctx context.Context, f func(context.Context, TransactionAdapter) error) error

type SpannerTestDatabase

+ func NewSpannerTestDatabase(ctx context.Context, logger *zap.Logger, spannerConnection string, ...) (SpannerTestDatabase, error)

+ func (d SpannerTestDatabase) Connection() string

+ type TransactionAdapter interface

Apr 30, 2024

Changes in this version

+ func SpannerTestModule(ball *mud.Ball, spannerConnection string)

type Adapter

+ EnsureNodeAliases func(ctx context.Context, opts EnsureNodeAliases) error

+ IterateLoopSegments func(ctx context.Context, aliasCache *NodeAliasCache, opts IterateLoopSegments, ...) error

+ ListNodeAliases func(ctx context.Context) (_ []NodeAliasEntry, err error)

+ TestingDeleteAll func(ctx context.Context) (err error)

+ TestingGetAllSegments func(ctx context.Context, aliasCache *NodeAliasCache) (_ []RawSegment, err error)

type AliasPieces

+ func (aliases *AliasPieces) DecodeSpanner(val any) (err error)

+ func (aliases AliasPieces) EncodeSpanner() (any, error)

type PostgresAdapter

+ func (p *PostgresAdapter) EnsureNodeAliases(ctx context.Context, opts EnsureNodeAliases) (err error)

+ func (p *PostgresAdapter) IterateLoopSegments(ctx context.Context, aliasCache *NodeAliasCache, opts IterateLoopSegments, ...) (err error)

+ func (p *PostgresAdapter) ListNodeAliases(ctx context.Context) (_ []NodeAliasEntry, err error)

+ func (p *PostgresAdapter) TestingDeleteAll(ctx context.Context) (err error)

+ func (p *PostgresAdapter) TestingGetAllSegments(ctx context.Context, aliasCache *NodeAliasCache) (_ []RawSegment, err error)

type SegmentPosition

+ func (pos *SegmentPosition) DecodeSpanner(val any) (err error)

+ func (pos SegmentPosition) EncodeSpanner() (any, error)

+ type SpannerAdapter struct

+ func NewSpannerAdapter(ctx context.Context, cfg SpannerConfig) (*SpannerAdapter, error)

+ func (s *SpannerAdapter) BeginObjectNextVersion(ctx context.Context, opts BeginObjectNextVersion, object *Object) error

+ func (s *SpannerAdapter) Close() error

+ func (s *SpannerAdapter) EnsureNodeAliases(ctx context.Context, opts EnsureNodeAliases) (err error)

+ func (s *SpannerAdapter) GetObjectLastCommitted(ctx context.Context, opts GetObjectLastCommitted, object *Object) error

+ func (s *SpannerAdapter) IterateLoopSegments(ctx context.Context, aliasCache *NodeAliasCache, opts IterateLoopSegments, ...) (err error)

+ func (s *SpannerAdapter) ListNodeAliases(ctx context.Context) (aliases []NodeAliasEntry, err error)

+ func (s *SpannerAdapter) TestingBatchInsertSegments(ctx context.Context, aliasCache *NodeAliasCache, segments []RawSegment) (err error)

+ func (s *SpannerAdapter) TestingBeginObjectExactVersion(ctx context.Context, opts BeginObjectExactVersion, object *Object) error

+ func (s *SpannerAdapter) TestingDeleteAll(ctx context.Context) (err error)

+ func (s *SpannerAdapter) TestingGetAllSegments(ctx context.Context, aliasCache *NodeAliasCache) (segments []RawSegment, err error)

+ type SpannerConfig struct

+ Database string

+ func NewTestSpannerConfig(database SpannerTestDatabase) SpannerConfig

+ type SpannerTestDatabase struct

+ Database string

+ func NewTestDatabase(ctx context.Context, logger *zap.Logger, spannerConnection string) (SpannerTestDatabase, error)

+ func (d SpannerTestDatabase) Close(ctx context.Context) error

Apr 15, 2024

Changes in this version

+ const DelimiterNext

+ type Adapter interface

+ BeginObjectNextVersion func(context.Context, BeginObjectNextVersion, *Object) error

+ GetObjectLastCommitted func(ctx context.Context, opts GetObjectLastCommitted, object *Object) error

+ TestingBatchInsertSegments func(ctx context.Context, segments []RawSegment) (err error)

+ TestingBeginObjectExactVersion func(ctx context.Context, opts BeginObjectExactVersion, object *Object) error

+ type CockroachAdapter struct

type Config

+ UseListObjectsIterator bool

type DB

+ func (db *DB) ChooseAdapter(projectID uuid.UUID) Adapter

+ func (db *DB) ListObjectsWithIterator(ctx context.Context, opts ListObjects) (result ListObjectsResult, err error)

+ func (db *DB) TestingBatchInsertSegments(ctx context.Context, segments []RawSegment) (err error)

+ type PostgresAdapter struct

+ func (p *PostgresAdapter) BeginObjectNextVersion(ctx context.Context, opts BeginObjectNextVersion, object *Object) error

+ func (p *PostgresAdapter) GetObjectLastCommitted(ctx context.Context, opts GetObjectLastCommitted, object *Object) error

+ func (p *PostgresAdapter) TestingBatchInsertSegments(ctx context.Context, segments []RawSegment) (err error)

+ func (p *PostgresAdapter) TestingBeginObjectExactVersion(ctx context.Context, opts BeginObjectExactVersion, object *Object) error

Apr 1, 2024

Changes in this version

type ListObjects

+ func (opts *ListObjects) VersionAscending() bool

Mar 15, 2024

Changes in this version

type ObjectEntry

+ func (entry ObjectEntry) LessVersionAsc(other ObjectEntry) bool

type ObjectStream

+ func (obj ObjectStream) LessVersionAsc(b ObjectStream) bool

Feb 20, 2024

Changes in this version

type DB

+ func (db *DB) TestingBatchInsertObjects(ctx context.Context, objects []RawObject) (err error)

Jan 30, 2024

Changes in this version

type DB

+ func (db *DB) IterateObjectsAllVersionsWithStatusAscending(ctx context.Context, opts IterateObjectsWithStatus, ...) (err error)

Jan 19, 2024

Changes in this version

type ListObjects

+ AllVersions bool

type ObjectEntry

+ func (entry ObjectEntry) Less(other ObjectEntry) bool

type ObjectStatus

+ func (status ObjectStatus) String() string

Jan 5, 2024

Changes in this version

+ type IntSet struct

+ func CopyIntSet(destination IntSet, sources ...IntSet) IntSet

+ func NewIntSet(n int) IntSet

+ func (i *IntSet) Include(value int)

+ func (i *IntSet) Remove(value int)

+ func (i IntSet) Cap() int

+ func (i IntSet) Contains(value int) bool

+ func (i IntSet) Size() int

type Object

+ func (obj *Object) StreamVersionID() StreamVersionID

type ObjectEntry

+ func (entry ObjectEntry) StreamVersionID() StreamVersionID

+ type StreamVersionID uuid.UUID

+ func StreamVersionIDFromBytes(bytes []byte) (_ StreamVersionID, err error)

+ func (s StreamVersionID) Bytes() []byte

+ func (s StreamVersionID) StreamIDSuffix() []byte

+ func (s StreamVersionID) Version() Version

Dec 8, 2023

Changes in this version

type BeginSegment

+ ObjectExistsChecked bool

Nov 28, 2023

Changes in this version

+ var ErrMethodNotAllowed = errs.Class("method not allowed")

Nov 13, 2023

Changes in this version

+ const Prefix

type FinishCopyObject

+ func (finishCopy FinishCopyObject) NewLocation() ObjectLocation

type FinishMoveObject

+ func (finishMove FinishMoveObject) NewLocation() ObjectLocation

Oct 30, 2023

Changes in this version

+ const CommittedUnversioned

+ const CommittedVersioned

+ const DeleteMarkerUnversioned

+ const DeleteMarkerVersioned

type CommitObject

+ Versioned bool

type CommitObjectWithSegments

+ DisallowDelete bool

+ Versioned bool

type Config

+ TestingUniqueUnversioned bool

type DB

+ func (db *DB) UpdateObjectLastCommittedMetadata(ctx context.Context, opts UpdateObjectLastCommittedMetadata) (err error)

type DeleteObjectLastCommitted

+ Suspended bool

+ Versioned bool

type DeleteObjectResult

+ Markers []Object

+ Removed []Object

type FinishCopyObject

+ NewDisallowDelete bool

+ NewVersioned bool

type FinishMoveObject

+ NewDisallowDelete bool

+ NewVersioned bool

type IterateObjectsWithStatus

+ Pending bool

type ListObjects

+ Pending bool

type ListVerifySegments

+ CreatedAfter *time.Time

+ CreatedBefore *time.Time

type ObjectStatus

+ func (status ObjectStatus) IsDeleteMarker() bool

type ObjectStream

+ func (obj ObjectStream) Less(b ObjectStream) bool

+ type UpdateObjectLastCommittedMetadata struct

+ BucketName string

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ ObjectKey ObjectKey

+ ProjectID uuid.UUID

+ StreamID uuid.UUID

+ func (obj *UpdateObjectLastCommittedMetadata) Verify() error

type Version

+ func VersionFromBytes(bytes []byte) (Version, error)

+ func (v Version) Encode() []byte

Oct 16, 2023

Changes in this version

type DB

+ func (db *DB) TestingBeginObjectExactVersion(ctx context.Context, opts BeginObjectExactVersion) (committed Object, err error)

Sep 18, 2023

Changes in this version

+ const PendingVersion

+ var ErrFailedPrecondition = errs.Class("metabase: failed precondition")

type DB

+ func (db *DB) DeleteInactivePendingObjects(ctx context.Context, opts DeleteZombieObjects) (err error)

Sep 5, 2023

Changes in this version

type DB

+ func (db *DB) DeletePendingObjectNew(ctx context.Context, opts DeletePendingObject) (result DeleteObjectResult, err error)

+ func (db *DB) IteratePendingObjects(ctx context.Context, opts IteratePendingObjects, ...) (err error)

+ func (db *DB) IteratePendingObjectsByKeyNew(ctx context.Context, opts IteratePendingObjectsByKey, ...) (err error)

+ type IteratePendingObjects struct

+ BatchSize int

+ BucketName string

+ Cursor PendingObjectsCursor

+ IncludeCustomMetadata bool

+ IncludeSystemMetadata bool

+ Prefix ObjectKey

+ ProjectID uuid.UUID

+ Recursive bool

+ func (opts *IteratePendingObjects) Verify() error

+ type PendingObject RawPendingObject

+ type PendingObjectEntry struct

+ CreatedAt time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ Encryption storj.EncryptionParameters

+ ExpiresAt *time.Time

+ IsPrefix bool

+ ObjectKey ObjectKey

+ StreamID uuid.UUID

+ type PendingObjectsCursor struct

+ Key ObjectKey

+ StreamID uuid.UUID

+ type PendingObjectsIterator interface

+ Next func(ctx context.Context, item *PendingObjectEntry) bool

Aug 18, 2023

Changes in this version

type CommitInlineSegment

+ UsePendingObjectsTable bool

type CommitObject

+ UsePendingObjectsTable bool

type CommitSegment

+ UsePendingObjectsTable bool

Aug 7, 2023

Changes in this version

type BeginObjectNextVersion

+ UsePendingObjectsTable bool

type BeginSegment

+ UsePendingObjectsTable bool

+ type PendingObjectStream struct

+ BucketName string

+ ObjectKey ObjectKey

+ ProjectID uuid.UUID

+ StreamID uuid.UUID

+ func (obj *PendingObjectStream) Verify() error

+ type RawPendingObject struct

+ CreatedAt time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ Encryption storj.EncryptionParameters

+ ExpiresAt *time.Time

+ ZombieDeletionDeadline *time.Time

type RawState

+ PendingObjects []RawPendingObject

Jul 24, 2023

Changes in this version

type FinishCopyObject

+ DuplicateMetadata bool

Jun 26, 2023

Changes in this version

type BucketTally

+ PendingObjectCount int64

type DeleteExpiredObjects

+ AsOfSystemInterval time.Duration

type DeleteZombieObjects

+ AsOfSystemInterval time.Duration

May 2, 2023

Changes in this version

+ var ErrObjectNotFound = errs.Class("metabase: object not found")

Apr 18, 2023

Changes in this version

+ var ErrValueChanged = errs.Class("value changed")

type ListSegments

+ Range *StreamRange

+ UpdateFirstWithAncestor bool

Mar 6, 2023

Changes in this version

type LoopSegmentEntry

+ AliasPieces AliasPieces

type Segment

+ func (s Segment) PieceSize() int64

Feb 24, 2023

Changes in this version

+ const MaxVersion

Jan 10, 2023

Changes in this version

type DB

+ func (db *DB) ListBucketsStreamIDs(ctx context.Context, opts ListBucketsStreamIDs) (ListBucketsStreamIDsResult, error)

+ type ListBucketsStreamIDs struct

+ AsOfSystemInterval time.Duration

+ AsOfSystemTime time.Time

+ BucketList ListVerifyBucketList

+ CursorBucket BucketLocation

+ CursorStreamID uuid.UUID

+ Limit int

+ type ListBucketsStreamIDsResult struct

+ Counts []int

+ LastBucket BucketLocation

+ StreamIDs []uuid.UUID

+ type ListVerifyBucketList struct

+ Buckets []BucketLocation

+ func (list *ListVerifyBucketList) Add(projectID uuid.UUID, bucketName string)

type ListVerifySegments

+ StreamIDs []uuid.UUID

type NodeAliasMap

+ func (m *NodeAliasMap) Max() NodeAlias

Nov 29, 2022

Changes in this version

type CollectBucketTallies

+ Now time.Time

Nov 14, 2022

Changes in this version

type Pieces

+ func (p Pieces) FindByNum(pieceNum int) (_ Piece, found bool)

Oct 31, 2022

Changes in this version

+ var ErrPermissionDenied = errs.Class("permission denied")

+ type BucketTally struct

+ MetadataSize int64

+ ObjectCount int64

+ TotalBytes int64

+ TotalSegments int64

+ type CollectBucketTallies struct

+ AsOfSystemInterval time.Duration

+ AsOfSystemTime time.Time

+ From BucketLocation

+ To BucketLocation

+ func (opts *CollectBucketTallies) Verify() error

type CommitObject

+ DisallowDelete bool

+ OnDelete func(segments []DeletedSegmentInfo)

type DB

+ func (db *DB) CollectBucketTallies(ctx context.Context, opts CollectBucketTallies) (result []BucketTally, err error)

+ func (db *DB) LatestNodesAliasMap(ctx context.Context) (_ *NodeAliasMap, err error)

type IterateLoopSegments

+ EndStreamID uuid.UUID

+ StartStreamID uuid.UUID

type NodeAliasCache

+ func (cache *NodeAliasCache) Latest(ctx context.Context) (_ *NodeAliasMap, err error)

type NodeAliasMap

+ func (m *NodeAliasMap) Alias(node storj.NodeID) (x NodeAlias, ok bool)

Sep 30, 2022

Changes in this version

+ const ListVerifyLimit

+ type BeginMoveCopyResults struct

+ EncryptedKeysNonces []EncryptedKeyAndNonce

+ EncryptedMetadata []byte

+ EncryptedMetadataKey []byte

+ EncryptedMetadataKeyNonce []byte

+ EncryptionParameters storj.EncryptionParameters

+ StreamID uuid.UUID

+ Version Version

type Config

+ MultipleVersions bool

type DB

+ func (db *DB) ConvertAliasesToNodes(ctx context.Context, aliases []NodeAlias) (_ []storj.NodeID, err error)

+ func (db *DB) ConvertNodesToAliases(ctx context.Context, nodeIDs []storj.NodeID) (_ []NodeAlias, err error)

+ func (db *DB) ListObjects(ctx context.Context, opts ListObjects) (result ListObjectsResult, err error)

+ func (db *DB) TestingEnableMultipleVersions(enabled bool)

+ type ListObjects struct

+ BucketName string

+ Cursor ListObjectsCursor

+ IncludeCustomMetadata bool

+ IncludeSystemMetadata bool

+ Limit int

+ Prefix ObjectKey

+ ProjectID uuid.UUID

+ Recursive bool

+ Status ObjectStatus

+ func (opts *ListObjects) Verify() error

+ type ListObjectsCursor struct

+ Key ObjectKey

+ Version Version

+ type ListObjectsResult struct

+ More bool

+ Objects []ObjectEntry

type NodeAliasCache

+ func (cache *NodeAliasCache) EnsureAliases(ctx context.Context, nodes []storj.NodeID) ([]NodeAlias, error)

+ func (cache *NodeAliasCache) EnsurePiecesToAliases(ctx context.Context, pieces Pieces) (_ AliasPieces, err error)

Sep 19, 2022

Changes in this version

type DB

+ func (db *DB) ListVerifySegments(ctx context.Context, opts ListVerifySegments) (result ListVerifySegmentsResult, err error)

+ type ListVerifySegments struct

+ AsOfSystemInterval time.Duration

+ AsOfSystemTime time.Time

+ CursorPosition SegmentPosition

+ CursorStreamID uuid.UUID

+ Limit int

+ type ListVerifySegmentsResult struct

+ Segments []VerifySegment

+ type VerifySegment struct

+ AliasPieces AliasPieces

+ CreatedAt time.Time

+ Position SegmentPosition

+ Redundancy storj.RedundancyScheme

+ RepairedAt *time.Time

+ RootPieceID storj.PieceID

+ StreamID uuid.UUID

Sep 1, 2022

Changes in this version

type BeginCopyObjectResult

+ Version Version

type BeginMoveObjectResult

+ Version Version

type DB

+ func (db *DB) DeleteObjectLastCommitted(ctx context.Context, opts DeleteObjectLastCommitted) (result DeleteObjectResult, err error)

+ type DeleteObjectLastCommitted struct

+ func (obj *DeleteObjectLastCommitted) Verify() error

type UpdateObjectMetadata

+ BucketName string

+ ObjectKey ObjectKey

+ ProjectID uuid.UUID

+ StreamID uuid.UUID

+ func (obj *UpdateObjectMetadata) Verify() error

Aug 22, 2022

Changes in this version

type DB

+ func (db *DB) GetObjectLastCommitted(ctx context.Context, opts GetObjectLastCommitted) (_ Object, err error)

+ type GetObjectLastCommitted struct

Aug 8, 2022

Changes in this version

type BeginCopyObject

+ VerifyLimits func(encryptedObjectSize int64, nSegments int64) error

type FinishCopyObject

+ VerifyLimits func(encryptedObjectSize int64, nSegments int64) error

Jul 13, 2022

Changes in this version

+ const MoveSegmentLimit

Jun 24, 2022

Changes in this version

type Config

+ ServerSideCopyDisabled bool

Jun 13, 2022

Changes in this version

type DB

+ func (db *DB) TestMigrateToLatest(ctx context.Context) error

May 13, 2022

Changes in this version

+ var ErrPendingObjectMissing = errs.Class("pending object missing")

May 3, 2022

Changes in this version

type CommitObject

+ OverrideEncryptedMetadata bool

Mar 21, 2022

Changes in this version

type FinishCopyObject

+ NewEncryptedMetadata []byte

+ OverrideMetadata bool

Mar 8, 2022

Changes in this version

+ const CopySegmentLimit

+ type BeginCopyObject struct

+ Version Version

+ type BeginCopyObjectResult struct

+ EncryptedKeysNonces []EncryptedKeyAndNonce

+ EncryptedMetadata []byte

+ EncryptedMetadataKey []byte

+ EncryptedMetadataKeyNonce []byte

+ EncryptionParameters storj.EncryptionParameters

+ StreamID uuid.UUID

type Config

+ ServerSideCopy bool

type DB

+ func (db *DB) BeginCopyObject(ctx context.Context, opts BeginCopyObject) (result BeginCopyObjectResult, err error)

+ func (db *DB) FinishCopyObject(ctx context.Context, opts FinishCopyObject) (object Object, err error)

+ type FinishCopyObject struct

+ NewBucket string

+ NewEncryptedMetadataKey []byte

+ NewEncryptedMetadataKeyNonce []byte

+ NewEncryptedObjectKey []byte

+ NewSegmentKeys []EncryptedKeyAndNonce

+ NewStreamID uuid.UUID

+ func (finishCopy FinishCopyObject) Verify() error

+ type RawCopy struct

+ AncestorStreamID uuid.UUID

+ StreamID uuid.UUID

type RawState

+ Copies []RawCopy

type Segment

+ func (s Segment) PiecesInAncestorSegment() bool

Feb 21, 2022

Changes in this version

type Config

+ ApplicationName string

Feb 7, 2022

Changes in this version

+ var ErrObjectAlreadyExists = errs.Class("object already exists")

Dec 13, 2021

Changes in this version

type DB

+ func (db *DB) GetProjectSegmentCount(ctx context.Context, opts GetProjectSegmentCount) (_ int64, err error)

+ type GetProjectSegmentCount struct

+ AsOfSystemInterval time.Duration

+ AsOfSystemTime time.Time

+ ProjectID uuid.UUID

+ func (g *GetProjectSegmentCount) Verify() error

Nov 29, 2021

Changes in this version

type CommitSegment

+ Placement storj.PlacementConstraint

type LoopSegmentEntry

+ Placement storj.PlacementConstraint

type RawSegment

+ Placement storj.PlacementConstraint

Nov 16, 2021

Changes in this version

type BeginObjectExactVersion

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ func (opts *BeginObjectExactVersion) Verify() error

type BeginObjectNextVersion

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ func (opts *BeginObjectNextVersion) Verify() error

type CommitObject

+ func (c *CommitObject) Verify() error

type IterateObjectsWithStatus

+ IncludeCustomMetadata bool

+ IncludeSystemMetadata bool

Nov 3, 2021

Changes in this version

+ type Config struct

+ MaxNumberOfParts int

+ MinPartSize memory.Size

Oct 15, 2021

Changes in this version

type ObjectKey

+ func (o *ObjectKey) Scan(value interface{}) error

+ func (o ObjectKey) Value() (driver.Value, error)

Oct 5, 2021

Changes in this version

type DB

+ func (db *DB) FinishMoveObject(ctx context.Context, opts FinishMoveObject) (err error)

+ type FinishMoveObject struct

+ NewBucket string

+ NewEncryptedMetadataKey []byte

+ NewEncryptedMetadataKeyNonce []byte

+ NewEncryptedObjectKey []byte

+ NewSegmentKeys []EncryptedKeyAndNonce

+ func (finishMove FinishMoveObject) Verify() error

Sep 23, 2021

Changes in this version

+ const DefaultVersion

+ const MoveLimit

+ type BeginMoveObject struct

+ Version Version

+ type BeginMoveObjectResult struct

+ EncryptedKeysNonces []EncryptedKeyAndNonce

+ EncryptedMetadata []byte

+ EncryptedMetadataKey []byte

+ EncryptedMetadataKeyNonce []byte

+ EncryptionParameters storj.EncryptionParameters

+ StreamID uuid.UUID

type DB

+ func (db *DB) BeginMoveObject(ctx context.Context, opts BeginMoveObject) (result BeginMoveObjectResult, err error)

type DeleteZombieObjects

+ InactiveDeadline time.Time

+ type EncryptedKeyAndNonce struct

+ EncryptedKey []byte

+ EncryptedKeyNonce []byte

+ Position SegmentPosition

Aug 9, 2021

Changes in this version

type IterateObjectsWithStatus

+ IncludeMetadata bool

type Pieces

+ func (p Pieces) Add(piecesToAdd Pieces) (Pieces, error)

+ func (p Pieces) Remove(piecesToRemove Pieces) (Pieces, error)

+ func (p Pieces) Update(piecesToAdd, piecesToRemove Pieces) (Pieces, error)

Jul 26, 2021

Changes in this version

+ const ListLimit

Jul 9, 2021

Changes in this version

type DeleteBucketObjects

+ DeletePiecesBatchSize int

type LoopObjectEntry

+ TotalEncryptedSize int64

+ func (o LoopObjectEntry) Expired(now time.Time) bool

type Segment

+ func (s Segment) Expired(now time.Time) bool

Jun 22, 2021

Changes in this version

type DB

+ func (db *DB) GetTableStats(ctx context.Context, opts GetTableStats) (result TableStats, err error)

+ func (db *DB) Implementation() dbutil.Implementation

+ type GetTableStats struct

+ AsOfSystemInterval time.Duration

type LoopSegmentEntry

+ ExpiresAt *time.Time

+ type TableStats struct

+ ObjectCount int64

+ SegmentCount int64

Jun 14, 2021

Changes in this version

type CommitInlineSegment

+ ExpiresAt *time.Time

type CommitSegment

+ ExpiresAt *time.Time

type IterateLoopSegments

+ AsOfSystemInterval time.Duration

type RawSegment

+ ExpiresAt *time.Time

Jun 8, 2021

Changes in this version

type IterateLoopObjects

+ AsOfSystemInterval time.Duration

type IterateLoopStreams

+ AsOfSystemInterval time.Duration

May 31, 2021

Changes in this version

type DB

+ func (db *DB) IterateLoopSegments(ctx context.Context, opts IterateLoopSegments, ...) (err error)

+ func (db *DB) TestingSetCleanup(cleanup func() error)

+ type IterateLoopSegments struct

+ AsOfSystemTime time.Time

+ BatchSize int

+ func (opts *IterateLoopSegments) Verify() error

+ type LoopSegmentsIterator interface

+ Next func(ctx context.Context, item *LoopSegmentEntry) bool

May 18, 2021

Changes in this version

type DB

+ func (db *DB) DeletePart(ctx context.Context, opts DeletePart) (err error)

+ func (db *DB) DeleteZombieObjects(ctx context.Context, opts DeleteZombieObjects) (err error)

+ func (db *DB) Now(ctx context.Context) (time.Time, error)

+ type DeletePart struct

+ DeletePieces func(ctx context.Context, segment DeletedSegmentInfo) error

+ PartNumber uint32

+ StreamID uuid.UUID

+ type DeleteZombieObjects struct

+ AsOfSystemTime time.Time

+ BatchSize int

+ DeadlineBefore time.Time

May 3, 2021

Changes in this version

type LoopObjectEntry

+ Status ObjectStatus

type LoopSegmentEntry

+ PlainOffset int64

+ PlainSize int32

Apr 26, 2021

Changes in this version

+ const Committed

+ const Delimiter

+ const LastSegmentIndex

+ const LastSegmentName

+ const MaxListLimit

+ const NextVersion

+ const Pending

+ var ErrConflict = errs.Class("metabase: conflict")

+ var ErrInvalidRequest = errs.Class("metabase: invalid request")

+ var ErrSegmentNotFound = errs.Class("segment not found")

+ var Error = errs.Class("metabase")

+ func EqualAliasPieces(xs, ys AliasPieces) bool

+ type AliasPiece struct

+ Alias NodeAlias

+ Number uint16

+ type AliasPieces []AliasPiece

+ func (aliases *AliasPieces) Scan(src interface{}) error

+ func (aliases *AliasPieces) SetBytes(data []byte) error

+ func (aliases AliasPieces) Bytes() ([]byte, error)

+ func (aliases AliasPieces) Value() (driver.Value, error)

+ type BeginObjectExactVersion struct

+ Encryption storj.EncryptionParameters

+ ExpiresAt *time.Time

+ ZombieDeletionDeadline *time.Time

+ type BeginObjectNextVersion struct

+ Encryption storj.EncryptionParameters

+ ExpiresAt *time.Time

+ ZombieDeletionDeadline *time.Time

+ type BeginSegment struct

+ Pieces Pieces

+ Position SegmentPosition

+ RootPieceID storj.PieceID

+ type BucketEmpty struct

+ BucketName string

+ ProjectID uuid.UUID

+ type BucketLocation struct

+ BucketName string

+ ProjectID uuid.UUID

+ func ParseBucketPrefix(prefix BucketPrefix) (BucketLocation, error)

+ func ParseCompactBucketPrefix(compactPrefix []byte) (BucketLocation, error)

+ func (loc BucketLocation) CompactPrefix() []byte

+ func (loc BucketLocation) Prefix() BucketPrefix

+ func (loc BucketLocation) Verify() error

+ type BucketPrefix string

+ type CommitInlineSegment struct

+ EncryptedETag []byte

+ EncryptedKey []byte

+ EncryptedKeyNonce []byte

+ InlineData []byte

+ PlainOffset int64

+ PlainSize int32

+ Position SegmentPosition

+ type CommitObject struct

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ Encryption storj.EncryptionParameters

+ type CommitObjectWithSegments struct

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ Segments []SegmentPosition

+ type CommitSegment struct

+ EncryptedETag []byte

+ EncryptedKey []byte

+ EncryptedKeyNonce []byte

+ EncryptedSize int32

+ Pieces Pieces

+ PlainOffset int64

+ PlainSize int32

+ Position SegmentPosition

+ Redundancy storj.RedundancyScheme

+ RootPieceID storj.PieceID

+ type DB struct

+ func Open(ctx context.Context, log *zap.Logger, driverName, connstr string) (*DB, error)

+ func (db *DB) BeginObjectExactVersion(ctx context.Context, opts BeginObjectExactVersion) (committed Object, err error)

+ func (db *DB) BeginObjectNextVersion(ctx context.Context, opts BeginObjectNextVersion) (committed Version, err error)

+ func (db *DB) BeginSegment(ctx context.Context, opts BeginSegment) (err error)

+ func (db *DB) BucketEmpty(ctx context.Context, opts BucketEmpty) (empty bool, err error)

+ func (db *DB) CheckVersion(ctx context.Context) error

+ func (db *DB) Close() error

+ func (db *DB) CommitInlineSegment(ctx context.Context, opts CommitInlineSegment) (err error)

+ func (db *DB) CommitObject(ctx context.Context, opts CommitObject) (object Object, err error)

+ func (db *DB) CommitObjectWithSegments(ctx context.Context, opts CommitObjectWithSegments) (object Object, deletedSegments []DeletedSegmentInfo, err error)

+ func (db *DB) CommitSegment(ctx context.Context, opts CommitSegment) (err error)

+ func (db *DB) DeleteBucketObjects(ctx context.Context, opts DeleteBucketObjects) (deletedObjectCount int64, err error)

+ func (db *DB) DeleteExpiredObjects(ctx context.Context, opts DeleteExpiredObjects) (err error)

+ func (db *DB) DeleteObjectAnyStatusAllVersions(ctx context.Context, opts DeleteObjectAnyStatusAllVersions) (result DeleteObjectResult, err error)

+ func (db *DB) DeleteObjectExactVersion(ctx context.Context, opts DeleteObjectExactVersion) (result DeleteObjectResult, err error)

+ func (db *DB) DeleteObjectLatestVersion(ctx context.Context, opts DeleteObjectLatestVersion) (result DeleteObjectResult, err error)

+ func (db *DB) DeleteObjectsAllVersions(ctx context.Context, opts DeleteObjectsAllVersions) (result DeleteObjectResult, err error)

+ func (db *DB) DeletePendingObject(ctx context.Context, opts DeletePendingObject) (result DeleteObjectResult, err error)

+ func (db *DB) DestroyTables(ctx context.Context) error

+ func (db *DB) EnsureNodeAliases(ctx context.Context, opts EnsureNodeAliases) (err error)

+ func (db *DB) GetLatestObjectLastSegment(ctx context.Context, opts GetLatestObjectLastSegment) (segment Segment, err error)

+ func (db *DB) GetObjectExactVersion(ctx context.Context, opts GetObjectExactVersion) (_ Object, err error)

+ func (db *DB) GetObjectLatestVersion(ctx context.Context, opts GetObjectLatestVersion) (_ Object, err error)

+ func (db *DB) GetSegmentByLocation(ctx context.Context, opts GetSegmentByLocation) (segment Segment, err error)

+ func (db *DB) GetSegmentByOffset(ctx context.Context, opts GetSegmentByOffset) (segment Segment, err error)

+ func (db *DB) GetSegmentByPosition(ctx context.Context, opts GetSegmentByPosition) (segment Segment, err error)

+ func (db *DB) GetStreamPieceCountByNodeID(ctx context.Context, opts GetStreamPieceCountByNodeID) (result map[storj.NodeID]int64, err error)

+ func (db *DB) InternalImplementation() interface{}

+ func (db *DB) IterateLoopObjects(ctx context.Context, opts IterateLoopObjects, ...) (err error)

+ func (db *DB) IterateLoopStreams(ctx context.Context, opts IterateLoopStreams, ...) (err error)

+ func (db *DB) IterateObjectsAllVersions(ctx context.Context, opts IterateObjects, ...) (err error)

+ func (db *DB) IterateObjectsAllVersionsWithStatus(ctx context.Context, opts IterateObjectsWithStatus, ...) (err error)

+ func (db *DB) IteratePendingObjectsByKey(ctx context.Context, opts IteratePendingObjectsByKey, ...) (err error)

+ func (db *DB) ListNodeAliases(ctx context.Context) (_ []NodeAliasEntry, err error)

+ func (db *DB) ListSegments(ctx context.Context, opts ListSegments) (result ListSegmentsResult, err error)

+ func (db *DB) ListStreamPositions(ctx context.Context, opts ListStreamPositions) (result ListStreamPositionsResult, err error)

+ func (db *DB) MigrateToLatest(ctx context.Context) error

+ func (db *DB) Ping(ctx context.Context) error

+ func (db *DB) PostgresMigration() *migrate.Migration

+ func (db *DB) TestingAllCommittedObjects(ctx context.Context, projectID uuid.UUID, bucketName string) (objects []ObjectEntry, err error)

+ func (db *DB) TestingAllObjectSegments(ctx context.Context, objectLocation ObjectLocation) (segments []Segment, err error)

+ func (db *DB) TestingAllObjects(ctx context.Context) (objects []Object, err error)

+ func (db *DB) TestingAllPendingObjects(ctx context.Context, projectID uuid.UUID, bucketName string) (objects []ObjectEntry, err error)

+ func (db *DB) TestingAllSegments(ctx context.Context) (segments []Segment, err error)

+ func (db *DB) TestingDeleteAll(ctx context.Context) (err error)

+ func (db *DB) TestingGetState(ctx context.Context) (_ *RawState, err error)

+ func (db *DB) UnderlyingTagSQL() tagsql.DB

+ func (db *DB) UpdateObjectMetadata(ctx context.Context, opts UpdateObjectMetadata) (err error)

+ func (db *DB) UpdateSegmentPieces(ctx context.Context, opts UpdateSegmentPieces) (err error)

+ type DeleteBucketObjects struct

+ BatchSize int

+ Bucket BucketLocation

+ DeletePieces func(ctx context.Context, segments []DeletedSegmentInfo) error

+ type DeleteExpiredObjects struct

+ AsOfSystemTime time.Time

+ BatchSize int

+ ExpiredBefore time.Time

+ type DeleteObjectAnyStatusAllVersions struct

+ type DeleteObjectExactVersion struct

+ Version Version

+ func (obj *DeleteObjectExactVersion) Verify() error

+ type DeleteObjectLatestVersion struct

+ type DeleteObjectResult struct

+ Objects []Object

+ Segments []DeletedSegmentInfo

+ type DeleteObjectsAllVersions struct

+ Locations []ObjectLocation

+ func (delete *DeleteObjectsAllVersions) Verify() error

+ type DeletePendingObject struct

+ StreamID uuid.UUID

+ func (opts *DeletePendingObject) Verify() error

+ type DeletedSegmentInfo struct

+ Pieces Pieces

+ RootPieceID storj.PieceID

+ type EnsureNodeAliases struct

+ Nodes []storj.NodeID

+ type GetLatestObjectLastSegment struct

+ type GetObjectExactVersion struct

+ Version Version

+ func (obj *GetObjectExactVersion) Verify() error

+ type GetObjectLatestVersion struct

+ type GetSegmentByLocation struct

+ type GetSegmentByOffset struct

+ PlainOffset int64

+ type GetSegmentByPosition struct

+ Position SegmentPosition

+ StreamID uuid.UUID

+ func (seg *GetSegmentByPosition) Verify() error

+ type GetStreamPieceCountByNodeID struct

+ StreamID uuid.UUID

+ type IterateCursor struct

+ Key ObjectKey

+ Version Version

+ type IterateLoopObjects struct

+ AsOfSystemTime time.Time

+ BatchSize int

+ func (opts *IterateLoopObjects) Verify() error

+ type IterateLoopStreams struct

+ AsOfSystemTime time.Time

+ StreamIDs []uuid.UUID

+ type IterateObjects struct

+ BatchSize int

+ BucketName string

+ Cursor IterateCursor

+ Prefix ObjectKey

+ ProjectID uuid.UUID

+ func (opts *IterateObjects) Verify() error

+ type IterateObjectsWithStatus struct

+ BatchSize int

+ BucketName string

+ Cursor IterateCursor

+ Prefix ObjectKey

+ ProjectID uuid.UUID

+ Recursive bool

+ Status ObjectStatus

+ func (opts *IterateObjectsWithStatus) Verify() error

+ type IteratePendingObjectsByKey struct

+ BatchSize int

+ Cursor StreamIDCursor

+ func (opts *IteratePendingObjectsByKey) Verify() error

+ type ListSegments struct

+ Cursor SegmentPosition

+ Limit int

+ StreamID uuid.UUID

+ type ListSegmentsResult struct

+ More bool

+ Segments []Segment

+ type ListStreamPositions struct

+ Cursor SegmentPosition

+ Limit int

+ Range *StreamRange

+ StreamID uuid.UUID

+ type ListStreamPositionsResult struct

+ More bool

+ Segments []SegmentPositionInfo

+ type LoopObjectEntry struct

+ CreatedAt time.Time

+ EncryptedMetadataSize int

+ ExpiresAt *time.Time

+ SegmentCount int32

+ type LoopObjectsIterator interface

+ Next func(ctx context.Context, item *LoopObjectEntry) bool

+ type LoopSegmentEntry struct

+ CreatedAt *time.Time

+ EncryptedSize int32

+ Pieces Pieces

+ Position SegmentPosition

+ Redundancy storj.RedundancyScheme

+ RepairedAt *time.Time

+ RootPieceID storj.PieceID

+ StreamID uuid.UUID

+ func (s LoopSegmentEntry) Inline() bool

+ type NodeAlias int32

+ type NodeAliasCache struct

+ func NewNodeAliasCache(db NodeAliasDB) *NodeAliasCache

+ func (cache *NodeAliasCache) Aliases(ctx context.Context, nodes []storj.NodeID) ([]NodeAlias, error)

+ func (cache *NodeAliasCache) ConvertAliasesToPieces(ctx context.Context, aliasPieces AliasPieces) (_ Pieces, err error)

+ func (cache *NodeAliasCache) ConvertPiecesToAliases(ctx context.Context, pieces Pieces) (_ AliasPieces, err error)

+ func (cache *NodeAliasCache) Nodes(ctx context.Context, aliases []NodeAlias) ([]storj.NodeID, error)

+ type NodeAliasDB interface

+ EnsureNodeAliases func(ctx context.Context, opts EnsureNodeAliases) error

+ ListNodeAliases func(ctx context.Context) (_ []NodeAliasEntry, err error)

+ type NodeAliasEntry struct

+ Alias NodeAlias

+ ID storj.NodeID

+ type NodeAliasMap struct

+ func NewNodeAliasMap(entries []NodeAliasEntry) *NodeAliasMap

+ func (m *NodeAliasMap) Aliases(nodes []storj.NodeID) (xs []NodeAlias, missing []storj.NodeID)

+ func (m *NodeAliasMap) ContainsAll(nodeIDs []storj.NodeID, nodeAliases []NodeAlias) bool

+ func (m *NodeAliasMap) Merge(other *NodeAliasMap)

+ func (m *NodeAliasMap) Node(alias NodeAlias) (x storj.NodeID, ok bool)

+ func (m *NodeAliasMap) Nodes(aliases []NodeAlias) (xs []storj.NodeID, missing []NodeAlias)

+ func (m *NodeAliasMap) Size() int

+ type Object RawObject

+ func (obj *Object) IsMigrated() bool

+ type ObjectEntry struct

+ CreatedAt time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ Encryption storj.EncryptionParameters

+ ExpiresAt *time.Time

+ FixedSegmentSize int32

+ IsPrefix bool

+ ObjectKey ObjectKey

+ SegmentCount int32

+ Status ObjectStatus

+ StreamID uuid.UUID

+ TotalEncryptedSize int64

+ TotalPlainSize int64

+ Version Version

+ ZombieDeletionDeadline *time.Time

+ type ObjectKey string

+ type ObjectLocation struct

+ BucketName string

+ ObjectKey ObjectKey

+ ProjectID uuid.UUID

+ func (obj ObjectLocation) Bucket() BucketLocation

+ func (obj ObjectLocation) Verify() error

+ type ObjectStatus byte

+ type ObjectStream struct

+ BucketName string

+ ObjectKey ObjectKey

+ ProjectID uuid.UUID

+ StreamID uuid.UUID

+ Version Version

+ func (obj *ObjectStream) Location() ObjectLocation

+ func (obj *ObjectStream) Verify() error

+ type ObjectsIterator interface

+ Next func(ctx context.Context, item *ObjectEntry) bool

+ type Piece struct

+ Number uint16

+ StorageNode storj.NodeID

+ type Pieces []Piece

+ func (p Pieces) Equal(pieces Pieces) bool

+ func (p Pieces) Len() int

+ func (p Pieces) Less(i, j int) bool

+ func (p Pieces) Swap(i, j int)

+ func (p Pieces) Verify() error

+ func (pieces *Pieces) Scan(value interface{}) error

+ func (pieces Pieces) Value() (driver.Value, error)

+ type RawObject struct

+ CreatedAt time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ Encryption storj.EncryptionParameters

+ ExpiresAt *time.Time

+ FixedSegmentSize int32

+ SegmentCount int32

+ Status ObjectStatus

+ TotalEncryptedSize int64

+ TotalPlainSize int64

+ ZombieDeletionDeadline *time.Time

+ type RawSegment struct

+ CreatedAt *time.Time

+ EncryptedETag []byte

+ EncryptedKey []byte

+ EncryptedKeyNonce []byte

+ EncryptedSize int32

+ InlineData []byte

+ Pieces Pieces

+ PlainOffset int64

+ PlainSize int32

+ Position SegmentPosition

+ Redundancy storj.RedundancyScheme

+ RepairedAt *time.Time

+ RootPieceID storj.PieceID

+ StreamID uuid.UUID

+ type RawState struct

+ Objects []RawObject

+ Segments []RawSegment

+ type Segment RawSegment

+ func (s Segment) Inline() bool

+ type SegmentIterator func(segment *LoopSegmentEntry) bool

+ type SegmentKey []byte

+ type SegmentLocation struct

+ BucketName string

+ ObjectKey ObjectKey

+ Position SegmentPosition

+ ProjectID uuid.UUID

+ func ParseSegmentKey(encoded SegmentKey) (SegmentLocation, error)

+ func (seg SegmentLocation) Bucket() BucketLocation

+ func (seg SegmentLocation) Encode() SegmentKey

+ func (seg SegmentLocation) Object() ObjectLocation

+ func (seg SegmentLocation) Verify() error

+ type SegmentPosition struct

+ Index uint32

+ Part uint32

+ func SegmentPositionFromEncoded(v uint64) SegmentPosition

+ func (params *SegmentPosition) Scan(value interface{}) error

+ func (params SegmentPosition) Value() (driver.Value, error)

+ func (pos SegmentPosition) Encode() uint64

+ func (pos SegmentPosition) Less(b SegmentPosition) bool

+ type SegmentPositionInfo struct

+ CreatedAt *time.Time

+ EncryptedETag []byte

+ EncryptedKey []byte

+ EncryptedKeyNonce []byte

+ PlainOffset int64

+ PlainSize int32

+ Position SegmentPosition

+ type StreamIDCursor struct

+ StreamID uuid.UUID

+ type StreamRange struct

+ PlainLimit int64

+ PlainStart int64

+ type UpdateObjectMetadata struct

+ EncryptedMetadata []byte

+ EncryptedMetadataEncryptedKey []byte

+ EncryptedMetadataNonce []byte

+ type UpdateSegmentPieces struct

+ NewPieces Pieces

+ NewRedundancy storj.RedundancyScheme

+ NewRepairedAt time.Time

+ OldPieces Pieces

+ Position SegmentPosition

+ StreamID uuid.UUID

+ type Version int64