Documentation
¶
Overview ¶
Package meshnode contains the mesh node and related interfaces.
Index ¶
- Variables
- type BootstrapOptions
- type Config
- type ConnectOptions
- type MockAnnouncer
- type Node
- type TestNode
- func (t *TestNode) Close(ctx context.Context) error
- func (t *TestNode) Connect(ctx context.Context, opts ConnectOptions) error
- func (t *TestNode) Credentials() []grpc.DialOption
- func (t *TestNode) Dial(ctx context.Context, network, address string) (net.Conn, error)
- func (t *TestNode) Discovery() libp2p.Announcer
- func (t *TestNode) Domain() string
- func (t *TestNode) ID() types.NodeID
- func (t *TestNode) Key() crypto.PrivateKey
- func (t *TestNode) LeaderID() (types.NodeID, error)
- func (t *TestNode) Network() meshnet.Manager
- func (t *TestNode) Plugins() plugins.Manager
- func (t *TestNode) Ready() <-chan struct{}
- func (t *TestNode) Started() bool
- func (t *TestNode) Storage() storage.Provider
Constants ¶
This section is empty.
Variables ¶
var ( // ErrNotOpen is returned when attempting to close a store that is not open. ErrNotOpen = fmt.Errorf("not open") // ErrOpen is returned when a store is already open. ErrOpen = fmt.Errorf("already open") // ErrNoLeader is returned when there is no Raft leader. ErrNoLeader = fmt.Errorf("no leader") )
Functions ¶
This section is empty.
Types ¶
type BootstrapOptions ¶
type BootstrapOptions struct { // Transport is the transport to use for bootstrapping the mesh. Transport transport.BootstrapTransport // IPv4Network is the IPv4 Network to use for the mesh. Defaults to // DefaultIPv4Network. IPv4Network string // IPv6Network is the IPv6 Network to use for the mesh. Defaults to // a randomly generated /32 prefix. IPv6Network string // MeshDomain is the domain of the mesh network. Defaults to // DefaultMeshDomain. MeshDomain string // Admin is the ID of the administrator node. Defaults to "admin". Admin string // Servers are other node IDs that were bootstrapped with the same // transport. Servers []string // Voters are additional node IDs to assign voter permissions to. Voters []string // DisableRBAC disables RBAC for the mesh. DisableRBAC bool // DefaultNetworkPolicy is the default network policy for the mesh. // If empty, DefaultNetworkPolicy will be used. DefaultNetworkPolicy string // Force is true if the node should force bootstrap. Force bool }
BootstrapOptions are options for bootstrapping the mesh when connecting for the first time.
func (BootstrapOptions) MarshalJSON ¶ added in v0.11.2
func (b BootstrapOptions) MarshalJSON() ([]byte, error)
type Config ¶
type Config struct { // NodeID is the node ID to use. If empty, the one from the raft // instance will be used. NodeID string // Credentials are gRPC credentials to use when dialing other nodes // in the mesh. Credentials []grpc.DialOption // Key is the private key to use for WireGuard and libp2p connections. // This can be nil, in which case one will be generated when Connect // is called. Key crypto.PrivateKey // HeartbeatPurgeThreshold is the number of failed heartbeats before // assuming a peer is offline. This is only applicable when currently // the leader of the raft group. HeartbeatPurgeThreshold int // ZoneAwarenessID is an to use with zone-awareness to determine // peers in the same LAN segment. ZoneAwarenessID string // UseMeshDNS will attempt to set the system DNS to any discovered // DNS servers. This is only applicable when not serving MeshDNS // ourselves. UseMeshDNS bool // LocalMeshDNSAddr is the address MeshDNS is listening on locally. LocalMeshDNSAddr string // LocalDNSOnly will only use the local MeshDNS server for DNS // resolution. This is only applicable when UseMeshDNS is true. LocalDNSOnly bool // DisableIPv4 is true if IPv4 should be disabled. DisableIPv4 bool // DisableIPv6 is true if IPv6 should be disabled. DisableIPv6 bool // DisableDefaultIPAM disables the default IPAM plugin. DisableDefaultIPAM bool // DefaultIPAMStaticIPv4 is a map of node names to IPv4 addresses. DefaultIPAMStaticIPv4 map[string]string }
Config contains the configurations for a new mesh connection.
type ConnectOptions ¶
type ConnectOptions struct { // StorageProvider is the underlying storage provider to use. StorageProvider storage.Provider // Features are the features to broadcast to others in the mesh. Features []*v1.FeaturePort // Plugins is a map of plugins to use. Plugins map[string]plugins.Plugin // JoinRoundTripper is the round tripper to use for joining the mesh. JoinRoundTripper transport.JoinRoundTripper // LeaveRoundTripper is the round tripper to use for leaving the mesh. LeaveRoundTripper transport.LeaveRoundTripper // NetworkOptions are options for the network manager NetworkOptions meshnet.Options // MaxJoinRetries is the maximum number of join retries. MaxJoinRetries int // GRPCAdvertisePort is the port to advertise for gRPC connections. GRPCAdvertisePort int // MeshDNSAdvertisePort is the port to advertise for MeshDNS connections. MeshDNSAdvertisePort int // PrimaryEndpoint is a publicly accessible address to broadcast as the // primary endpoint for this node. This is used for discovery and // connection into the mesh. If left unset, the node will be assumed to be // behind a NAT. PrimaryEndpoint netip.Addr // WireGuardEndpoints are endpoints to advertise for WireGuard connections. WireGuardEndpoints []netip.AddrPort // RequestVote requests a vote in Raft elections. RequestVote bool // RequestObserver requests to be an observer in Raft elections. RequestObserver bool // Routes are additional routes to broadcast to the mesh. Routes []netip.Prefix // DirectPeers are a map of peers to connect to directly. The values // are the prefered transport to use. DirectPeers map[types.NodeID]v1.ConnectProtocol // Bootstrap are options for bootstrapping the mesh when connecting for // the first time. Bootstrap *BootstrapOptions // PreferIPv6 is true if IPv6 should be preferred over IPv4. PreferIPv6 bool // Multiaddrs are the multiaddrs to advertise for this node. Multiaddrs []multiaddr.Multiaddr }
ConnectOptions are options for opening the connection to the mesh.
func (ConnectOptions) MarshalJSON ¶ added in v0.11.2
func (c ConnectOptions) MarshalJSON() ([]byte, error)
type MockAnnouncer ¶ added in v0.10.5
type MockAnnouncer struct {
// contains filtered or unexported fields
}
MockAnnouncer is a mock announcer that tracks state internally but does not perform any actual announcements.
func (*MockAnnouncer) AnnounceToDHT ¶ added in v0.10.5
func (m *MockAnnouncer) AnnounceToDHT(ctx context.Context, opts libp2p.AnnounceOptions) error
AnnounceToDHT should announce the join protocol to the DHT, such that it can be used by a libp2p transport.JoinRoundTripper.
type Node ¶
type Node interface { // Dialer is the dialer for all connections. transport.Dialer // NodeDialer is the dialer for node RPC connections. transport.NodeDialer // LeaderDialer is the dialer for leader RPC connections. transport.LeaderDialer // ID returns the node ID. ID() types.NodeID // Started returns true if the mesh is started. Started() bool // Domain returns the domain of the mesh network. Domain() string // Key returns the private key used for WireGuard and libp2p connections. Key() crypto.PrivateKey // Connect opens the connection to the mesh. This must be called before // other methods can be used. Connect(ctx context.Context, opts ConnectOptions) error // Ready returns a channel that will be closed when the mesh is ready. // Ready is defined as having a leader and knowing its address. Ready() <-chan struct{} // Close closes the connection to the mesh and shuts down the storage. Close(ctx context.Context) error // Credentials returns the gRPC credentials to use for dialing the mesh. Credentials() []grpc.DialOption // LeaderID returns the current Raft leader ID. LeaderID() (types.NodeID, error) // Storage returns the underlying storage provider. Storage() storage.Provider // Network returns the Network manager. Network() meshnet.Manager // Plugins returns the Plugin manager. Plugins() plugins.Manager }
Node is the connection to the Webmesh. It controls raft consensus, plugins, data storage, and WireGuard connections.
func NewSingleNodeTestMesh ¶ added in v0.10.5
NewTestNode creates a new test mesh and waits for it to be ready. The context is used to enforce startup timeouts.
func NewTestNode ¶
NewTestNode creates a new test mesh node. It is not started and proper methods will return errors. A proper join round tripper must be supllied to the connect method.
func NewTestNodeWithLogger ¶ added in v0.10.5
NewTestNodeWithLogger creates a new test mesh node with a logger. It is not started and proper methods will return errors.
type TestNode ¶ added in v0.10.5
type TestNode struct { transport.NodeDialer transport.LeaderDialer // contains filtered or unexported fields }
TestNode is a mesh node for testing.
func (*TestNode) Close ¶ added in v0.10.5
Close closes the connection to the mesh and shuts down the storage.
func (*TestNode) Connect ¶ added in v0.10.5
func (t *TestNode) Connect(ctx context.Context, opts ConnectOptions) error
Connect opens the connection to the mesh. This must be called before other methods can be used.
func (*TestNode) Credentials ¶ added in v0.10.5
func (t *TestNode) Credentials() []grpc.DialOption
Credentials returns the gRPC credentials to use for dialing the mesh.
func (*TestNode) Discovery ¶ added in v0.10.5
Discovery returns the interface libp2p.Announcer for announcing the mesh to the discovery service.
func (*TestNode) Key ¶ added in v0.10.5
func (t *TestNode) Key() crypto.PrivateKey
Key returns the private key used for WireGuard and libp2p connections.
func (*TestNode) Ready ¶ added in v0.10.5
func (t *TestNode) Ready() <-chan struct{}
Ready returns a channel that will be closed when the mesh is ready. Ready is defined as having a leader and knowing its address.