rolluparchive

Documentation

Index

• Variables
• type Chore
  • func New(log *zap.Logger, sdb accounting.StoragenodeAccounting, ...) *Chore
  • func (chore *Chore) ArchiveRollups(ctx context.Context, cutoff time.Time, batchSize int) (err error)
  • func (chore *Chore) Close() error
  • func (chore *Chore) Run(ctx context.Context) (err error)
• type Config

Variables

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

Error is a standard error class for this package.

Types

type Chore

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

Chore archives bucket and storagenode rollups at a given interval.

architecture: Chore

func New

func New(log *zap.Logger, sdb accounting.StoragenodeAccounting, pdb accounting.ProjectAccounting, config Config) *Chore

New creates a new rollup archiver chore.

func (*Chore) ArchiveRollups

func (chore *Chore) ArchiveRollups(ctx context.Context, cutoff time.Time, batchSize int) (err error)

ArchiveRollups will remove old rollups from active rollup tables.

func (*Chore) Close

func (chore *Chore) Close() error

Close stops the service and releases any resources.

func (*Chore) Run

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

Run starts the archiver chore.

type Config

type Config struct {
	Interval   time.Duration `help:"how frequently rollup archiver should run" releaseDefault:"24h" devDefault:"120s"`
	ArchiveAge time.Duration `help:"age at which a rollup is archived" releaseDefault:"2160h" devDefault:"24h"`
	BatchSize  int           `help:"number of records to delete per delete execution. Used only for crdb which is slow without limit." default:"500"`
	Enabled    bool          `help:"whether or not the rollup archive is enabled." default:"true"`
}

Config contains configurable values for rollup archiver.