discovery

package
v0.6.136 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ErrChallengeMismatch         warpnet.WarpError = "challenge mismatch"
	ErrChallengeSignatureInvalid warpnet.WarpError = "invalid challenge signature"
)

Variables

This section is empty.

Functions

func NewBootstrapDiscoveryService 

func NewBootstrapDiscoveryService(ctx context.Context, m MetricsOnlineDiscoverer) *discoveryService

func NewDiscoveryService 

func NewDiscoveryService(
	ctx context.Context,
	userRepo UserStorer,
	nodeRepo NodeStorer,
	m MetricsOnlineDiscoverer,
) *discoveryService

Types

type DiscoveryHandler 

type DiscoveryHandler func(warpnet.WarpAddrInfo)

type DiscoveryInfoStorer 

type DiscoveryInfoStorer interface {
	NodeInfo() warpnet.NodeInfo
	Peerstore() warpnet.WarpPeerstore
	SimpleConnect(warpnet.WarpAddrInfo) error
	GenericStream(nodeId string, path stream.WarpRoute, data any) ([]byte, error)
}

type MetricsOnlineDiscoverer added in v0.6.127 

type MetricsOnlineDiscoverer interface {
	PushStatusOnline(nodeId string)
	PushStatusOffline(nodeId string)
}

type NodeStorer 

type NodeStorer interface {
	BlocklistRemove(peerId string) error
	IsBlocklisted(peerId string) bool
	Blocklist(peerId string) error
	BlocklistTerm(peerId string) (*database.BlocklistTerm, error)
}

type UserStorer 

type UserStorer interface {
	Create(user domain.User) (domain.User, error)
	Update(userId string, newUser domain.User) (domain.User, error)
	GetByNodeID(nodeID string) (user domain.User, err error)
}

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.