handler

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2025 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CEmptyDirETagPlaceholder = "d"
)
View Source 
const (
	CMaxBufferedMoveObjectVersions = 100
)

Variables

This section is empty.

Functions

func New 

func New(conf *Config, clients s3client.Service, versionSvc meta.VersionService,
	policySvc policy.Service, storageSvc storage.Service, rc rclone.Service,
	queueSvc tasks.QueueService, limit ratelimit.RPM, objectLocker *store.ObjectLocker,
	bucketLocker *store.BucketLocker, replicationstatusLocker *store.ReplicationStatusLocker) *svc

Types

type Config added in v0.5.2 

type Config struct {
	PauseRetryInterval  time.Duration `yaml:"pauseRetryInterval"`
	SwitchRetryInterval time.Duration `yaml:"switchRetryInterval"`
	QueueUpdateInterval time.Duration `yaml:"queueUpdateInterval"`
}

type ConsistencyCheckCtrl added in v0.6.0 

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

func NewConsistencyCheckCtrl added in v0.6.0 

func NewConsistencyCheckCtrl(svc *ConsistencyCheckSvc, queueSvc tasks.QueueService) *ConsistencyCheckCtrl

func (*ConsistencyCheckCtrl) HandleConsistencyCheck added in v0.6.0 

func (r *ConsistencyCheckCtrl) HandleConsistencyCheck(ctx context.Context, t *asynq.Task) error

func (*ConsistencyCheckCtrl) HandleConsistencyCheckList added in v0.6.0 

func (r *ConsistencyCheckCtrl) HandleConsistencyCheckList(ctx context.Context, t *asynq.Task) error

func (*ConsistencyCheckCtrl) HandleConsistencyCheckListVersions added in v0.6.0 

func (r *ConsistencyCheckCtrl) HandleConsistencyCheckListVersions(ctx context.Context, t *asynq.Task) (err error)

type ConsistencyCheckSvc added in v0.6.0 

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

func NewConsistencyCheckSvc added in v0.6.0 

func NewConsistencyCheckSvc(idStore *store.ConsistencyCheckIDStore, settingsStore *store.ConsistencyCheckSettingsStore, listStateStore *store.ConsistencyCheckListStateStore, setStore *store.ConsistencyCheckSetStore, copySvc rclone.CopySvc, queueSvc tasks.QueueService) *ConsistencyCheckSvc

func (*ConsistencyCheckSvc) AccountObjectVersions added in v0.6.0 

func (r *ConsistencyCheckSvc) AccountObjectVersions(ctx context.Context, checkID entity.ConsistencyCheckID,
	user string, location entity.ConsistencyCheckLocation, prefix string, ignoreEtags bool, ignoreSizes bool) error

func (*ConsistencyCheckSvc) DeleteConsistencyCheck added in v0.6.0 

func (r *ConsistencyCheckSvc) DeleteConsistencyCheck(ctx context.Context, id entity.ConsistencyCheckID) error

func (*ConsistencyCheckSvc) GetConsistencyCheckList added in v0.6.0 

func (r *ConsistencyCheckSvc) GetConsistencyCheckList(ctx context.Context) ([]entity.ConsistencyCheckStatus, error)

func (*ConsistencyCheckSvc) GetConsistencyCheckReportEntries added in v0.6.0 

func (r *ConsistencyCheckSvc) GetConsistencyCheckReportEntries(ctx context.Context, id entity.ConsistencyCheckID, cursor uint64, pageSize uint64) (entity.ConsistencyCheckReportEntryPage, error)

func (*ConsistencyCheckSvc) GetConsistencyCheckStatus added in v0.6.0 

func (r *ConsistencyCheckSvc) GetConsistencyCheckStatus(ctx context.Context, id entity.ConsistencyCheckID) (entity.ConsistencyCheckStatus, error)

func (*ConsistencyCheckSvc) ObjectTasks added in v0.6.0 

func (r *ConsistencyCheckSvc) ObjectTasks(ctx context.Context, checkID entity.ConsistencyCheckID,
	user string, location entity.ConsistencyCheckLocation, prefix string, versioned bool, ignoreEtags bool, ignoreSizes bool) iter.Seq2[ObjectTask, error]

func (*ConsistencyCheckSvc) RegisterConsistencyCheck added in v0.6.0 

func (r *ConsistencyCheckSvc) RegisterConsistencyCheck(ctx context.Context, id entity.ConsistencyCheckID, settings entity.ConsistencyCheckSettings) error

func (*ConsistencyCheckSvc) ShouldCheckVersions added in v0.6.0 

func (r *ConsistencyCheckSvc) ShouldCheckVersions(ctx context.Context, user string, locations []entity.ConsistencyCheckLocation) (bool, error)

type ObjectTask added in v0.6.0 

type ObjectTask struct {
	Key string
	Dir bool
}

type VersionedMigrationCtrl added in v0.6.0 

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

func NewVersionedMigrationCtrl added in v0.6.0 

func NewVersionedMigrationCtrl(svc *VersionedMigrationSvc, queueSvc tasks.QueueService) *VersionedMigrationCtrl

func (*VersionedMigrationCtrl) HandleObjectVersionList added in v0.6.0 

func (r *VersionedMigrationCtrl) HandleObjectVersionList(ctx context.Context, t *asynq.Task) error

func (*VersionedMigrationCtrl) HandleVersionedObjectMigration added in v0.6.0 

func (r *VersionedMigrationCtrl) HandleVersionedObjectMigration(ctx context.Context, t *asynq.Task) error

type VersionedMigrationSvc added in v0.6.0 

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

func NewVersionedMigrationSvc added in v0.6.0 

func NewVersionedMigrationSvc(policySvc policy.Service, copySvc rclone.CopySvc,
	objectVersionInfoStore *store.ObjectVersionInfoStore, objectLocker *store.ObjectLocker,
	pauseRetryInterval time.Duration) *VersionedMigrationSvc

func (*VersionedMigrationSvc) ListVersions added in v0.6.0 

func (r *VersionedMigrationSvc) ListVersions(ctx context.Context, objectID entity.VersionedObjectID, replicationID entity.BucketReplicationPolicy) error

func (*VersionedMigrationSvc) MigrateVersions added in v0.6.0 

func (r *VersionedMigrationSvc) MigrateVersions(ctx context.Context, replicationID entity.BucketReplicationPolicy, prefix string) 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.