verify

Documentation

Index

• Variables
• type Chore
  • func New(log *zap.Logger, mdb metaloop.MetabaseDB, config Config) *Chore
  • func (chore *Chore) RunOnce(ctx context.Context) error
• type Config
• type ProgressObserver
  • func (progress *ProgressObserver) InlineSegment(context.Context, *metaloop.Segment) error
  • func (progress *ProgressObserver) LoopStarted(ctx context.Context, info metaloop.LoopInfo) (err error)
  • func (progress *ProgressObserver) Object(context.Context, *metaloop.Object) error
  • func (progress *ProgressObserver) RemoteSegment(context.Context, *metaloop.Segment) error
  • func (progress *ProgressObserver) Report()
• type SegmentSizes
  • func (verify *SegmentSizes) InlineSegment(ctx context.Context, seg *metaloop.Segment) error
  • func (verify *SegmentSizes) LoopStarted(ctx context.Context, info metaloop.LoopInfo) (err error)
  • func (verify *SegmentSizes) Object(ctx context.Context, obj *metaloop.Object) error
  • func (verify *SegmentSizes) RemoteSegment(ctx context.Context, seg *metaloop.Segment) error

Variables

var Error = errs.Class("verify")

Error is the default error class for the package.

Types

type Chore

type Chore struct {
	Log *zap.Logger

	Config Config

	DB metaloop.MetabaseDB
}

Chore runs different verifications on metabase loop.

func New

func New(log *zap.Logger, mdb metaloop.MetabaseDB, config Config) *Chore

New creates new verification.

func (*Chore) RunOnce

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

RunOnce creates a new metaloop and runs the verifications.

type Config

type Config struct {
	ProgressPrintFrequency int64
	Loop                   metaloop.Config
}

Config contains configuration for all the services.

type ProgressObserver

type ProgressObserver struct {
	Log *zap.Logger

	ProgressPrintFrequency int64

	ObjectCount        int64
	RemoteSegmentCount int64
	InlineSegmentCount int64
}

ProgressObserver counts and prints progress of metabase loop.

func (*ProgressObserver) InlineSegment

func (progress *ProgressObserver) InlineSegment(context.Context, *metaloop.Segment) error

InlineSegment implements the Observer interface.

func (*ProgressObserver) LoopStarted

func (progress *ProgressObserver) LoopStarted(ctx context.Context, info metaloop.LoopInfo) (err error)

LoopStarted is called at each start of a loop.

func (*ProgressObserver) Object

func (progress *ProgressObserver) Object(context.Context, *metaloop.Object) error

Object implements the Observer interface.

func (*ProgressObserver) RemoteSegment

func (progress *ProgressObserver) RemoteSegment(context.Context, *metaloop.Segment) error

RemoteSegment implements the Observer interface.

func (*ProgressObserver) Report

func (progress *ProgressObserver) Report()

Report reports the current progress.

type SegmentSizes

type SegmentSizes struct {
	Log *zap.Logger
	// contains filtered or unexported fields
}

SegmentSizes verifies segments table plain_offset and plain_size.

func (*SegmentSizes) InlineSegment

func (verify *SegmentSizes) InlineSegment(ctx context.Context, seg *metaloop.Segment) error

InlineSegment implements the Observer interface.

func (*SegmentSizes) LoopStarted

func (verify *SegmentSizes) LoopStarted(ctx context.Context, info metaloop.LoopInfo) (err error)

LoopStarted is called at each start of a loop.

func (*SegmentSizes) Object

func (verify *SegmentSizes) Object(ctx context.Context, obj *metaloop.Object) error

Object implements the Observer interface.

func (*SegmentSizes) RemoteSegment

func (verify *SegmentSizes) RemoteSegment(ctx context.Context, seg *metaloop.Segment) error

RemoteSegment implements the Observer interface.