mirror of
https://github.com/logos-messaging/go-libp2p-pubsub.git
synced 2026-01-05 22:33:10 +00:00
feat: expose router and mesh peers
This commit is contained in:
parent
8e498e9e96
commit
cb2c7f7ddc
16
gossipsub.go
16
gossipsub.go
@ -1985,6 +1985,22 @@ func (gs *GossipSubRouter) getPeers(topic string, count int, filter func(peer.ID
|
|||||||
return peers
|
return peers
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (gs *GossipSubRouter) MeshPeers(topic string) []peer.ID {
|
||||||
|
peers, ok := gs.mesh[topic]
|
||||||
|
if !ok {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
result := make([]peer.ID, len(peers))
|
||||||
|
i := 0
|
||||||
|
for p := range peers {
|
||||||
|
result[i] = p
|
||||||
|
i++
|
||||||
|
}
|
||||||
|
|
||||||
|
return result
|
||||||
|
}
|
||||||
|
|
||||||
// WithDefaultTagTracer returns the tag tracer of the GossipSubRouter as a PubSub option.
|
// WithDefaultTagTracer returns the tag tracer of the GossipSubRouter as a PubSub option.
|
||||||
// This is useful for cases where the GossipSubRouter is instantiated externally, and is
|
// This is useful for cases where the GossipSubRouter is instantiated externally, and is
|
||||||
// injected into the GossipSub constructor as a dependency. This allows the tag tracer to be
|
// injected into the GossipSub constructor as a dependency. This allows the tag tracer to be
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user