yggconn

Documentation

Index

• type Node
  • func Setup(instanceName, storageDirectory string) (*Node, error)
  • func (n *Node) Accept() (net.Conn, error)
  • func (n *Node) Addr() net.Addr
  • func (n *Node) Close() error
  • func (n *Node) CreateClient(base *setup.BaseDendrite) *gomatrixserverlib.Client
  • func (n *Node) CreateFederationClient(base *setup.BaseDendrite) *gomatrixserverlib.FederationClient
  • func (n *Node) DerivedServerName() string
  • func (n *Node) DerivedSessionName() string
  • func (n *Node) Dial(network, address string) (net.Conn, error)
  • func (n *Node) DialContext(ctx context.Context, network, address string) (net.Conn, error)
  • func (n *Node) Dialer(_, address string) (net.Conn, error)
  • func (n *Node) DialerContext(ctx context.Context, network, address string) (net.Conn, error)
  • func (n *Node) DisconnectMulticastPeers()
  • func (n *Node) DisconnectNonMulticastPeers()
  • func (n *Node) EncryptionPrivateKey() []byte
  • func (n *Node) EncryptionPublicKey() []byte
  • func (n *Node) KnownNodes() []gomatrixserverlib.ServerName
  • func (n *Node) PeerCount() int
  • func (n *Node) SessionCount() int
  • func (n *Node) SetMulticastEnabled(enabled bool)
  • func (n *Node) SetSessionFunc(f func(address string))
  • func (n *Node) SetStaticPeer(uri string) error
  • func (n *Node) SigningPrivateKey() ed25519.PrivateKey
  • func (n *Node) SigningPublicKey() ed25519.PublicKey
  • func (n *Node) Stop()
• type QUICStream
  • func (s QUICStream) LocalAddr() net.Addr
  • func (s QUICStream) RemoteAddr() net.Addr

Types

type Node

type Node struct {
	NewSession func(remote gomatrixserverlib.ServerName)
	// contains filtered or unexported fields
}

func Setup

func Setup(instanceName, storageDirectory string) (*Node, error)

nolint:gocyclo

func (*Node) Accept

func (n *Node) Accept() (net.Conn, error)

Implements net.Listener

func (*Node) Addr

func (n *Node) Addr() net.Addr

Implements net.Listener

func (*Node) Close

func (n *Node) Close() error

Implements net.Listener

func (*Node) CreateClient

func (n *Node) CreateClient(
	base *setup.BaseDendrite,
) *gomatrixserverlib.Client

func (*Node) CreateFederationClient

func (n *Node) CreateFederationClient(
	base *setup.BaseDendrite,
) *gomatrixserverlib.FederationClient

func (*Node) DerivedServerName

func (n *Node) DerivedServerName() string

func (*Node) DerivedSessionName

func (n *Node) DerivedSessionName() string

func (*Node) Dial

func (n *Node) Dial(network, address string) (net.Conn, error)

Implements http.Transport.Dial

func (*Node) DialContext

func (n *Node) DialContext(ctx context.Context, network, address string) (net.Conn, error)

Implements http.Transport.DialContext nolint:gocyclo

func (*Node) Dialer

func (n *Node) Dialer(_, address string) (net.Conn, error)

func (*Node) DialerContext

func (n *Node) DialerContext(ctx context.Context, network, address string) (net.Conn, error)

func (*Node) DisconnectMulticastPeers

func (n *Node) DisconnectMulticastPeers()

func (*Node) DisconnectNonMulticastPeers

func (n *Node) DisconnectNonMulticastPeers()

func (*Node) EncryptionPrivateKey

func (n *Node) EncryptionPrivateKey() []byte

func (*Node) EncryptionPublicKey

func (n *Node) EncryptionPublicKey() []byte

func (*Node) KnownNodes

func (n *Node) KnownNodes() []gomatrixserverlib.ServerName

func (*Node) PeerCount

func (n *Node) PeerCount() int

func (*Node) SessionCount

func (n *Node) SessionCount() int

func (*Node) SetMulticastEnabled

func (n *Node) SetMulticastEnabled(enabled bool)

func (*Node) SetSessionFunc

func (n *Node) SetSessionFunc(f func(address string))

func (*Node) SetStaticPeer

func (n *Node) SetStaticPeer(uri string) error

func (*Node) SigningPrivateKey

func (n *Node) SigningPrivateKey() ed25519.PrivateKey

func (*Node) SigningPublicKey

func (n *Node) SigningPublicKey() ed25519.PublicKey

func (*Node) Stop

func (n *Node) Stop()

type QUICStream

type QUICStream struct {
	quic.Stream
	// contains filtered or unexported fields
}

func (QUICStream) LocalAddr

func (s QUICStream) LocalAddr() net.Addr

func (QUICStream) RemoteAddr

func (s QUICStream) RemoteAddr() net.Addr