switcher

package

v0.0.0-...-9e054ec Latest Latest Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cockroachdb/cdc-sink

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