rootchain

Documentation

Index

• type CertRequestBuffer
  • func NewCertificationRequestBuffer() *CertRequestBuffer
  • func (c *CertRequestBuffer) Add(id types.SystemID, request *certification.BlockCertificationRequest, ...) (QuorumStatus, []*certification.BlockCertificationRequest, error)
  • func (c *CertRequestBuffer) Clear(id types.SystemID)
  • func (c *CertRequestBuffer) IsConsensusReceived(id types.SystemID, tb partitions.PartitionTrustBase) QuorumStatus
  • func (c *CertRequestBuffer) Reset()
• type ConsensusManager
• type Node
  • func New(p *network.Peer, pNet PartitionNet, ps partitions.PartitionConfiguration, ...) (*Node, error)
  • func (v *Node) Run(ctx context.Context) error
• type Observability
• type PartitionNet
• type QuorumStatus
• type Subscriptions
  • func NewSubscriptions(m metric.Meter) *Subscriptions
  • func (s *Subscriptions) Get(id types.SystemID) []string
  • func (s *Subscriptions) ResponseSent(id types.SystemID, nodeId string)
  • func (s *Subscriptions) Subscribe(id types.SystemID, 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(id types.SystemID, 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 types.SystemID)

Clear clears node request in one partition

func (*CertRequestBuffer) IsConsensusReceived

func (c *CertRequestBuffer) IsConsensusReceived(id types.SystemID, 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 ConsensusManager

type ConsensusManager interface {
	// RequestCertification accepts certification requests with proof of quorum or no-quorum.
	RequestCertification(ctx context.Context, cr consensus.IRChangeRequest) error
	// CertificationResult read the channel to receive certification results
	CertificationResult() <-chan *types.UnicityCertificate
	// GetLatestUnicityCertificate get the latest certification for partition (maybe should/can be removed)
	GetLatestUnicityCertificate(id types.SystemID) (*types.UnicityCertificate, error)
	// Run consensus algorithm
	Run(ctx context.Context) error
}

type Node

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

func New

func New(
	p *network.Peer,
	pNet PartitionNet,
	ps partitions.PartitionConfiguration,
	cm ConsensusManager,
	observe Observability,
) (*Node, error)

New creates a new instance of the root chain node

func (*Node) Run

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

type Observability

type Observability interface {
	Meter(name string, opts ...metric.MeterOption) metric.Meter
	Tracer(name string, options ...trace.TracerOption) trace.Tracer
	Logger() *slog.Logger
}

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(m metric.Meter) *Subscriptions

func (*Subscriptions) Get

func (s *Subscriptions) Get(id types.SystemID) []string

func (*Subscriptions) ResponseSent

func (s *Subscriptions) ResponseSent(id types.SystemID, nodeId string)

func (*Subscriptions) Subscribe

func (s *Subscriptions) Subscribe(id types.SystemID, nodeId string)