piecemigrate

Documentation

Index

• type Chore
  • func NewChore(log *zap.Logger, config Config, old, new piecestore.PieceBackend) *Chore
  • func (chore *Chore) Close() (err error)
  • func (chore *Chore) Run(ctx context.Context) (err error)
  • func (chore *Chore) RunOnce(ctx context.Context) (err error)
  • func (chore *Chore) SetMigrate(sat storj.NodeID, migrate bool)
  • func (chore *Chore) TryMigrateOne(sat storj.NodeID, piece storj.PieceID)
• type Config

Types

type Chore

type Chore struct {
	Loop *sync2.Cycle
	// contains filtered or unexported fields
}

Chore migrates pieces.

architecture: Chore

func NewChore

func NewChore(log *zap.Logger, config Config, old, new piecestore.PieceBackend) *Chore

NewChore initializes and returns a new Chore instance.

func (*Chore) Close

func (chore *Chore) Close() (err error)

Close shuts down the chore's loop and releases associated resources. Always returns nil.

func (*Chore) Run

func (chore *Chore) Run(ctx context.Context) (err error)

Run starts the chore loop to migrate pieces based on the configuration.

func (*Chore) RunOnce

func (chore *Chore) RunOnce(ctx context.Context) (err error)

RunOnce executes a single iteration of the chore to migrate pieces based on the configuration.

func (*Chore) SetMigrate

func (chore *Chore) SetMigrate(sat storj.NodeID, migrate bool)

SetMigrate enables or disables migration for the given satellite. Adds the satellite to the active set if migrate is true; otherwise, removes it.

func (*Chore) TryMigrateOne

func (chore *Chore) TryMigrateOne(sat storj.NodeID, piece storj.PieceID)

TryMigrateOne enqueues a migration item for the given satellite and piece if the queue has capacity. Fails silently if the queue is full.

type Config

type Config struct {
	BatchSize int           `help:"how many pieces to migrate at once" default:"10000"`
	Interval  time.Duration `help:"how long to wait between the batches" default:"10m"`
}

Config defines the configuration for the chore.