sequencer

Documentation

Index

• type Sequencer
  • func NewSequencer() *Sequencer
  • func (s *Sequencer) Pushed(changes []abstract.ChangeItem) (uint64, error)
  • func (s *Sequencer) StartProcessing(changes []abstract.ChangeItem) error

Types

type Sequencer

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

Sequencer takes items and updates progressInfo

func NewSequencer

func NewSequencer() *Sequencer

func (*Sequencer) Pushed

func (s *Sequencer) Pushed(changes []abstract.ChangeItem) (uint64, error)

func (*Sequencer) StartProcessing

func (s *Sequencer) StartProcessing(changes []abstract.ChangeItem) error

StartProcessing receives changes in correct transaction order because we read from server synchronously