repairer

Documentation

Index

• Variables
• type Config
  • func (c Config) GetSegmentRepairer(ctx context.Context, tc transport.Client, metainfo *metainfo.Service, ...) (ss SegmentRepairer, err error)
• type SegmentRepairer
• type Service
  • func NewService(queue queue.RepairQueue, config *Config, interval time.Duration, ...) *Service
  • func (service *Service) Close() error
  • func (service *Service) Run(ctx context.Context) (err error)

Variables

var (
	Error = errs.Class("repairer error")
)

Error is a standard error class for this package.

Types

type Config

type Config struct {
	MaxRepair    int           `help:"maximum segments that can be repaired concurrently" releaseDefault:"5" devDefault:"1"`
	Interval     time.Duration `help:"how frequently repairer should try and repair more data" releaseDefault:"1h" devDefault:"0h5m0s"`
	Timeout      time.Duration `help:"time limit for uploading repaired pieces to new storage nodes" devDefault:"10m0s" releaseDefault:"2h"`
	MaxBufferMem memory.Size   `help:"maximum buffer memory (in bytes) to be allocated for read buffers" default:"4M"`
}

Config contains configurable values for repairer

func (Config) GetSegmentRepairer

func (c Config) GetSegmentRepairer(ctx context.Context, tc transport.Client, metainfo *metainfo.Service, orders *orders.Service, cache *overlay.Cache, identity *identity.FullIdentity) (ss SegmentRepairer, err error)

GetSegmentRepairer creates a new segment repairer from storeConfig values

type SegmentRepairer

type SegmentRepairer interface {
	Repair(ctx context.Context, path storj.Path) (err error)
}

SegmentRepairer is a repairer for segments

type Service

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

Service contains the information needed to run the repair service

func NewService

func NewService(queue queue.RepairQueue, config *Config, interval time.Duration, concurrency int, transport transport.Client, metainfo *metainfo.Service, orders *orders.Service, cache *overlay.Cache) *Service

NewService creates repairing service

func (*Service) Close

func (service *Service) Close() error

Close closes resources

func (*Service) Run

func (service *Service) Run(ctx context.Context) (err error)

Run runs the repairer service