handler

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2026 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CMaxBufferedMoveObjectVersions = 100
)

Variables

This section is empty.

Functions

func New 

func New(conf *Config, credsSvc objstore.CredsService, clients objstore.Clients, versionSvc meta.VersionService,
	copySvc copy.CopySvc, queueSvc tasks.QueueService, uploadSvc *storage.UploadSvc,
	limit ratelimit.RPM, listStateStore *store.MigrationObjectListStateStore,
	objectLocker *store.ObjectLocker, bucketLocker *store.BucketLocker,
	replicationstatusLocker *store.ReplicationStatusLocker, versionedSvc *VersionedMigrationSvc) *svc

func NewSwitchSvc added in v0.7.0 

func NewSwitchSvc(conf *Config, policySvc policy.Service, uploadSvc *storage.UploadSvc,
	replicationstatusLocker *store.ReplicationStatusLocker) *switchSvc

Types

type Config added in v0.5.2 

type Config struct {
	SwiftRetryInterval       time.Duration  `yaml:"swiftRetryInterval"`
	PauseRetryInterval       time.Duration  `yaml:"pauseRetryInterval"`
	SwitchRetryInterval      time.Duration  `yaml:"switchRetryInterval"`
	QueueUpdateInterval      time.Duration  `yaml:"queueUpdateInterval"`
	TaskCheckInterval        time.Duration  `yaml:"taskCheckInterval"`
	DelayedTaskCheckInterval time.Duration  `yaml:"delayedTaskCheckInterval"`
	CustomErrRetryInterval   *time.Duration `yaml:"customErrRetryInterval,omitempty"`
}

func (*Config) Validate added in v0.7.2 

func (c *Config) Validate() error

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, clients objstore.Clients, 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[string, 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 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 copy.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

Directories

Path Synopsis

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.