moderator

type ConsensusServicer interface {
	Start(streamer consensus.ConsensusStreamer) (err error)
	Close()
	AskValidation(data event.ValidationEvent)
	Validate(ev event.ValidationEvent) error
	ValidationResult(ev event.ValidationResultEvent) error
}

type DiscoveryHandler interface {
	HandlePeerFound(pi warpnet.WarpAddrInfo)
	Run(n discovery.DiscoveryInfoStorer) error
	Close()
}

type DistributedHashTableCloser interface {
	Close()
}

type DistributedStorer interface {
	GetStream(ctx context.Context, id string) (io.ReadCloser, error)
	PutStream(ctx context.Context, reader io.ReadCloser) (id string, _ error)
	Close() error
}

type Moderator interface {
	Moderate(content string) (bool, string, error)
	Close()
}

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

type ProviderCloser interface {
	io.Closer
}

type PubSubProvider interface {
	Run(m pubsub.PubsubServerNodeConnector)
	Close() error
	SubscribeModerationTopic() error
}