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 (c *Conn) Annotation(key string, defaultValue any) any
  • func (c *Conn) BytesReceived() int64
  • func (c *Conn) BytesSent() int64
  • func (c *Conn) Close() error
  • func (c *Conn) CopyAnnotationsFrom(cc *Conn)
  • 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) SetLimiters(ingress, egress *rate.Limiter)
  • func (c *Conn) StreamID() int64
  • func (c *Conn) Write(b []byte) (int, error)
• type QUICConn
  • 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 (*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) 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) CopyAnnotationsFrom

func (c *Conn) CopyAnnotationsFrom(cc *Conn)

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) 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) 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