mesh

package

Go to main page

Versions in this module

v0

v0.6.6

Sep 25, 2023

v0.6.5

Sep 24, 2023

v0.6.4

Sep 19, 2023

v0.6.3

Sep 19, 2023

v0.6.2

Sep 14, 2023

v0.6.1

Sep 11, 2023

v0.6.0

Sep 11, 2023

Changes in this version

+ type Node interface

+ Close func(ctx context.Context) error

+ Connect func(ctx context.Context, opts ConnectOptions) error

+ Credentials func() []grpc.DialOption

+ Discovery func() libp2p.Announcer

+ Domain func() string

+ ID func() string

+ Key func() crypto.PrivateKey

+ LeaderID func() (string, error)

+ Network func() meshnet.Manager

+ Plugins func() plugins.Manager

+ Raft func() raft.Raft

+ Ready func() <-chan struct{}

+ Storage func() storage.MeshStorage

v0.5.1

Sep 7, 2023

Changes in this version

type ConnectOptions

+ Multiaddrs []multiaddr.Multiaddr

v0.5.0

Sep 4, 2023

Changes in this version

type Config

+ Key crypto.Key

type Mesh

+ Key func() crypto.Key

v0.4.1

Sep 3, 2023

Changes in this version

type Mesh

+ Discovery func() libp2p.Announcer

v0.4.0

Sep 1, 2023

Changes in this version

type DiscoveryOptions

+ ConnectTimeout time.Duration

v0.3.4

Aug 31, 2023

Changes in this version

type DiscoveryOptions

+ LocalAddrs []multiaddr.Multiaddr

v0.3.3

Aug 31, 2023

Changes in this version

+ const DefaultBootstrapPort

v0.3.2

Aug 30, 2023

v0.3.1

Aug 30, 2023

Changes in this version

+ const DefaultBootstrapListenAddress

+ const DefaultMeshAdmin

type BootstrapOptions

+ Transport transport.BootstrapTransport

+ type Config struct

+ Credentials []grpc.DialOption

+ DisableIPv4 bool

+ DisableIPv6 bool

+ HeartbeatPurgeThreshold int

+ KeyRotationInterval time.Duration

+ LocalMeshDNSAddr string

+ NodeID string

+ UseMeshDNS bool

+ WireGuardKeyFile string

+ ZoneAwarenessID string

type ConnectOptions

+ Bootstrap *BootstrapOptions

+ DirectPeers []string

+ Discovery *DiscoveryOptions

+ GRPCAdvertisePort int

+ JoinRoundTripper transport.JoinRoundTripper

+ MaxJoinRetries int

+ MeshDNSAdvertisePort int

+ NetworkOptions net.Options

+ Plugins map[string]plugins.Plugin

+ PreferIPv6 bool

+ PrimaryEndpoint netip.Addr

+ Raft raft.Raft

+ RequestObserver bool

+ RequestVote bool

+ Routes []netip.Prefix

+ WireGuardEndpoints []netip.AddrPort

type DiscoveryOptions

+ BootstrapServers []string

+ DiscoveryTTL time.Duration

type Mesh

+ Connect func(ctx context.Context, opts ConnectOptions) error

+ Credentials func() []grpc.DialOption

v0.3.0

Aug 28, 2023

Changes in this version

+ type ConnectOptions struct

+ Features []v1.Feature

+ MeshStorage storage.MeshStorage

+ RaftStorage storage.RaftStorage

+ RaftTransport transport.RaftTransport

type Mesh

+ LeaderID func() (string, error)

v0.2.7

Aug 23, 2023

Changes in this version

type Mesh

+ AnnounceDHT func(context.Context, *DiscoveryOptions) error

+ LeaveDHT func(ctx context.Context, psk string) error

v0.2.6

Aug 23, 2023

Changes in this version

+ const DiscoveryAnnounceEnvVar

+ const DiscoveryKadBootstrapServersEnvVar

+ const DiscoveryPSKEnvVar

+ const DiscoveryUseKadDHTEnvVar

+ type DiscoveryOptions struct

+ Announce bool

+ KadBootstrapServers []string

+ PSK string

+ UseKadDHT bool

+ func NewDiscoveryOptions() *DiscoveryOptions

+ func (o *DiscoveryOptions) BindFlags(fl *flag.FlagSet, prefix ...string)

+ func (o *DiscoveryOptions) DeepCopy() *DiscoveryOptions

+ func (o *DiscoveryOptions) Validate() error

type Options

+ Discovery *DiscoveryOptions

v0.2.5

Aug 22, 2023

v0.2.4

Aug 19, 2023

Changes in this version

+ const BootstrapDisableRBACEnvVar

type BootstrapOptions

+ DisableRBAC bool

v0.2.3

Aug 19, 2023

v0.2.2

Aug 19, 2023

v0.2.1

Aug 16, 2023

v0.2.0

Aug 16, 2023

Changes in this version

+ const JoinAsObserverEnvVar

+ const JoinCampfireURIEnvVar

+ const WaitCampfireURIEnvVar

type MeshOptions

+ JoinAsObserver bool

+ JoinCampfireURI string

+ WaitCampfireURI string

type Options

+ func (o *Options) IsRaftMember() bool

v0.1.13

Aug 14, 2023

Changes in this version

type AuthOptions

+ func (o *AuthOptions) DeepCopy() *AuthOptions

type BootstrapOptions

+ func (o *BootstrapOptions) DeepCopy() *BootstrapOptions

+ type CampfireConnHandler func(context.Context, io.ReadWriteCloser)

type Mesh

+ LeaveCampfire func(ctx context.Context, id string) error

+ StartCampfire func(ctx context.Context, opts campfire.Options, hdlr CampfireConnHandler) error

type MeshOptions

+ func (o *MeshOptions) DeepCopy() *MeshOptions

type Options

+ func (o *Options) DeepCopy() *Options

type TLSOptions

+ func (o *TLSOptions) DeepCopy() *TLSOptions

type WireGuardOptions

+ func (o *WireGuardOptions) DeepCopy() *WireGuardOptions

v0.1.12

Aug 13, 2023

v0.1.11

Aug 13, 2023

v0.1.10

Aug 13, 2023

v0.1.9

Aug 13, 2023

v0.1.8

Aug 13, 2023

v0.1.7

Aug 13, 2023

Changes in this version

+ const JoinCampfirePSKEnvVar

+ const JoinCampfireTURNServersEnvVar

+ const WaitCampfirePSKEnvVar

+ const WaitCampfireTURNServersEnvVar

type MeshOptions

+ JoinCampfirePSK string

+ JoinCampfireTURNServers []string

+ WaitCampfirePSK string

+ WaitCampfireTURNServers []string

v0.1.6

Aug 12, 2023

v0.1.5

Aug 11, 2023

v0.1.4

Aug 8, 2023

v0.1.3

Aug 8, 2023

Changes in this version

+ const HeartbeatPurgeThresholdEnvVar

type MeshOptions

+ HeartbeatPurgeThreshold int

v0.1.2

Aug 5, 2023

Changes in this version

+ const DefaultGRPCPort

+ var ErrNoLeader = fmt.Errorf("no leader")

type Mesh

+ func NewWithLogger(opts *Options, log *slog.Logger) (Mesh, error)

+ Dial func(ctx context.Context, nodeID string) (*grpc.ClientConn, error)

+ DialLeader func(ctx context.Context) (*grpc.ClientConn, error)

+ Ready func() <-chan struct{}

type MeshOptions

+ GRPCAdvertisePort int

+ MeshDNSAdvertisePort int

type Options

+ func NewDefaultOptions() *Options

v0.1.1

Aug 2, 2023

v0.1.0

Jul 31, 2023

v0.0.28

Jul 31, 2023

v0.0.27

Jul 31, 2023

v0.0.26

Jul 30, 2023

v0.0.25

Jul 30, 2023

Changes in this version

+ const DNSAdvertisePortEnvVar

+ const UseMeshDNSEnvVar

type Mesh

+ Network func() net.Manager

type MeshOptions

+ MeshDNSPort int

+ UseMeshDNS bool

v0.0.24

Jul 29, 2023

v0.0.23

Jul 29, 2023

v0.0.22

Jul 28, 2023

Changes in this version

+ const AdvertiseAddressEnvVar

+ const AuthBasicEnabledEnvVar

+ const AuthBasicPasswordEnvVar

+ const AuthBasicUsernameEnvVar

+ const BootstrapAdminEnvVar

+ const BootstrapDefaultNetworkPolicyEnvVar

+ const BootstrapEnabledEnvVar

+ const BootstrapIPv4NetworkEnvVar

+ const BootstrapMeshDomainEnvVar

+ const BootstrapRestoreSnapshotEnvVar

+ const BootstrapServersEnvVar

+ const BootstrapServersGRPCPortsEnvVar

+ const BootstrapVotersEnvVar

+ const CAFileEnvVar

+ const DefaultAdminUser

+ const DefaultIPv4Network

+ const DefaultMeshDomain

+ const DefaultNetworkPolicy

+ const ForceBootstrapClusterEnvVar

+ const GRPCAdvertisePortEnvVar

+ const InsecureEnvVar

+ const InsecureSkipVerifyEnvVar

+ const JoinAddressEnvVar

+ const JoinAsVoterEnvVar

+ const JoinTimeoutEnvVar

+ const MTLSCertFileEnvVar

+ const MTLSEnabledEnvVar

+ const MTLSKeyFileEnvVar

+ const MaxJoinRetriesEnvVar

+ const NoIPv4EnvVar

+ const NoIPv6EnvVar

+ const NodeDirectPeersEnvVar

+ const NodeIDEnvVar

+ const NodeRoutesEnvVar

+ const PeerDiscoveryAddressesEnvVar

+ const PrimaryEndpointEnvVar

+ const VerifyChainOnlyEnvVar

+ const WireGuardEndpointsEnvVar

+ const WireGuardKeyFileEnvVar

+ const WireGuardKeyRotationIntervalEnvVar

+ const WireGuardRecordMetricsEnvVar

+ const WireGuardRecordMetricsIntervalEnvVar

+ const WireguardAllowedIPsEnvVar

+ const WireguardForceNameEnvVar

+ const WireguardForceTUNEnvVar

+ const WireguardListenPortEnvVar

+ const WireguardMTUEnvVar

+ const WireguardMasqueradeEnvVar

+ const WireguardModprobeEnvVar

+ const WireguardNameEnvVar

+ const WireguardPersistentKeepaliveEnvVar

+ const ZoneAwarenessIDEnvVar

+ var ErrNotOpen = fmt.Errorf("not open")

+ var ErrOpen = fmt.Errorf("already open")

+ type AuthOptions struct

+ Basic *BasicAuthOptions

+ LDAP *LDAPAuthOptions

+ MTLS *MTLSOptions

+ func NewAuthOptions() *AuthOptions

+ func (o *AuthOptions) BindFlags(fl *flag.FlagSet)

+ func (o *AuthOptions) Validate() error

+ type BasicAuthOptions struct

+ Password string

+ Username string

+ type BootstrapOptions struct

+ Admin string

+ AdvertiseAddress string

+ DefaultNetworkPolicy string

+ Enabled bool

+ Force bool

+ IPv4Network string

+ MeshDomain string

+ RestoreSnapshot string

+ Servers map[string]string

+ ServersGRPCPorts map[string]int

+ Voters string

+ func NewBootstrapOptions() *BootstrapOptions

+ func (o *BootstrapOptions) BindFlags(fl *flag.FlagSet)

+ func (o *BootstrapOptions) Validate() error

+ type LDAPAuthOptions struct

+ Password string

+ Username string

+ type MTLSOptions struct

+ CertData string

+ CertFile string

+ KeyData string

+ KeyFile string

+ type Mesh interface

+ Close func() error

+ Domain func() string

+ ID func() string

+ Leader func() (string, error)

+ LeaderRPCAddr func(ctx context.Context) (string, error)

+ Open func(context.Context) error

+ Plugins func() plugins.Manager

+ Raft func() raft.Raft

+ Storage func() storage.Storage

+ WireGuard func() wireguard.Interface

+ func New(opts *Options) (Mesh, error)

+ func NewTestCluster(ctx context.Context, numNodes int, startPort int) ([]Mesh, error)

+ func NewTestMesh(ctx context.Context) (Mesh, error)

+ type MeshOptions struct

+ DirectPeers []string

+ GRPCPort int

+ JoinAddress string

+ JoinAsVoter bool

+ MaxJoinRetries int

+ NoIPv4 bool

+ NoIPv6 bool

+ NodeID string

+ PeerDiscoveryAddresses []string

+ PrimaryEndpoint string

+ Routes []string

+ ZoneAwarenessID string

+ func NewMeshOptions() *MeshOptions

+ func (o *MeshOptions) BindFlags(fl *flag.FlagSet)

+ func (o *MeshOptions) Validate() error

+ type NetworkPolicy string

+ const NetworkPolicyAccept

+ const NetworkPolicyDeny

+ func (n NetworkPolicy) IsValid() bool

+ type Options struct

+ Auth *AuthOptions

+ Bootstrap *BootstrapOptions

+ Mesh *MeshOptions

+ Plugins *plugins.Options

+ Raft *raft.Options

+ TLS *TLSOptions

+ WireGuard *WireGuardOptions

+ func NewOptions() *Options

+ func (o *Options) BindFlags(fl *flag.FlagSet)

+ func (o *Options) TLSConfig() (*tls.Config, error)

+ func (o *Options) Validate() error

+ type TLSOptions struct

+ CAData string

+ CAFile string

+ Insecure bool

+ InsecureSkipVerify bool

+ VerifyChainOnly bool

+ func NewTLSOptions() *TLSOptions

+ func (o *TLSOptions) BindFlags(fl *flag.FlagSet)

+ type WireGuardOptions struct

+ Endpoints []string

+ ForceInterfaceName bool

+ ForceTUN bool

+ InterfaceName string

+ KeyFile string

+ KeyRotationInterval time.Duration

+ ListenPort int

+ MTU int

+ Masquerade bool

+ Modprobe bool

+ PersistentKeepAlive time.Duration

+ RecordMetrics bool

+ RecordMetricsInterval time.Duration

+ func NewWireGuardOptions() *WireGuardOptions

+ func (o *WireGuardOptions) BindFlags(fl *flag.FlagSet)

+ func (o *WireGuardOptions) Validate() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL