immediate

Documentation

Overview

Package immediate contains a trivial sequencer.Sequencer implementation which writes data directly to the configured acceptor.

Index

• Variables
• type Immediate
  • func ProvideImmediate(db *types.TargetPool) *Immediate
  • func (i *Immediate) Start(ctx *stopper.Context, opts *sequencer.StartOptions) (types.MultiAcceptor, *notify.Var[sequencer.Stat], error)

Variables

var Set = wire.NewSet(
	ProvideImmediate,
)

Set is used by Wire.

Types

type Immediate

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

Immediate is a trivial implementation of sequencer.Sequencer that writes through to the underlying acceptor.

func ProvideImmediate

func ProvideImmediate(db *types.TargetPool) *Immediate

ProvideImmediate is called by Wire.

func (*Immediate) Start

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

Start implements sequencer.Sequencer. The emitted stat will advance all tables in the group to the ends of the resolving bounds.