pmsg

package

v0.8.10 Latest Latest Go to latest Published: Sep 1, 2025 License: Apache-2.0, MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewPartialMessageManager(progress gpbft.Progress, ps *pubsub.PubSub, m manifest.Manifest, clk clock.Clock) (*PartialMessageManager, error)

func (pmm *PartialMessageManager) BroadcastChain(ctx context.Context, instance uint64, chain *gpbft.ECChain) error

func (pmm *PartialMessageManager) BufferPartialMessage(ctx context.Context, msg gpbft.PartiallyValidatedMessage)

func (pmm *PartialMessageManager) CompleteMessage(ctx context.Context, pgmsg *gpbft.PartialGMessage) (*gpbft.GMessage, bool)

func (pmm *PartialMessageManager) NotifyChainDiscovered(ctx context.Context, instance uint64, chain *gpbft.ECChain)

func (pmm *PartialMessageManager) RemoveMessagesBeforeInstance(ctx context.Context, instance uint64)

func (pmm *PartialMessageManager) Shutdown(ctx context.Context) error

func (pmm *PartialMessageManager) Start(ctx context.Context) (<-chan gpbft.PartiallyValidatedMessage, error)

func (pmm *PartialMessageManager) ToPartialGMessage(msg *gpbft.GMessage) (*gpbft.PartialGMessage, error)