node

Oct 27, 2025

Changes in this version

type DistributedHashTableDiscoverer

+ NearestPeers func() []warpnet.WarpPeerID

type ModeratorNode

+ func (mn *ModeratorNode) NearestPeers() []warpnet.WarpPeerID

Oct 20, 2025

Changes in this version

+ type DistributedHashTableDiscoverer interface

+ Close func()

+ ClosestPeers func() ([]warpnet.WarpPeerID, error)

+ Discovery func() warpnet.Discovery

type ModeratorNode

+ func (mn *ModeratorNode) RoutingDiscovery() warpnet.Discovery

Aug 18, 2025

Changes in this version

type DistributedHashTableCloser

+ ClosestPeers func() ([]warpnet.WarpPeerID, error)

type ModeratorNode

+ func (mn *ModeratorNode) ClosestPeers() ([]warpnet.WarpPeerID, error)

+ func (mn *ModeratorNode) ID() warpnet.WarpPeerID

Aug 5, 2025

Changes in this version

+ type ConsensusServicer interface

+ Close func()

+ Start func(streamer consensus.ConsensusStreamer) (err error)

+ Validate func(ev event.ValidationEvent) error

+ ValidationResult func(ev event.ValidationResultEvent) error

+ type DiscoveryHandler interface

+ Close func()

+ HandlePeerFound func(pi warpnet.WarpAddrInfo)

+ Run func(n discovery.DiscoveryInfoStorer) error

+ type DistributedHashTableCloser interface

+ Close func()

+ type DistributedStorer interface

+ Close func() error

+ GetStream func(ctx context.Context, id string) (io.ReadCloser, error)

+ PutStream func(ctx context.Context, reader io.ReadCloser) (id string, _ error)

+ type Moderator interface

+ Close func()

+ Moderate func(content string) (bool, string, error)

+ type ModeratorNode struct

+ func NewModeratorNode(ctx context.Context, privKey ed25519.PrivateKey, psk security.PSK, ...) (_ *ModeratorNode, err error)

+ func (mn *ModeratorNode) GenericStream(nodeIdStr string, path stream.WarpRoute, data any) (_ []byte, err error)

+ func (mn *ModeratorNode) Node() warpnet.P2PNode

+ func (mn *ModeratorNode) NodeInfo() warpnet.NodeInfo

+ func (mn *ModeratorNode) Peerstore() warpnet.WarpPeerstore

+ func (mn *ModeratorNode) SelfStream(path stream.WarpRoute, data any) (_ []byte, err error)

+ func (mn *ModeratorNode) SimpleConnect(pi warpnet.WarpAddrInfo) error

+ func (mn *ModeratorNode) Start() (err error)

+ func (mn *ModeratorNode) Stop()

+ type ProviderCloser interface

+ type PubSubProvider interface

+ Close func() error

+ Run func(m pubsub.PubsubServerNodeConnector)

+ SubscribeModerationTopic func() error