Versions in this module Expand all Collapse all v0 v0.4.0 Mar 25, 2024 v0.3.0 Feb 28, 2024 Changes in this version + type CertRequestBuffer struct + 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 interface + CertificationResult func() <-chan *types.UnicityCertificate + GetLatestUnicityCertificate func(id types.SystemID) (*types.UnicityCertificate, error) + RequestCertification func(ctx context.Context, cr consensus.IRChangeRequest) error + Run func(ctx context.Context) error + type Node struct + func New(p *network.Peer, pNet PartitionNet, ps partitions.PartitionConfiguration, ...) (*Node, error) + func (v *Node) Run(ctx context.Context) error + type Observability interface + Logger func() *slog.Logger + Meter func(name string, opts ...metric.MeterOption) metric.Meter + Tracer func(name string, options ...trace.TracerOption) trace.Tracer + type PartitionNet interface + ReceivedChannel func() <-chan any + Send func(ctx context.Context, msg any, receivers ...peer.ID) error + type QuorumStatus uint8 + const QuorumAchieved + const QuorumInProgress + const QuorumNotPossible + type Subscriptions struct + 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)