besteffort

Documentation

Overview

Package besteffort contains a best-effort implementation of types.MultiAcceptor.

Index

• Variables
• type BestEffort
  • func ProvideBestEffort(cfg *sequencer.Config, leases types.Leases, scheduler *scheduler.Scheduler, ...) *BestEffort
  • func (s *BestEffort) SetTimeSource(source func() hlc.Time)
  • func (s *BestEffort) Wrap(_ *stopper.Context, delegate sequencer.Sequencer) (sequencer.Sequencer, error)

Variables

var Set = wire.NewSet(
	ProvideBestEffort,
)

Set is used by Wire.

Types

type BestEffort

type BestEffort struct {
	// contains filtered or unexported fields
}

BestEffort injects an acceptor shim that will attempt to write directly to the target table. It will also run a concurrent sequencer for each table that is provided.

func ProvideBestEffort

func ProvideBestEffort(
	cfg *sequencer.Config,
	leases types.Leases,
	scheduler *scheduler.Scheduler,
	stagingPool *types.StagingPool,
	stagers types.Stagers,
	targetPool *types.TargetPool,
	watchers types.Watchers,
) *BestEffort

ProvideBestEffort is called by Wire.

func (*BestEffort) SetTimeSource

func (s *BestEffort) SetTimeSource(source func() hlc.Time)

SetTimeSource is called by tests that need to ensure lock-step behaviors in sweepTable or when testing the proactive timestamp behavior.

func (*BestEffort) Wrap

func (s *BestEffort) Wrap(
	_ *stopper.Context, delegate sequencer.Sequencer,
) (sequencer.Sequencer, error)

Wrap implements sequencer.Shim.