xconn

Nov 24, 2024

Changes in this version

type Config

+ func (x *Config) GeneratePrivateKeyIfNotExists() error

+ func (x *Config) PublicKeyStr() string

Nov 16, 2024

Changes in this version

+ const PacketByteLimit

+ var EmbeddedPrivateKey = ""

+ var ErrRemotePeerClosed = fmt.Errorf("remote peer closed connection")

+ func Listen(ctx context.Context, network, address string, config *Config) (net.Listener, error)

+ func ListenURL(ctx context.Context, listenURL *url.URL, config *Config) (net.Listener, error)

+ func MayPerformXConnHandshake(Raw net.Conn) error

+ func NewXDialerProtocol(UnderlyingDialer client.DialerContext, XConfig *Config) client.Protocol

+ func ValidateCryptoConnURL(Raw net.Conn, URL *url.URL) bool

+ type Config struct

+ AuthFunc func(string, ed25519.PublicKey) bool

+ AuthPrivateKey ed25519.PrivateKey

+ EnableAIO bool

+ FECParityNum int

+ HandshakeServerAllowPublic bool

+ HandshakeTimeout time.Duration

+ KeepaliveInterval time.Duration

+ TraceFunc util.TracerFunc

+ func ConstructXConfigFromEnv(maybeFec *int, maybePrivateKey, maybeKnownPeerPubKeys *string) (*Config, bool, error)

+ func Default() *Config

+ func (x *Config) Clone() *Config

+ type Conn struct

+ func Client(raw net.Conn, xConfig *Config) *Conn

+ func ClientWithKnownPeer(raw net.Conn, xConfig *Config, remotePub []byte) *Conn

+ func Server(raw net.Conn, xConfig *Config) *Conn

+ func (*Conn) SupportBufferIO() bool

+ func (c *Conn) Close() error

+ func (c *Conn) ConsumeBuffer(ba *bufferio.BufferArray) error

+ func (c *Conn) GetExtensionProperty() map[string]uint64

+ func (c *Conn) Handshake() error

+ func (c *Conn) IsClosed() bool

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

+ func (c *Conn) ProduceBuffer(bs *bufferio.BufferArray, startOffset int) error

+ func (c *Conn) Read(b []byte) (int, 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) SupportKeepAlive() bool

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

+ func (c *Conn) WriteTo(writer io.Writer) (int64, error)