sequencer

Documentation

Overview

Package sequencer reads mutations and applies them to the Trillian Map.

Index

• Constants
• type ForceNewEpoch
• type Sequencer
  • func New(domains domain.Storage, tmap trillian.TrillianMapClient, ...) *Sequencer
  • func (s *Sequencer) CreateEpoch(ctx context.Context, logID, mapID int64, forceNewEpoch ForceNewEpoch) error
  • func (s *Sequencer) Initialize(ctx context.Context, logID, mapID int64) error
  • func (s *Sequencer) StartSequencingAll(ctx context.Context, refresh time.Duration) error
  • func (s *Sequencer) StartSigning(ctx context.Context, logID, mapID int64, ...)

Constants

const MaxBatchSize = int32(1000)

MaxBatchSize limits the number of mutations that will be processed per epoch.

Types

type ForceNewEpoch

type ForceNewEpoch bool

ForceNewEpoch determines whether an epoch should be created, even if there are no mutation to process.

type Sequencer

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

Sequencer processes mutations and sends them to the trillian map.

func New

func New(domains domain.Storage,
	tmap trillian.TrillianMapClient,
	tlog trillian.TrillianLogClient,
	mutator mutator.Mutator,
	mutations mutator.MutationStorage) *Sequencer

New creates a new instance of the signer.

func (*Sequencer) CreateEpoch

func (s *Sequencer) CreateEpoch(ctx context.Context, logID, mapID int64, forceNewEpoch ForceNewEpoch) error

CreateEpoch signs the current map head.

func (*Sequencer) Initialize

func (s *Sequencer) Initialize(ctx context.Context, logID, mapID int64) error

Initialize inserts the object hash of an empty struct into the log if it is empty. This keeps the log leaves in-sync with the map which starts off with an empty log root at map revision 0.

func (*Sequencer) StartSequencingAll

func (s *Sequencer) StartSequencingAll(ctx context.Context, refresh time.Duration) error

StartSequencingAll starts sequencing processes for all domains.

func (*Sequencer) StartSigning

func (s *Sequencer) StartSigning(ctx context.Context, logID, mapID int64, minInterval, maxInterval time.Duration)

StartSigning advance epochs once per minInterval, if there were mutations, and at least once per maxElapsed minIntervals.