reportedrollup

Documentation

Index

• Variables
• type Chore
  • func NewChore(log *zap.Logger, db orders.DB, config Config) *Chore
  • func (chore *Chore) Close() error
  • func (chore *Chore) Run(ctx context.Context) (err error)
  • func (chore *Chore) RunOnce(ctx context.Context, now time.Time) (err error)
• type Config

Variables

var (

	// Error is the error class for this package.
	Error = errs.Class("reportedrollup")
)

Types

type Chore

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

Chore for flushing reported serials to the database as rollups.

architecture: Chore

func NewChore

func NewChore(log *zap.Logger, db orders.DB, config Config) *Chore

NewChore creates new chore for flushing the reported serials to the database as rollups.

func (*Chore) Close

func (chore *Chore) Close() error

Close stops the reported rollups chore.

func (*Chore) Run

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

Run starts the reported rollups chore.

func (*Chore) RunOnce

func (chore *Chore) RunOnce(ctx context.Context, now time.Time) (err error)

RunOnce finds expired bandwidth as of 'now' and inserts rollups into the appropriate tables.

type Config

type Config struct {
	Interval       time.Duration `help:"how often to flush the reported serial rollups to the database" default:"5m"`
	QueueBatchSize int           `help:"default queue batch size" default:"10000"`
}

Config is a configuration struct for the Chore.