replica

type Options ¶ added in v0.2.0

type Options struct {
	Logger           logrus.FieldLogger
	TimerOpts        timer.Options
	MessageQueueOpts mq.Options
}

func DefaultOptions() Options

func (opts Options) WithLogLevel(level logrus.Level) Options

func (opts Options) WithLogOutput(output io.Writer) Options

func (opts Options) WithTimerOptions(timerOpts timer.Options) Options

type Replica ¶

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

A Replica represents one Process in a replicated state machine that is bound to a specific Shard. It signs Messages before sending them to other Replicas, and verifies Messages before accepting them from other Replicas.

func New(opts Options, whoami id.Signatory, signatories []id.Signatory, propose process.Proposer, validate process.Validator, commit process.Committer, catch process.Catcher, broadcast process.Broadcaster) *Replica

func (replica *Replica) Precommit(ctx context.Context, precommit process.Precommit)

func (replica *Replica) Prevote(ctx context.Context, prevote process.Prevote)

func (replica *Replica) Propose(ctx context.Context, propose process.Propose)

func (replica *Replica) Run(ctx context.Context)