moderator

Jun 27, 2025

Changes in this version

+ type Moderator interface

+ Close func()

+ Moderate func(content string) (moderation.ModerationResult, moderation.ModerationReason, error)

type PubSubProvider

+ SubscribeModerationTopic func() error

Jun 25, 2025

Changes in this version

type ConsensusServicer

+ AskValidation func(data event.ValidationEvent) error

Jun 23, 2025

Changes in this version

type ModeratorNode

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

Jun 22, 2025

Changes in this version

+ type ConsensusServicer interface

+ Close func()

+ Start func(data event.ValidationEvent) error

+ Validate func(data []byte, _ warpnet.WarpStream) (any, error)

+ ValidationResult func(data []byte, s warpnet.WarpStream) (any, error)

Jun 21, 2025

Changes in this version

type DistributedStorer

+ Close func() error

type ModeratorNode

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

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

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

+ type Streamer interface

+ Send func(peerAddr warpnet.WarpAddrInfo, r stream.WarpRoute, data []byte) ([]byte, error)

Jun 21, 2025

Changes in this version

+ type ClientNodeStreamer interface

+ ClientStream func(nodeId string, path string, data any) (_ []byte, err 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

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

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

+ type ModeratorNode struct

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

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

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

+ func (bn *ModeratorNode) Start() error

+ func (bn *ModeratorNode) Stop()

+ type ProviderCloser interface

+ type PubSubProvider interface

+ Close func() error

+ PublishUpdateToFollowers func(ownerId string, msg event.Message) (err error)

+ Run func(m pubsub.PubsubServerNodeConnector, clientNode pubsub.PubsubClientNodeStreamer)