consensus

Documentation

Index

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

Functions

func NewInsolarConsensus

func NewInsolarConsensus(keeper nodekeeper.NodeKeeper, handler hosthandler.HostHandler) (consensus.Processor, error)

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