gossipsubbuilder

Oct 3, 2023

Changes in this version

type Builder

+ func (g *Builder) EnableGossipSubScoringWithOverride(override *p2p.PeerScoringConfigOverride)

+ func (g *Builder) OverrideDefaultRpcInspectorSuiteFactory(factory p2p.GossipSubRpcInspectorSuiteFactoryFunc)

Jun 5, 2023

Changes in this version

type Builder

+ func (g *Builder) SetGossipSubRPCInspectorSuite(inspectorSuite p2p.GossipSubInspectorSuite)

Apr 5, 2023

Changes in this version

+ type Builder struct

+ func NewGossipSubBuilder(logger zerolog.Logger, metrics module.GossipSubMetrics) *Builder

+ func (g *Builder) Build(ctx irrecoverable.SignalerContext) (p2p.PubSubAdapter, p2p.PeerScoreTracer, error)

+ func (g *Builder) SetAppSpecificScoreParams(f func(peer.ID) float64)

+ func (g *Builder) SetGossipSubConfigFunc(gossipSubConfigFunc p2p.GossipSubAdapterConfigFunc)

+ func (g *Builder) SetGossipSubFactory(gossipSubFactory p2p.GossipSubFactoryFunc)

+ func (g *Builder) SetGossipSubPeerScoring(gossipSubPeerScoring bool)

+ func (g *Builder) SetGossipSubRPCInspectors(inspectors ...p2p.GossipSubRPCInspector)

+ func (g *Builder) SetGossipSubScoreTracerInterval(gossipSubScoreTracerInterval time.Duration)

+ func (g *Builder) SetGossipSubTracer(gossipSubTracer p2p.PubSubTracer)

+ func (g *Builder) SetHost(h host.Host)

+ func (g *Builder) SetIDProvider(idProvider module.IdentityProvider)

+ func (g *Builder) SetRoutingSystem(routingSystem routing.Routing)

+ func (g *Builder) SetSubscriptionFilter(subscriptionFilter pubsub.SubscriptionFilter)

+ func (g *Builder) SetTopicScoreParams(topic channels.Topic, topicScoreParams *pubsub.TopicScoreParams)