platform

Documentation

Index

• Constants
• type LocalDialer
  • func (d *LocalDialer) DialUDP(ctx context.Context, port int) (net.Conn, error)
• type Queue
  • func (rb *Queue[T]) Peek() (T, bool)
  • func (rb *Queue[T]) Pop() (T, bool)
  • func (rb *Queue[T]) Push(item T)
• type TTLMap
  • func NewTTLMap[K comparable, V any](ttl time.Duration) *TTLMap[K, V]
  • func (m *TTLMap[K, V]) GetOrSet(k K, newV func() V) V

Constants

const MTU = 1200

MTU is a safe maximum size of a UDP packet.

Types

type LocalDialer

type LocalDialer struct {
	Dialer net.Dialer
}

func (*LocalDialer) DialUDP

func (d *LocalDialer) DialUDP(ctx context.Context, port int) (net.Conn, error)

type Queue

type Queue[T any] struct {
	// contains filtered or unexported fields
}

Queue is a simple FIFO queue backed by a ring buffer. Zero value is a Queue backed by empty slice.

func (*Queue[T]) Peek

func (rb *Queue[T]) Peek() (T, bool)

Peek returns the first element of the queue without removing it, or false if the queue is empty.

func (*Queue[T]) Pop

func (rb *Queue[T]) Pop() (T, bool)

Pop removes and returns the first element of the queue, or false if the queue is empty.

func (*Queue[T]) Push

func (rb *Queue[T]) Push(item T)

Push adds an element to the end of the queue.

type TTLMap

type TTLMap[K comparable, V any] struct {
	// contains filtered or unexported fields
}

TTLMap is a map where items are evicted after they are not accessed for a certain duration.

func NewTTLMap

func NewTTLMap[K comparable, V any](ttl time.Duration) *TTLMap[K, V]

NewTTLMap creates a new TTLMap with the given time-to-live for items.

func (*TTLMap[K, V]) GetOrSet

func (m *TTLMap[K, V]) GetOrSet(k K, newV func() V) V

GetOrSet gets a value for a key or creates a new one if it doesn't exist. It also evicts expired items.