switcher

package

v1.0.5 Latest Latest Go to latest Published: Oct 28, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cockroachdb/replicator

Links

Open Source Insights

Documentation ¶

Overview ¶

Package switcher contains a meta-Sequencer that switches between various modes of operation.

Index ¶

Variables
type Mode
- func (i Mode) String() string
type Switcher
- func ProvideSequencer(best *besteffort.BestEffort, core *core.Core, diags *diag.Diagnostics, ...) *Switcher
- func (s *Switcher) Start(ctx *stopper.Context, opts *sequencer.StartOptions) (types.MultiAcceptor, *notify.Var[sequencer.Stat], error)
- func (s *Switcher) WithMode(mode *notify.Var[Mode]) *Switcher

Constants ¶

This section is empty.

Variables ¶

View Source

var Set = wire.NewSet(
	besteffort.Set,
	chaos.Set,
	core.Set,
	immediate.Set,
	script.Set,
	scheduler.Set,

	ProvideSequencer,
)

Set is used by Wire.

Functions ¶

This section is empty.

Types ¶

type Mode ¶

type Mode int

Mode describes a strategy using another sequencer.

const (
	ModeUnknown Mode = iota
	ModeBestEffort
	ModeConsistent
	ModeImmediate

	MaxMode = iota - 1 // Used for testing all modes.
	MinMode = Mode(1)  // Used for testing all modes.
)

The modes of operation that can be dynamically selected from.

func (Mode) String ¶

func (i Mode) String() string

type Switcher ¶

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

Switcher switches between delegate sequencers. It also adds script bindings into the sequencer stack.

func ProvideSequencer ¶

func ProvideSequencer(
	best *besteffort.BestEffort,
	core *core.Core,
	diags *diag.Diagnostics,
	imm *immediate.Immediate,
	script *script.Sequencer,
	stagingPool *types.StagingPool,
	targetPool *types.TargetPool,
) *Switcher

ProvideSequencer is called by Wire.

func (*Switcher) Start ¶

func (s *Switcher) Start(
	ctx *stopper.Context, opts *sequencer.StartOptions,
) (types.MultiAcceptor, *notify.Var[sequencer.Stat], error)

Start a sequencer that can switch between various modes of operation. Callers must call Switcher.WithMode before calling this method.

func (*Switcher) WithMode ¶

func (s *Switcher) WithMode(mode *notify.Var[Mode]) *Switcher

WithMode returns a copy of the Switcher that uses the given variable for mode control. This method exists so that Switcher can satisfy the sequencer.Sequencer interface.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL