core

package
v0.0.0-...-5ecf247 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2024 License: LGPL-3.0 Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ProtocolVersionMajor uint16 = 0
	ProtocolVersionMinor uint16 = 5
)
View Source 
const ErrLinkAlreadyConfigured = linkError("peer is already configured")
View Source 
const ErrLinkMaxBackoffInvalid = linkError("max backoff duration invalid")
View Source 
const ErrLinkNotConfigured = linkError("peer is not configured")
View Source 
const ErrLinkPasswordInvalid = linkError("password is invalid")
View Source 
const ErrLinkPinnedKeyInvalid = linkError("pinned public key is invalid")
View Source 
const ErrLinkPriorityInvalid = linkError("priority value is invalid")
View Source 
const ErrLinkUnrecognisedSchema = linkError("link schema unknown")

Variables

This section is empty.

Functions

This section is empty.

Types

type AddHandler 

type AddHandler interface {
	AddHandler(name, desc string, args []string, handlerfunc AddHandlerFunc) error
}

type AddHandlerFunc 

type AddHandlerFunc func(json.RawMessage) (interface{}, error)

type AllowedPublicKey 

type AllowedPublicKey ed25519.PublicKey

type Core 

type Core struct {
	// This is the main data structure that holds everything else for a node
	// We're going to keep our own copy of the provided config - that way we can
	// guarantee that it will be covered by the mutex
	phony.Inbox
	*iwe.PacketConn
	// contains filtered or unexported fields
}

The Core object represents the Ruvmeshnet node. You should create a Core object for each Ruvmeshnet node you plan to run.

func New 

func New(cert *tls.Certificate, logger Logger, opts ...SetupOption) (*Core, error)

func (*Core) AddPeer 

func (c *Core) AddPeer(u *url.URL, sintf string) error

AddPeer adds a peer. This should be specified in the peer URI format, e.g.: 

tcp://a.b.c.d:e
socks://a.b.c.d:e/f.g.h.i:j

This adds the peer to the peer list, so that they will be called again if the connection drops.

func (*Core) Address 

func (c *Core) Address() net.IP

Address gets the IPv6 address of the Ruvmeshnet node. This is always a /128 address. The IPv6 address is only relevant when the node is operating as an IP router and often is meaningless when embedded into an application, unless that application also implements either VPN functionality or deals with IP packets specifically.

func (*Core) CallPeer 

func (c *Core) CallPeer(u *url.URL, sintf string) error

CallPeer calls a peer once. This should be specified in the peer URI format, e.g.: 

tcp://a.b.c.d:e
socks://a.b.c.d:e/f.g.h.i:j

This does not add the peer to the peer list, so if the connection drops, the peer will not be called again automatically.

func (*Core) GetPaths 

func (c *Core) GetPaths() []PathEntryInfo

func (*Core) GetPeers 

func (c *Core) GetPeers() []PeerInfo

func (*Core) GetSelf 

func (c *Core) GetSelf() SelfInfo

func (*Core) GetSessions 

func (c *Core) GetSessions() []SessionInfo

func (*Core) GetTree 

func (c *Core) GetTree() []TreeEntryInfo

func (*Core) Listen 

func (c *Core) Listen(u *url.URL, sintf string) (*Listener, error)

Listen starts a new listener (either TCP or TLS). The input should be a url.URL parsed from a string of the form e.g. "tcp://a.b.c.d:e". In the case of a link-local address, the interface should be provided as the second argument.

func (*Core) MTU 

func (c *Core) MTU() uint64

func (*Core) PublicKey 

func (c *Core) PublicKey() ed25519.PublicKey

func (*Core) ReadFrom 

func (c *Core) ReadFrom(p []byte) (n int, from net.Addr, err error)

func (*Core) RemovePeer 

func (c *Core) RemovePeer(u *url.URL, sintf string) error

RemovePeer removes a peer. The peer should be specified in URI format, see AddPeer. The peer is not disconnected immediately.

func (*Core) RetryPeersNow 

func (c *Core) RetryPeersNow()

func (*Core) SetAdmin 

func (c *Core) SetAdmin(a AddHandler) error

SetAdmin must be called after Init and before Start. It sets the admin handler for NodeInfo and the Debug admin functions.

func (*Core) SetLogger 

func (c *Core) SetLogger(log Logger)

SetLogger sets the output logger of the Ruvmeshnet node after startup. This may be useful if you want to redirect the output later. Note that this expects a Logger from the github.com/gologme/log package and not from Go's built-in log package.

func (*Core) SetPathNotify 

func (c *Core) SetPathNotify(notify func(ed25519.PublicKey))

func (*Core) Stop 

func (c *Core) Stop()

Stop shuts down the Ruvmeshnet node.

func (*Core) Subnet 

func (c *Core) Subnet() net.IPNet

Subnet gets the routed IPv6 subnet of the Ruvmeshnet node. This is always a /64 subnet. The IPv6 subnet is only relevant when the node is operating as an IP router and often is meaningless when embedded into an application, unless that application also implements either VPN functionality or deals with IP packets specifically.

func (*Core) WriteTo 

func (c *Core) WriteTo(p []byte, addr net.Addr) (n int, err error)

type DebugGetPeersRequest 

type DebugGetPeersRequest struct {
	Key string `json:"key"`
}

type DebugGetPeersResponse 

type DebugGetPeersResponse map[string]interface{}

type DebugGetSelfRequest 

type DebugGetSelfRequest struct {
	Key string `json:"key"`
}

type DebugGetSelfResponse 

type DebugGetSelfResponse map[string]interface{}

type DebugGetTreeRequest 

type DebugGetTreeRequest struct {
	Key string `json:"key"`
}

type DebugGetTreeResponse 

type DebugGetTreeResponse map[string]interface{}

type GetNodeInfoRequest 

type GetNodeInfoRequest struct {
	Key string `json:"key"`
}

type GetNodeInfoResponse 

type GetNodeInfoResponse map[string]json.RawMessage

type ListenAddress 

type ListenAddress string

type Listener 

type Listener struct {
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

func (*Listener) Addr 

func (l *Listener) Addr() net.Addr

func (*Listener) Close 

func (l *Listener) Close() error

type Logger 

type Logger interface {
	Printf(string, ...interface{})
	Println(...interface{})
	Infof(string, ...interface{})
	Infoln(...interface{})
	Warnf(string, ...interface{})
	Warnln(...interface{})
	Errorf(string, ...interface{})
	Errorln(...interface{})
	Debugf(string, ...interface{})
	Debugln(...interface{})
	Traceln(...interface{})
}

type NodeInfo 

type NodeInfo map[string]interface{}

type NodeInfoPrivacy 

type NodeInfoPrivacy bool

type PathEntryInfo 

type PathEntryInfo struct {
	Key      ed25519.PublicKey
	Path     []uint64
	Sequence uint64
}

type Peer 

type Peer struct {
	URI             string
	SourceInterface string
}

type PeerInfo 

type PeerInfo struct {
	URI           string
	Up            bool
	Inbound       bool
	LastError     error
	LastErrorTime time.Time
	Key           ed25519.PublicKey
	Root          ed25519.PublicKey
	Coords        []uint64
	Port          uint64
	Priority      uint8
	RXBytes       uint64
	TXBytes       uint64
	Uptime        time.Duration
}

type SelfInfo 

type SelfInfo struct {
	Key            ed25519.PublicKey
	RoutingEntries uint64
}

type SessionInfo 

type SessionInfo struct {
	Key     ed25519.PublicKey
	RXBytes uint64
	TXBytes uint64
	Uptime  time.Duration
}

type SetupOption 

type SetupOption interface {
	// contains filtered or unexported methods
}

type TreeEntryInfo 

type TreeEntryInfo struct {
	Key      ed25519.PublicKey
	Parent   ed25519.PublicKey
	Sequence uint64
}

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.