bootstrap

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 20, 2025 License: AGPL-3.0, AGPL-3.0-or-later Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BootstrapNode 

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

func NewBootstrapNode 

func NewBootstrapNode(
	ctx context.Context,
	privKey ed25519.PrivateKey,
	psk security.PSK,
	selfHashHex string,
	interruptChan chan os.Signal,
) (_ *BootstrapNode, err error)

func (*BootstrapNode) GenericStream 

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

func (*BootstrapNode) Network added in v0.3.110 

func (bn *BootstrapNode) Network() warpnet.WarpNetwork

func (*BootstrapNode) Node added in v0.3.110 

func (bn *BootstrapNode) Node() warpnet.P2PNode

func (*BootstrapNode) NodeInfo added in v0.3.8 

func (bn *BootstrapNode) NodeInfo() warpnet.NodeInfo

func (*BootstrapNode) Peerstore added in v0.3.110 

func (bn *BootstrapNode) Peerstore() warpnet.WarpPeerstore

func (*BootstrapNode) SelfStream added in v0.3.114 

func (bn *BootstrapNode) SelfStream(path stream.WarpRoute, data any) (_ []byte, err error)

func (*BootstrapNode) SimpleConnect added in v0.3.110 

func (bn *BootstrapNode) SimpleConnect(info warpnet.WarpAddrInfo) error

func (*BootstrapNode) Start 

func (bn *BootstrapNode) Start() (err error)

func (*BootstrapNode) Stop 

func (bn *BootstrapNode) Stop()

type ConsensusServicer added in v0.3.76 

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 

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

type DistributedHashTableCloser 

type DistributedHashTableCloser interface {
	Close()
}

type ProviderCloser 

type ProviderCloser interface {
	io.Closer
}

type PubSubProvider 

type PubSubProvider interface {
	Run(m pubsub.PubsubServerNodeConnector)
	Close() error
	PublishValidationRequest(bt []byte) (err error)
	GetConsensusTopicSubscribers() []warpnet.WarpAddrInfo
	OwnerID() string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.