netceptor

package

Go to main page

Versions in this module

v1

v1.4.8

May 22, 2024

v1.4.7

May 9, 2024

v1.4.6

May 7, 2024

v1.4.5

Mar 21, 2024

v1.4.4

Feb 7, 2024

Changes in this version

type PacketConn

+ func (pc *PacketConn) GetReadDeadline() time.Time

type PacketConner

+ GetReadDeadline func() time.Time

v1.4.3

Nov 22, 2023

v1.4.2

Oct 13, 2023

Changes in this version

+ func CreateTraceroute(ctx context.Context, s NetcForTraceroute, target string) <-chan *TracerouteResult

+ func SendPing(ctx context.Context, s NetcForPing, target string, hopsToLive byte) (time.Duration, string, error)

+ type NetcForPacketConn interface

+ AddLocalServiceAdvertisement func(service string, connType byte, tags map[string]string)

+ AddNameHash func(name string) uint64

+ Context func() context.Context

+ GetEphemeralService func() string

+ GetListenerLock func() *sync.RWMutex

+ GetListenerRegistry func() map[string]*PacketConn

+ GetLogger func() *logger.ReceptorLogger

+ GetNetworkName func() string

+ GetUnreachableBroker func() *utils.Broker

+ MaxForwardingHops func() byte

+ NodeID func() string

+ RemoveLocalServiceAdvertisement func(service string) error

+ SendMessageWithHopsToLive func(fromService string, toNode string, toService string, data []byte, ...) error

+ type NetcForPing interface

+ Context func() context.Context

+ ListenPacket func(service string) (PacketConner, error)

+ NewAddr func(target string, service string) Addr

+ NodeID func() string

+ type NetcForTraceroute interface

+ Context func() context.Context

+ MaxForwardingHops func() byte

+ Ping func(ctx context.Context, target string, hopsToLive byte) (time.Duration, string, error)

type Netceptor

+ func (s *Netceptor) AddLocalServiceAdvertisement(service string, connType byte, tags map[string]string)

+ func (s *Netceptor) AddNameHash(name string) uint64

+ func (s *Netceptor) GetEphemeralService() string

+ func (s *Netceptor) GetListenerLock() *sync.RWMutex

+ func (s *Netceptor) GetListenerRegistry() map[string]*PacketConn

+ func (s *Netceptor) GetLogger() *logger.ReceptorLogger

+ func (s *Netceptor) GetNameFromHash(namehash uint64) (string, error)

+ func (s *Netceptor) GetNetworkName() string

+ func (s *Netceptor) GetUnreachableBroker() *utils.Broker

+ func (s *Netceptor) RemoveLocalServiceAdvertisement(service string) error

+ func (s *Netceptor) SendMessageWithHopsToLive(fromService string, toNode string, toService string, data []byte, ...) error

type PacketConn

+ func NewPacketConn(s NetcForPacketConn, service string, connTypeDatagram byte) *PacketConn

+ func NewPacketConnWithConst(s NetcForPacketConn, service string, advertise bool, adtags map[string]string, ...) *PacketConn

+ func (pc *PacketConn) Cancel() *context.CancelFunc

+ func (pc *PacketConn) GetHopsToLive() byte

+ func (pc *PacketConn) GetLogger() *logger.ReceptorLogger

+ func (pc *PacketConn) StartUnreachable()

+ type PacketConner interface

+ Cancel func() *context.CancelFunc

+ Close func() error

+ GetHopsToLive func() byte

+ GetLogger func() *logger.ReceptorLogger

+ LocalAddr func() net.Addr

+ LocalService func() string

+ ReadFrom func(p []byte) (int, net.Addr, error)

+ SetDeadline func(t time.Time) error

+ SetHopsToLive func(hopsToLive byte)

+ SetReadDeadline func(t time.Time) error

+ SetWriteDeadline func(t time.Time) error

+ StartUnreachable func()

+ SubscribeUnreachable func(doneChan chan struct{}) chan UnreachableNotification

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

v1.4.1

Jun 7, 2023

v1.4.0

May 24, 2023

Changes in this version

+ type BackendInfo struct

type Netceptor

+ Logger *logger.ReceptorLogger

+ type TLSClientConfig struct

+ Cert string

+ InsecureSkipVerify bool

+ Key string

+ MinTLS13 bool

+ Name string

+ PinnedServerCert []string

+ RootCAs string

+ SkipReceptorNamesCheck bool

+ func (cfg TLSClientConfig) Prepare() error

+ func (cfg TLSClientConfig) PrepareTLSClientConfig(n *Netceptor) (tlscfg *tls.Config, pinnedFingerprints [][]byte, err error)

+ type TLSServerConfig struct

+ Cert string

+ ClientCAs string

+ Key string

+ MinTLS13 bool

+ Name string

+ PinnedClientCert []string

+ RequireClientCert bool

+ SkipReceptorNamesCheck bool

+ func (cfg TLSServerConfig) Prepare() error

+ func (cfg TLSServerConfig) PrepareTLSServerConfig(n *Netceptor) (*tls.Config, error)

v1.3.1

Feb 3, 2023

v1.3.0

Dec 3, 2022

Changes in this version

type Netceptor

+ func (s *Netceptor) SetMaxConnectionIdleTime(userDefinedMaxIdleConnectionTimeout string) error

v1.2.3

May 2, 2022

v1.2.2

Apr 25, 2022

v1.2.1

Mar 29, 2022

v1.2.0

Mar 21, 2022

Changes in this version

+ var KeepAliveForQuicConnections = true

+ var MaxIdleTimeoutForQuicConnections = 30 * time.Second

+ func ReceptorVerifyFunc(tlscfg *tls.Config, pinnedFingerprints [][]byte, expectedHostname string, ...) func(rawCerts [][]byte, verifiedChains [][]*x509.Certificate) error

+ type ExpectedHostnameType int

+ const ExpectedHostnameTypeDNS

+ const ExpectedHostnameTypeReceptor

type Netceptor

+ func (s *Netceptor) Ping(ctx context.Context, target string, hopsToLive byte) (time.Duration, string, error)

+ func (s *Netceptor) Traceroute(ctx context.Context, target string) <-chan *TracerouteResult

+ type TracerouteResult struct

+ Err error

+ From string

+ Time time.Duration

+ type VerifyType int

v1.1.1

Nov 17, 2021

v1.1.0

Nov 12, 2021

Changes in this version

+ const ConnTypeDatagram

+ const ConnTypeStream

+ const ConnTypeStreamTLS

+ const MsgTypeData

+ const MsgTypeReject

+ const MsgTypeRoute

+ const MsgTypeServiceAdvertisement

+ const ProblemExpiredInTransit

+ const ProblemRejected

+ const ProblemServiceUnknown

+ const VerifyClient

+ const VerifyServer

+ var ErrTimeout error = &TimeoutError

+ func BackendAllowedPeers(peers []string) func(*backendInfo)

+ func BackendConnectionCost(cost float64) func(*backendInfo)

+ func BackendNodeCost(nodeCost map[string]float64) func(*backendInfo)

+ type Addr struct

+ func (a Addr) Network() string

+ func (a Addr) String() string

+ type Backend interface

+ Start func(context.Context, *sync.WaitGroup) (chan BackendSession, error)

+ type BackendSession interface

+ Close func() error

+ Recv func(time.Duration) ([]byte, error)

+ Send func([]byte) error

+ type CompareFunc func(md *MessageData) bool

+ type Conn struct

+ func (c *Conn) CancelRead()

+ func (c *Conn) Close() error

+ func (c *Conn) CloseConnection() error

+ func (c *Conn) LocalAddr() net.Addr

+ func (c *Conn) Read(b []byte) (n int, err error)

+ func (c *Conn) RemoteAddr() net.Addr

+ func (c *Conn) SetDeadline(t time.Time) error

+ func (c *Conn) SetReadDeadline(t time.Time) error

+ func (c *Conn) SetWriteDeadline(t time.Time) error

+ func (c *Conn) Write(b []byte) (n int, err error)

+ type ConnStatus struct

+ Cost float64

+ NodeID string

+ type ErrorFunc func(error, bool)

+ type ExternalBackend struct

+ func NewExternalBackend() (*ExternalBackend, error)

+ func (b *ExternalBackend) NewConnection(conn MessageConn, closeConnWithSession bool)

+ func (b *ExternalBackend) Start(ctx context.Context, wg *sync.WaitGroup) (chan BackendSession, error)

+ type ExternalSession struct

+ func (es *ExternalSession) Close() error

+ func (es *ExternalSession) Recv(timeout time.Duration) ([]byte, error)

+ func (es *ExternalSession) Send(data []byte) error

+ type FirewallResult int

+ const FirewallResultAccept

+ const FirewallResultContinue

+ const FirewallResultDrop

+ const FirewallResultReject

+ type FirewallRule struct

+ Action string

+ FromNode string

+ FromService string

+ ToNode string

+ ToService string

+ func (fr FirewallRule) BuildComps() []CompareFunc

+ type FirewallRuleData map[interface{}]interface

+ func (frd FirewallRuleData) ParseFirewallRule() (FirewallRuleFunc, error)

+ type FirewallRuleFunc func(*MessageData) FirewallResult

+ func ParseFirewallRules(rules []FirewallRuleData) ([]FirewallRuleFunc, error)

+ type Listener struct

+ func (li *Listener) Accept() (net.Conn, error)

+ func (li *Listener) Addr() net.Addr

+ func (li *Listener) Close() error

+ type MessageConn interface

+ Close func() error

+ ReadMessage func(ctx context.Context, timeout time.Duration) ([]byte, error)

+ SetReadDeadline func(t time.Time) error

+ WriteMessage func(ctx context.Context, data []byte) error

+ func MessageConnFromNetConn(conn net.Conn) MessageConn

+ func MessageConnFromWebsocketConn(conn *websocket.Conn) MessageConn

+ type MessageData struct

+ Data []byte

+ FromNode string

+ FromService string

+ HopsToLive byte

+ ToNode string

+ ToService string

+ type Netceptor struct

+ var MainInstance *Netceptor

+ func New(ctx context.Context, nodeID string) *Netceptor

+ func NewWithConsts(ctx context.Context, nodeID string, mtu int, routeUpdateTime time.Duration, ...) *Netceptor

+ func (s *Netceptor) AddBackend(backend Backend, modifiers ...func(*backendInfo)) error

+ func (s *Netceptor) AddFirewallRules(rules []FirewallRuleFunc, clearExisting bool) error

+ func (s *Netceptor) AddWorkCommand(command string, secure bool) error

+ func (s *Netceptor) BackendCount() int

+ func (s *Netceptor) BackendDone()

+ func (s *Netceptor) BackendWait()

+ func (s *Netceptor) CancelBackends()

+ func (s *Netceptor) Context() context.Context

+ func (s *Netceptor) Dial(node string, service string, tlscfg *tls.Config) (*Conn, error)

+ func (s *Netceptor) DialContext(ctx context.Context, node string, service string, tlscfg *tls.Config) (*Conn, error)

+ func (s *Netceptor) GetClientTLSConfig(name string, expectedHostName string, expectedHostNameType string) (*tls.Config, error)

+ func (s *Netceptor) GetServerTLSConfig(name string) (*tls.Config, error)

+ func (s *Netceptor) GetServiceInfo(nodeID string, service string) (*ServiceAdvertisement, bool)

+ func (s *Netceptor) Listen(service string, tlscfg *tls.Config) (*Listener, error)

+ func (s *Netceptor) ListenAndAdvertise(service string, tlscfg *tls.Config, tags map[string]string) (*Listener, error)

+ func (s *Netceptor) ListenContext(ctx context.Context, service string, tlscfg *tls.Config) (*Listener, error)

+ func (s *Netceptor) ListenContextAndAdvertise(ctx context.Context, service string, tlscfg *tls.Config, ...) (*Listener, error)

+ func (s *Netceptor) ListenPacket(service string) (*PacketConn, error)

+ func (s *Netceptor) ListenPacketAndAdvertise(service string, tags map[string]string) (*PacketConn, error)

+ func (s *Netceptor) MTU() int

+ func (s *Netceptor) MaxConnectionIdleTime() time.Duration

+ func (s *Netceptor) MaxForwardingHops() byte

+ func (s *Netceptor) NetceptorDone() <-chan struct{}

+ func (s *Netceptor) NewAddr(node string, service string) Addr

+ func (s *Netceptor) NodeID() string

+ func (s *Netceptor) PathCost(nodeID string) (float64, error)

+ func (s *Netceptor) RouteUpdateTime() time.Duration

+ func (s *Netceptor) SeenUpdateExpireTime() time.Duration

+ func (s *Netceptor) ServiceAdTime() time.Duration

+ func (s *Netceptor) SetClientTLSConfig(name string, config *tls.Config) error

+ func (s *Netceptor) SetServerTLSConfig(name string, config *tls.Config) error

+ func (s *Netceptor) Shutdown()

+ func (s *Netceptor) Status() Status

+ func (s *Netceptor) SubscribeRoutingUpdates() chan map[string]string

+ type PacketConn struct

+ func (pc *PacketConn) Close() error

+ func (pc *PacketConn) LocalAddr() net.Addr

+ func (pc *PacketConn) LocalService() string

+ func (pc *PacketConn) ReadFrom(p []byte) (n int, addr net.Addr, err error)

+ func (pc *PacketConn) SetDeadline(t time.Time) error

+ func (pc *PacketConn) SetHopsToLive(hopsToLive byte)

+ func (pc *PacketConn) SetReadDeadline(t time.Time) error

+ func (pc *PacketConn) SetWriteDeadline(t time.Time) error

+ func (pc *PacketConn) SubscribeUnreachable(doneChan chan struct{}) chan UnreachableNotification

+ func (pc *PacketConn) WriteTo(p []byte, addr net.Addr) (n int, err error)

+ type ReceptorCertNameError struct

+ ExpectedNode string

+ ValidNodes []string

+ func (rce ReceptorCertNameError) Error() string

+ type ServiceAdvertisement struct

+ ConnType byte

+ NodeID string

+ Service string

+ Tags map[string]string

+ Time time.Time

+ WorkCommands []WorkCommand

+ type Status struct

+ Advertisements []*ServiceAdvertisement

+ Connections []*ConnStatus

+ KnownConnectionCosts map[string]map[string]float64

+ NodeID string

+ RoutingTable map[string]string

+ type TimeoutError struct

+ func (e *TimeoutError) Error() string

+ func (e *TimeoutError) Temporary() bool

+ func (e *TimeoutError) Timeout() bool

+ type UnreachableMessage struct

+ FromNode string

+ FromService string

+ Problem string

+ ToNode string

+ ToService string

+ type UnreachableNotification struct

+ ReceivedFromNode string

+ type WorkCommand struct

+ Secure bool

+ WorkType string

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