rootchain

Documentation

Index

• type CertRequestBuffer
  • func NewCertificationRequestBuffer() *CertRequestBuffer
  • func (c *CertRequestBuffer) Add(request *certification.BlockCertificationRequest, ...) (QuorumStatus, []*certification.BlockCertificationRequest, error)
  • func (c *CertRequestBuffer) Clear(id protocol.SystemIdentifier)
  • func (c *CertRequestBuffer) IsConsensusReceived(id protocol.SystemIdentifier, tb partitions.PartitionTrustBase) QuorumStatus
  • func (c *CertRequestBuffer) Reset()
• type MsgVerification
• type Node
  • func New(p *network.Peer, pNet PartitionNet, ps partitions.PartitionConfiguration, ...) (*Node, error)
  • func (v *Node) Run(ctx context.Context) error
• type PartitionNet
• type QuorumStatus
• type Subscriptions
  • func NewSubscriptions() *Subscriptions
  • func (s *Subscriptions) Get(id p.SystemIdentifier) []string
  • func (s *Subscriptions) Subscribe(id p.SystemIdentifier, nodeId string)
  • func (s *Subscriptions) SubscriberError(id p.SystemIdentifier, nodeId string)

Types

type CertRequestBuffer

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

func NewCertificationRequestBuffer

func NewCertificationRequestBuffer() *CertRequestBuffer

NewCertificationRequestBuffer create new certification nodeRequest buffer

func (*CertRequestBuffer) Add

func (c *CertRequestBuffer) Add(request *certification.BlockCertificationRequest, tb partitions.PartitionTrustBase) (QuorumStatus, []*certification.BlockCertificationRequest, error)

Add request to certification store. Per node id first valid request is stored. Rest are either duplicate or equivocating and in both cases error is returned. Clear or Reset in order to receive new nodeRequest

func (*CertRequestBuffer) Clear

func (c *CertRequestBuffer) Clear(id protocol.SystemIdentifier)

Clear clears node request in one partition

func (*CertRequestBuffer) IsConsensusReceived

func (c *CertRequestBuffer) IsConsensusReceived(id protocol.SystemIdentifier, tb partitions.PartitionTrustBase) QuorumStatus

IsConsensusReceived has partition with id reached consensus

func (*CertRequestBuffer) Reset

func (c *CertRequestBuffer) Reset()

Reset removed all incoming nodeRequest from all stores

type MsgVerification

type MsgVerification interface {
	IsValid(v crypto.Verifier) error
}

type Node

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

func New

func New(
	p *network.Peer,
	pNet PartitionNet,
	ps partitions.PartitionConfiguration,
	cm consensus.Manager,
) (*Node, error)

New creates a new instance of the root chain node

func (*Node) Run

func (v *Node) Run(ctx context.Context) error

type PartitionNet

type PartitionNet interface {
	Send(ctx context.Context, msg any, receivers ...peer.ID) error
	ReceivedChannel() <-chan any
}

type QuorumStatus

type QuorumStatus uint8

const (
	QuorumInProgress QuorumStatus = iota
	QuorumAchieved
	QuorumNotPossible
)

type Subscriptions

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

func NewSubscriptions

func NewSubscriptions() *Subscriptions

func (*Subscriptions) Get

func (s *Subscriptions) Get(id p.SystemIdentifier) []string

func (*Subscriptions) Subscribe

func (s *Subscriptions) Subscribe(id p.SystemIdentifier, nodeId string)

func (*Subscriptions) SubscriberError

func (s *Subscriptions) SubscriberError(id p.SystemIdentifier, nodeId string)