92a2be2abd
As part of the Metainfo Refactoring, we need to make the Metainfo Loop working with both the current PointerDB and the new Metabase. Thus, the Metainfo Loop should pass to the Observer interface more specific Object and Segment types instead of pb.Pointer. After this change, there are still a couple of use cases that require access to the pb.Pointer (hence we have it as a field in the metainfo.Segment type): 1. Expired Deletion Service 2. Repair Service It would require additional refactoring in these two services before we are able to clean this. Change-Id: Ib3eb6b7507ed89d5ba745ffbb6b37524ef10ed9f
65 lines
1.7 KiB
Go
65 lines
1.7 KiB
Go
// Copyright (C) 2020 Storj Labs, Inc.
|
|
// See LICENSE for copying information.
|
|
|
|
package expireddeletion
|
|
|
|
import (
|
|
"context"
|
|
"time"
|
|
|
|
"go.uber.org/zap"
|
|
|
|
"storj.io/common/pb"
|
|
"storj.io/common/storj"
|
|
"storj.io/storj/satellite/metainfo"
|
|
"storj.io/storj/storage"
|
|
)
|
|
|
|
var _ metainfo.Observer = (*expiredDeleter)(nil)
|
|
|
|
// expiredDeleter implements the metainfo loop observer interface for expired segment cleanup
|
|
//
|
|
// architecture: Observer
|
|
type expiredDeleter struct {
|
|
log *zap.Logger
|
|
metainfo *metainfo.Service
|
|
}
|
|
|
|
// RemoteSegment deletes the segment if it is expired.
|
|
func (ed *expiredDeleter) RemoteSegment(ctx context.Context, segment *metainfo.Segment) (err error) {
|
|
defer mon.Task()(&ctx)(&err)
|
|
|
|
return ed.deleteSegmentIfExpired(ctx, segment)
|
|
}
|
|
|
|
// InlineSegment deletes the segment if it is expired.
|
|
func (ed *expiredDeleter) InlineSegment(ctx context.Context, segment *metainfo.Segment) (err error) {
|
|
defer mon.Task()(&ctx)(&err)
|
|
|
|
return ed.deleteSegmentIfExpired(ctx, segment)
|
|
}
|
|
|
|
// Object returns nil because the expired deleter only cares about segments.
|
|
func (ed *expiredDeleter) Object(ctx context.Context, object *metainfo.Object) (err error) {
|
|
return nil
|
|
}
|
|
|
|
func (ed *expiredDeleter) deleteSegmentIfExpired(ctx context.Context, segment *metainfo.Segment) error {
|
|
if segment.Expired(time.Now()) {
|
|
pointerBytes, err := pb.Marshal(segment.Pointer)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
err = ed.metainfo.Delete(ctx, segment.Location.Encode(), pointerBytes)
|
|
if storj.ErrObjectNotFound.Has(err) {
|
|
// segment already deleted
|
|
return nil
|
|
} else if storage.ErrValueChanged.Has(err) {
|
|
// segment was replaced
|
|
return nil
|
|
}
|
|
return err
|
|
}
|
|
return nil
|
|
}
|