gossip

Documentation

Index

• Variables
• type Broadcaster
  • func NewBroadcaster(networkID rebro.NetworkID, singer crypto.Signer, certifier rebro.Certifier, ...) *Broadcaster
  • func (bro *Broadcaster) Broadcast(ctx context.Context, msg rebro.Message, qcomm rebro.QuorumCertificate) error
  • func (bro *Broadcaster) Start() (err error)
  • func (bro *Broadcaster) Stop(ctx context.Context) (err error)
• type Orchestrator
  • func NewOrchestrator(ps *pubsub.PubSub) *Orchestrator
  • func (o *Orchestrator) NewBroadcaster(nid rebro.NetworkID, signer crypto.Signer, certifier rebro.Certifier, ...) (rebro.Broadcaster, error)

Variables

var ValidationTimeout = time.Second * 30

Types

type Broadcaster

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

func NewBroadcaster

func NewBroadcaster(
	networkID rebro.NetworkID,
	singer crypto.Signer,
	certifier rebro.Certifier,
	hasher rebro.Hasher,
	decoder rebro.MessageIDDecoder,
	ps *pubsub.PubSub,
) *Broadcaster

NewBroadcaster instantiates a new gossiping Broadcaster.

func (*Broadcaster) Broadcast

func (bro *Broadcaster) Broadcast(ctx context.Context, msg rebro.Message, qcomm rebro.QuorumCertificate) error

func (*Broadcaster) Start

func (bro *Broadcaster) Start() (err error)

func (*Broadcaster) Stop

func (bro *Broadcaster) Stop(ctx context.Context) (err error)

type Orchestrator

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

func NewOrchestrator

func NewOrchestrator(ps *pubsub.PubSub) *Orchestrator

func (*Orchestrator) NewBroadcaster

func (o *Orchestrator) NewBroadcaster(
	nid rebro.NetworkID,
	signer crypto.Signer,
	certifier rebro.Certifier,
	hasher rebro.Hasher,
	decoder rebro.MessageIDDecoder,
) (rebro.Broadcaster, error)