bootstrap

type BasicValidator struct {
	OwnSelfHashHex string
}

type BootstrapNode struct {
	*base.WarpNode
	// contains filtered or unexported fields
}

type ClientNodeStreamer interface {
	ClientStream(nodeId string, path string, data any) (_ []byte, err error)
}

type ConsensusServicer interface {
	AskValidation(data event.ValidationEvent) error
	Validate(data []byte, _ warpnet.WarpStream) (any, error)
	ValidationResult(data []byte, s warpnet.WarpStream) (any, error)
}

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

type DistributedHashTableCloser interface {
	Close()
}

type ProviderCloser interface {
	io.Closer
}

type PubSubProvider interface {
	Run(m pubsub.PubsubServerNodeConnector, clientNode pubsub.PubsubClientNodeStreamer)
	PublishUpdateToFollowers(ownerId string, msg event.Message) (err error)
	Close() error
}