collector

Documentation

Overview

Package collector implements expired piece deletion from storage node.

Index

• type Config
• type Service
  • func NewService(log *zap.Logger, pieces *pieces.Store, usedSerials *usedserials.Table, ...) *Service
  • func (service *Service) Close() (err error)
  • func (service *Service) Collect(ctx context.Context, now time.Time) (err error)
  • func (service *Service) Run(ctx context.Context) (err error)

Types

type Config

type Config struct {
	Interval              time.Duration `help:"how frequently expired pieces are collected" default:"1h0m0s"`
	ExpirationGracePeriod time.Duration `` /* 191-byte string literal not displayed */
	ExpirationBatchSize   int           `` /* 127-byte string literal not displayed */
}

Config defines parameters for storage node Collector.

type Service

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

Service implements collecting expired pieces on the storage node.

architecture: Chore

func NewService

func NewService(log *zap.Logger, pieces *pieces.Store, usedSerials *usedserials.Table, config Config) *Service

NewService creates a new collector service.

func (*Service) Close

func (service *Service) Close() (err error)

Close stops the collector service.

func (*Service) Collect

func (service *Service) Collect(ctx context.Context, now time.Time) (err error)

Collect collects pieces that have expired by now.

func (*Service) Run

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

Run runs collector service.