Documentation
¶
Overview ¶
Package besteffort contains a best-effort implementation of types.MultiAcceptor.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Set = wire.NewSet( ProvideBestEffort, )
Set is used by Wire.
Functions ¶
This section is empty.
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.
Source Files
Click to show internal directories.
Click to hide internal directories.