link

Oct 30, 2026

Changes in this version

type Session

+ func (s *Session) OnGrant(f func(n int))

Oct 29, 2026

Changes in this version

type Conn

+ func (c *Conn) Stats() ConnStats

+ type ConnStats struct

+ BytesIn uint64

+ BytesOut uint64

+ CreditWait time.Duration

+ CreditWaits uint64

+ QueuedBytes int

+ SessionsAborted uint64

+ SessionsOpened uint64

type Credit

+ func (c *Credit) SetObserver(obs Observer)

type NopObserver

+ func (NopObserver) SessionAbort(Abort, bool)

type Observer

+ SessionAbort func(Abort, bool)

type Pool

+ func (p *Pool) ConnStats() ConnStats

Oct 16, 2026

Changes in this version

+ var ErrDrainDeadline = errors.New("link: the drain's deadline cut the session")

Oct 15, 2026

Changes in this version

+ const CodeApp

+ const CodeConnLost

+ const CodeDrainDeadline

+ const CodeDraining

+ const CodeHopLimit

+ const CodeNoRoute

+ const CodeRefused

+ const CodeTimeout

+ const CodeUnspecified

+ const DefaultMaxHops

+ const FeatureChain

+ const MaxAbortMsg

+ var ErrNoAnswers = errors.New("link: the peer does not answer opens (no FeatureChain)")

+ var ErrOpenRefused = errors.New("link: session refused")

+ func ContextWithChain(ctx context.Context, c Chain) context.Context

+ func Forward(route Route, cfg ForwardConfig) func(header []byte, s *Session)

+ func Join(a, b *Session) error

+ type Abort struct

+ Code uint32

+ Hops uint8

+ Msg string

+ Refused bool

+ func (a *Abort) Error() string

+ func (a *Abort) Is(target error) bool

+ type Chain struct

+ Hops uint8

+ Trace Trace

+ func ChainFromContext(ctx context.Context) (Chain, bool)

+ type ForwardConfig struct

+ AnswerTimeout time.Duration

+ MaxHops uint8

+ Observer Observer

type Frame

+ Abort *Abort

+ Accept bool

+ Chain Chain

+ type HopEvent struct

+ Chain Chain

+ Err error

+ In int64

+ Kind HopKind

+ Latency time.Duration

+ Out int64

+ type HopKind uint8

+ const HopAnswered

+ const HopEnded

+ const HopOpened

type Mux

+ func (m *Mux) OpenChain(header []byte, c Chain) (*Session, error)

type NopObserver

+ func (NopObserver) Hop(HopEvent)

type Observer

+ Hop func(HopEvent)

+ type Route func(ctx context.Context, in *Session) (*Session, error)

type Session

+ func (s *Session) Abort(code uint32, msg string) error

+ func (s *Session) AbortWith(a *Abort) error

+ func (s *Session) Accept() error

+ func (s *Session) AcceptPath(pathLen uint8) error

+ func (s *Session) Answered(ctx context.Context) error

+ func (s *Session) Answers() bool

+ func (s *Session) Chain() Chain

+ func (s *Session) PathLen() uint8

+ func (s *Session) Refuse(code uint32, msg string) error

+ type Trace [16]byte

Oct 15, 2026

Changes in this version

type Conn

+ func (c *Conn) Credit() *Credit

type Mux

+ func (m *Mux) Drain(ctx context.Context) error

Oct 14, 2026

Changes in this version

+ const MethodName

+ var ErrHandshake = errors.New("link: handshake failed")

type Authenticator

+ var CertAuth Authenticator = certAuth{}

+ func NameAuth(name string) Authenticator

type Config

+ func (cfg Config) Validate() error

type PoolConfig

+ func (cfg PoolConfig) Validate() error

Oct 12, 2026

Changes in this version

type PoolConfig

+ Accept func(open []byte, s *Session)

Oct 11, 2026

Changes in this version

+ var ErrV1 = fmt.Errorf(...)

Oct 11, 2026

Changes in this version

type Conn

+ func (c *Conn) Drained() <-chan struct{}

type PoolConfig

+ GrowWait time.Duration

Oct 11, 2026

Changes in this version

type Session

+ func (s *Session) Pump(w io.Writer, done func(n int64, err error))

Oct 10, 2026

Changes in this version

+ const FeatureReset

+ var ErrConnClosed = errors.New("link: connection closed")

+ var ErrReset = errors.New("link: session reset by the peer")

type Conn

+ func (c *Conn) PeerFeatures() uint32

+ func (c *Conn) SendReset(sid string) error

type Frame

+ Reset bool

type Session

+ func (s *Session) Done() <-chan struct{}

+ func (s *Session) Reset() error

+ func (s *Session) WriteBuffers(bufs [][]byte) (int64, error)

Oct 10, 2026

Changes in this version

+ const DefaultWindow

+ const MaxAuth

+ const MaxVersion

+ const MethodNone

+ const MethodToken

+ const StatusVersion

+ var ErrAuth = errors.New("link: peer not authenticated")

+ var ErrDeadPeer = errors.New("link: peer silent past the liveness timeout")

+ var ErrGoAway = errors.New("link: connection going away")

+ var ErrVersion = errors.New("link: wire version not supported")

+ func AppendWindow(b []byte, sid string, n int) []byte

+ func IsHello(prefix []byte) bool

+ func ParseWindow(b []byte) (sid string, n int, err error)

+ func Server(ctx context.Context, nc net.Conn, cfg Config) (*Conn, Identity, error)

+ type Authenticator interface

+ Hello func(ctx context.Context, cs tls.ConnectionState) (method byte, payload []byte, err error)

+ Verify func(ctx context.Context, cs tls.ConnectionState, method byte, payload []byte) (Identity, error)

+ var NoAuth Authenticator = noAuth{}

+ type Config struct

+ Auth Authenticator

+ Liveness Liveness

+ MaxSessions int

+ Observer Observer

+ Version int

+ Window int

type Conn

+ func Client(ctx context.Context, nc net.Conn, cfg Config) (*Conn, error)

+ func (c *Conn) Done() <-chan struct{}

+ func (c *Conn) Err() error

+ func (c *Conn) GoAway(drain time.Duration, reason string) error

+ func (c *Conn) GoingAway() bool

+ func (c *Conn) Identity() Identity

+ func (c *Conn) PeerGoAway() <-chan struct{}

+ func (c *Conn) PeerMaxSessions() int

+ func (c *Conn) SendClose(sid string, half bool) error

+ func (c *Conn) SendOpen(sid string, header []byte) error

+ func (c *Conn) Version() int

+ type Credit struct

+ func NewCredit(window, peerWindow int, grant func(sid string, n int)) *Credit

+ func (c *Credit) Acquire(sid string, n int) bool

+ func (c *Credit) Close()

+ func (c *Credit) Consumed(sid string, n int)

+ func (c *Credit) Forget(sid string)

+ func (c *Credit) Grant(sid string, n int) error

+ func (c *Credit) Open(sid string)

+ func (c *Credit) PeerWindow() int

+ func (c *Credit) Received(sid string, n int) error

+ func (c *Credit) Window() int

type Frame

+ Close bool

+ Half bool

+ Header []byte

+ Open bool

+ type Identity struct

+ Method string

+ Subject string

type Mux

+ func (m *Mux) Conn() *Conn

+ func (m *Mux) GoAway(deadline time.Time) error

+ func (m *Mux) Sessions() int

+ type NopObserver struct

+ func (NopObserver) ConnDown(Identity, error)

+ func (NopObserver) ConnUp(Identity)

+ func (NopObserver) CreditWait(time.Duration)

+ func (NopObserver) GoAway(Identity)

+ func (NopObserver) PingRTT(time.Duration)

+ func (NopObserver) SessionClose(error)

+ func (NopObserver) SessionOpen()

+ type Observer interface

+ ConnDown func(Identity, error)

+ ConnUp func(Identity)

+ CreditWait func(time.Duration)

+ GoAway func(Identity)

+ PingRTT func(time.Duration)

+ SessionClose func(error)

+ SessionOpen func()

+ type Pool struct

+ func NewPool(cfg PoolConfig) *Pool

+ func (p *Pool) Close() error

+ func (p *Pool) Drain(ctx context.Context) error

+ func (p *Pool) Open(ctx context.Context, header []byte) (*Session, error)

+ func (p *Pool) Stats() PoolStats

+ type PoolConfig struct

+ Backoff func(attempt int) time.Duration

+ Dial func(ctx context.Context) (net.Conn, error)

+ Grow func(PoolStats) bool

+ Link Config

+ Max int

+ Min int

+ type PoolStats struct

+ Conns int

+ Sessions int

type Session

+ func (s *Session) CloseWrite() error

+ func (s *Session) Header() []byte

+ type VersionError struct

+ Max int

+ func (e *VersionError) Error() string

+ func (e *VersionError) Is(target error) bool

Oct 10, 2026

Changes in this version

+ const Magic

+ const MaxChunk

+ const MaxLivenessInterval

+ const MaxSID

+ const MaxSessions

+ const MaxWindow

+ const MinLivenessInterval

+ const MinWindow

+ const StatusBound

+ const StatusRefused

+ const TokenLen

+ const Version

+ var ErrCredit = errors.New("link: peer exceeded the session window")

+ var ErrFrame = errors.New("link: malformed frame")

+ var ErrFull = errors.New("link: connection carries its most sessions")

+ var ErrRefused = errors.New("link: peer refused the connection")

+ var LivenessDatacenter = Liveness

+ var LivenessDefault = Liveness

+ var LivenessFast = Liveness

+ var LivenessMobile = Liveness

+ var LivenessNAT = Liveness

+ var LivenessPresets = []string

+ func CheckWindow(w uint32) (int, error)

+ func Hello(nc net.Conn, token string, window int) (int, error)

+ func ReadHello(r io.Reader) (string, int, error)

+ func Reply(w io.Writer, status byte, window int) error

+ type Codec interface

+ Close func(sid string) ([]byte, error)

+ Parse func(msg []byte) (Message, error)

+ type Conn struct

+ func NewConn(nc net.Conn, window, peerWindow int) *Conn

+ func (c *Conn) Acquire(sid string, n int) bool

+ func (c *Conn) Close() error

+ func (c *Conn) Consumed(sid string, n int)

+ func (c *Conn) Flush() error

+ func (c *Conn) Forget(sid string)

+ func (c *Conn) Open(sid string)

+ func (c *Conn) PeerWindow() int

+ func (c *Conn) Received(sid string, n int) error

+ func (c *Conn) Recv() (Frame, error)

+ func (c *Conn) SendData(sid string, data []byte) error

+ func (c *Conn) SendMsg(b []byte) error

+ func (c *Conn) Window() int

+ type Frame struct

+ Data []byte

+ Msg []byte

+ SID string

+ type Liveness struct

+ Interval time.Duration

+ Timeout time.Duration

+ func ParseLiveness(spec string) (Liveness, error)

+ func (l Liveness) DeadAfter(stated time.Duration) time.Duration

+ func (l Liveness) String() string

+ func (l Liveness) Validate() error

+ type Message struct

+ Close bool

+ Data []byte

+ Open bool

+ SID string

+ type Mux struct

+ func NewMux(c *Conn, codec Codec) *Mux

+ func (m *Mux) Close() error

+ func (m *Mux) Open(open func(sid string) ([]byte, error)) (*Session, error)

+ func (m *Mux) Serve(accept func(open []byte, s *Session)) error

+ type OwnedWriter interface

+ WriteOwned func(b []byte) error

+ type Session struct

+ func (s *Session) Close() error

+ func (s *Session) LocalAddr() net.Addr

+ func (s *Session) Read(b []byte) (int, error)

+ func (s *Session) RemoteAddr() net.Addr

+ func (s *Session) SetDeadline(time.Time) error

+ func (s *Session) SetReadDeadline(time.Time) error

+ func (s *Session) SetWriteDeadline(time.Time) error

+ func (s *Session) Write(b []byte) (int, error)

+ func (s *Session) WriteTo(w io.Writer) (int64, error)