netw

Documentation

Overview

Package netw is a wrapper around network connections that stores annotations and records metrics.

Index

• func Listen(network, laddr string) (net.Listener, error)
• func SetAnnotation(conn net.Conn, key string, value any)
• type Conn
  • func NewConn(c net.Conn) *Conn
  • func NewConnForTest(c net.Conn) *Conn
  • func (c *Conn) Annotation(key string, defaultValue any) any
  • func (c *Conn) ByteRateReceived() float64
  • func (c *Conn) ByteRateSent() float64
  • func (c *Conn) BytesReceived() int64
  • func (c *Conn) BytesSent() int64
  • func (c *Conn) Close() error
  • func (c *Conn) OnClose(f func())
  • func (c *Conn) Peek(b []byte) (int, error)
  • func (c *Conn) Read(b []byte) (int, error)
  • func (c *Conn) SetAnnotation(key string, value any)
  • func (c *Conn) SetCounters(sent, received *counter.Counter)
  • func (c *Conn) SetLimiters(ingress, egress *rate.Limiter)
  • func (c *Conn) StreamID() int64
  • func (c *Conn) Write(b []byte) (int, error)
• type QUICConn
  • func (*QUICConn) Annotation(key string, defaultValue any) any
  • func (*QUICConn) ByteRateReceived() float64
  • func (*QUICConn) ByteRateSent() float64
  • func (*QUICConn) BytesReceived() int64
  • func (*QUICConn) BytesSent() int64
  • func (*QUICConn) SetAnnotation(key string, value any)
  • func (*QUICConn) Streams() []*QUICStream
• type QUICStream
  • func (*QUICStream) BridgeAddr() string
  • func (*QUICStream) Dir() string

Functions

func Listen

func Listen(network, laddr string) (net.Listener, error)

Listen creates a net listener that is instrumented to store per connection annotations and metrics.

func SetAnnotation

func SetAnnotation(conn net.Conn, key string, value any)

SetAnnotation sets an annotation on a connection. The value can be any go value.

Types

type Conn

type Conn struct {
	net.Conn
	// contains filtered or unexported fields
}

Conn is a wrapper around net.Conn that stores annotations and metrics.

func NewConn

func NewConn(c net.Conn) *Conn

func NewConnForTest

func NewConnForTest(c net.Conn) *Conn

func (*Conn) Annotation

func (c *Conn) Annotation(key string, defaultValue any) any

Annotation retrieves an annotation that was previously set on the connection. The defaultValue is returned if the annotation was never set.

func (*Conn) ByteRateReceived

func (c *Conn) ByteRateReceived() float64

ByteRateReceived returns the rate of bytes received on this connection in the last minute.

func (*Conn) ByteRateSent

func (c *Conn) ByteRateSent() float64

ByteRateSent returns the rate of bytes sent on this connection in the last minute.

func (*Conn) BytesReceived

func (c *Conn) BytesReceived() int64

BytesReceived returns the number of bytes received on this connection so far.

func (*Conn) BytesSent

func (c *Conn) BytesSent() int64

BytesSent returns the number of bytes sent on this connection so far.

func (*Conn) Close

func (c *Conn) Close() error

func (*Conn) OnClose

func (c *Conn) OnClose(f func())

OnClose sets a callback function that will be called when the connection is closed.

func (*Conn) Peek

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

func (*Conn) Read

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

func (*Conn) SetAnnotation

func (c *Conn) SetAnnotation(key string, value any)

SetAnnotation sets an annotation. The value can be any go value.

func (*Conn) SetCounters

func (c *Conn) SetCounters(sent, received *counter.Counter)

func (*Conn) SetLimiters

func (c *Conn) SetLimiters(ingress, egress *rate.Limiter)

SetLimiter sets the rate limiters for this connection. It must be called before the first Read() or Write(). Peek() is OK.

func (*Conn) StreamID

func (c *Conn) StreamID() int64

func (*Conn) Write

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

type QUICConn

type QUICConn struct {
	net.Conn
}

func (*QUICConn) Annotation

func (*QUICConn) Annotation(key string, defaultValue any) any

func (*QUICConn) ByteRateReceived

func (*QUICConn) ByteRateReceived() float64

func (*QUICConn) ByteRateSent

func (*QUICConn) ByteRateSent() float64

func (*QUICConn) BytesReceived

func (*QUICConn) BytesReceived() int64

func (*QUICConn) BytesSent

func (*QUICConn) BytesSent() int64

func (*QUICConn) SetAnnotation

func (*QUICConn) SetAnnotation(key string, value any)

func (*QUICConn) Streams

func (*QUICConn) Streams() []*QUICStream

type QUICStream

type QUICStream struct {
	Conn
}

func (*QUICStream) BridgeAddr

func (*QUICStream) BridgeAddr() string

func (*QUICStream) Dir

func (*QUICStream) Dir() string