objectdeletion

Aug 24, 2020

Changes in this version

type Config

+ MaxConcurrentRequests int

type Report

+ func (r Report) DeletedObjects() ([]*pb.Object, error)

+ func (r Report) DeletedPointers() []*pb.Pointer

Aug 10, 2020

Changes in this version

type Service

+ func (service *Service) Delete(ctx context.Context, requests ...*ObjectIdentifier) (pointers []*pb.Pointer, paths [][]byte, err error)

Jul 24, 2020

Changes in this version

+ const ObjectActiveOrZombie

+ const ObjectMissing

+ const ObjectMultiSegment

+ const ObjectSingleSegment

+ var Error = errs.Class("object deletion")

+ func CreateObjectStates(ctx context.Context, requests []*ObjectIdentifier, pointers []*pb.Pointer, ...) (map[string]*ObjectState, error)

+ func GroupPiecesByNodeID(pointers []*pb.Pointer) map[storj.NodeID][]storj.PieceID

+ type Config struct

+ MaxObjectsPerRequest int

+ ZombieSegmentsPerRequest int

+ func (config *Config) Verify() errs.Group

+ type ObjectIdentifier struct

+ Bucket []byte

+ EncryptedPath []byte

+ ProjectID uuid.UUID

+ func ParseSegmentPath(rawPath []byte) (ObjectIdentifier, int64, error)

+ func (id *ObjectIdentifier) Key() string

+ func (id *ObjectIdentifier) SegmentPath(segmentIndex int64) ([]byte, error)

+ type ObjectState struct

+ LastSegment *pb.Pointer

+ OtherSegments []*pb.Pointer

+ ZeroSegment *pb.Pointer

+ func (state *ObjectState) Status() ObjectStatus

+ type ObjectStatus byte

+ type PointerDB interface

+ GetItems func(ctx context.Context, paths [][]byte) ([]*pb.Pointer, error)

+ UnsynchronizedGetDel func(ctx context.Context, paths [][]byte) (deletedPaths [][]byte, _ []*pb.Pointer, _ error)

+ type Report struct

+ Deleted []*ObjectIdentifier

+ Failed []*ObjectIdentifier

+ func GenerateReport(ctx context.Context, log *zap.Logger, requests []*ObjectIdentifier, ...) Report

+ func (r Report) HasFailures() bool

+ type Service struct

+ func NewService(log *zap.Logger, pointerDB PointerDB, config Config) (*Service, error)

+ func (service *Service) DeletePointers(ctx context.Context, requests []*ObjectIdentifier) (_ []*pb.Pointer, _ [][]byte, err error)