core

Documentation

Overview

Package core contains a sequencer implementation that preserves source transactions and relative timestamps.

Index

• Variables
• type Core
  • func ProvideCore(cfg *sequencer.Config, leases types.Leases, scheduler *scheduler.Scheduler, ...) *Core
  • func (s *Core) Start(ctx *stopper.Context, opts *sequencer.StartOptions) (types.MultiAcceptor, *notify.Var[sequencer.Stat], error)

Variables

var Set = wire.NewSet(ProvideCore)

Set is used by Wire.

Types

type Core

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

The Core sequencer accepts batches by writing them to a staging table. It will then apply the data in a transactionally-consistent and possibly concurrent fashion.

func ProvideCore

func ProvideCore(
	cfg *sequencer.Config,
	leases types.Leases,
	scheduler *scheduler.Scheduler,
	stagers types.Stagers,
	stagingPool *types.StagingPool,
	targetPool *types.TargetPool,
) *Core

ProvideCore is called by Wire.

func (*Core) Start

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

Start implements sequencer.Sequencer. It will incrementally unstage and apply batches of mutations within the given bounds.