consensus

Documentation

Index

• func NewInsolarConsensus(handler hosthandler.HostHandler) consensus.Processor
• type NetworkConsensus
  • func (ic *NetworkConsensus) IsPartOfConsensus() bool
  • func (ic *NetworkConsensus) ProcessPulse(ctx context.Context, pulse core.Pulse)
  • func (ic *NetworkConsensus) ReceiverHandler() consensus.CommunicatorReceiver
  • func (ic *NetworkConsensus) SetNodeKeeper(keeper consensus.NodeKeeper)

Functions

func NewInsolarConsensus

func NewInsolarConsensus(handler hosthandler.HostHandler) consensus.Processor

NewInsolarConsensus creates new object to handle all consensus events

Types

type NetworkConsensus

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

NetworkConsensus binds all functionality related to consensus with the network layer

func (*NetworkConsensus) IsPartOfConsensus

func (ic *NetworkConsensus) IsPartOfConsensus() bool

IsPartOfConsensus returns whether we should perform all consensus interactions or not

func (*NetworkConsensus) ProcessPulse

func (ic *NetworkConsensus) ProcessPulse(ctx context.Context, pulse core.Pulse)

ProcessPulse is called when we get new pulse from pulsar. Should be called in goroutine

func (*NetworkConsensus) ReceiverHandler

func (ic *NetworkConsensus) ReceiverHandler() consensus.CommunicatorReceiver

ReceiverHandler return handler that is responsible to handle consensus network requests

func (*NetworkConsensus) SetNodeKeeper

func (ic *NetworkConsensus) SetNodeKeeper(keeper consensus.NodeKeeper)

SetNodeKeeper set NodeKeeper for the processor to integrate Processor with unsync -> sync -> active pipeline