sub

Documentation

Index

• Variables
• func FetchMessagesByCids(ctx context.Context, bserv bserv.BlockGetter, cids []cid.Cid) ([]*types.Message, error)
• func FetchSignedMessagesByCids(ctx context.Context, bserv bserv.BlockGetter, cids []cid.Cid) ([]*types.SignedMessage, error)
• func HandleIncomingBlocks(ctx context.Context, bsub *pubsub.Subscription, s *chain.Syncer, ...)
• func HandleIncomingMessages(ctx context.Context, mpool *messagepool.MessagePool, msub *pubsub.Subscription)
• type BlockValidator
  • func NewBlockValidator(self peer.ID, chain *store.ChainStore, cns consensus.Consensus, ...) *BlockValidator
  • func (bv *BlockValidator) Validate(ctx context.Context, pid peer.ID, msg *pubsub.Message) (res pubsub.ValidationResult)
• type IndexerMessageValidator
  • func NewIndexerMessageValidator(self peer.ID, chainApi full.ChainModuleAPI, stateApi full.StateModuleAPI) *IndexerMessageValidator
  • func (v *IndexerMessageValidator) Validate(ctx context.Context, pid peer.ID, msg *pubsub.Message) pubsub.ValidationResult
• type MessageValidator
  • func NewMessageValidator(self peer.ID, mp *messagepool.MessagePool) *MessageValidator
  • func (mv *MessageValidator) Validate(ctx context.Context, pid peer.ID, msg *pubsub.Message) pubsub.ValidationResult

Variables

var DefaultHashFunction = uint64(mh.BLAKE2B_MIN + 31)

Functions

func FetchMessagesByCids

func FetchMessagesByCids(
	ctx context.Context,
	bserv bserv.BlockGetter,
	cids []cid.Cid,
) ([]*types.Message, error)

func FetchSignedMessagesByCids

func FetchSignedMessagesByCids(
	ctx context.Context,
	bserv bserv.BlockGetter,
	cids []cid.Cid,
) ([]*types.SignedMessage, error)

func HandleIncomingBlocks

func HandleIncomingBlocks(ctx context.Context, bsub *pubsub.Subscription, s *chain.Syncer, bs bserv.BlockService, cmgr connmgr.ConnManager)

func HandleIncomingMessages

func HandleIncomingMessages(ctx context.Context, mpool *messagepool.MessagePool, msub *pubsub.Subscription)

Types

type BlockValidator

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

func NewBlockValidator

func NewBlockValidator(self peer.ID, chain *store.ChainStore, cns consensus.Consensus, blacklist func(peer.ID)) *BlockValidator

func (*BlockValidator) Validate

func (bv *BlockValidator) Validate(ctx context.Context, pid peer.ID, msg *pubsub.Message) (res pubsub.ValidationResult)

type IndexerMessageValidator

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

func NewIndexerMessageValidator

func NewIndexerMessageValidator(self peer.ID, chainApi full.ChainModuleAPI, stateApi full.StateModuleAPI) *IndexerMessageValidator

func (*IndexerMessageValidator) Validate

func (v *IndexerMessageValidator) Validate(ctx context.Context, pid peer.ID, msg *pubsub.Message) pubsub.ValidationResult

type MessageValidator

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

func NewMessageValidator

func NewMessageValidator(self peer.ID, mp *messagepool.MessagePool) *MessageValidator

func (*MessageValidator) Validate

func (mv *MessageValidator) Validate(ctx context.Context, pid peer.ID, msg *pubsub.Message) pubsub.ValidationResult