udp

Documentation

Index

• Variables
• func CopyPacketConn(dst internet.AbstractPacketConnWriter, src internet.AbstractPacketConnReader, ...) error
• func DialDispatcher(ctx context.Context, dispatcher routing.Dispatcher) (net.PacketConn, error)
• func ReadUDPMsg(conn *net.UDPConn, payload []byte, oob []byte) (int, int, int, *net.UDPAddr, error)
• func RetrieveOriginalDest(oob []byte) net.Destination
• type Config
  • func (*Config) Descriptor() ([]byte, []int)
  • func (*Config) ProtoMessage()
  • func (x *Config) ProtoReflect() protoreflect.Message
  • func (x *Config) Reset()
  • func (x *Config) String() string
• type CopyOption
  • func UpdateActivity(timer signal.ActivityUpdater) CopyOption
• type Dispatcher
  • func (v *Dispatcher) Close() error
  • func (v *Dispatcher) Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer)
  • func (v *Dispatcher) RemoveRay(dest net.Destination)
• type DispatcherConnectionTerminationSignalReceiver
• type DispatcherI
  • func NewSplitDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) DispatcherI
• type Hub
  • func ListenUDP(ctx context.Context, address net.Address, port net.Port, ...) (*Hub, error)
  • func (h *Hub) Addr() net.Addr
  • func (h *Hub) Close() error
  • func (h *Hub) Receive() <-chan *udp.Packet
  • func (h *Hub) WriteTo(payload []byte, dest net.Destination) (int, error)
• type HubOption
  • func HubCapacity(capacity int) HubOption
  • func HubReceiveOriginalDestination(r bool) HubOption
• type PacketAddrDispatcher
  • func (p PacketAddrDispatcher) Close() error
  • func (p PacketAddrDispatcher) Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer)
• type PacketAddrDispatcherCreator
  • func NewPacketAddrDispatcherCreator(ctx context.Context) PacketAddrDispatcherCreator
  • func (pdc *PacketAddrDispatcherCreator) NewPacketAddrDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) DispatcherI
• type ResponseCallback

Variables

var DispatcherConnectionTerminationSignalReceiverMark = "DispatcherConnectionTerminationSignalReceiverMark"

var File_transport_internet_udp_config_proto protoreflect.FileDescriptor

Functions

func CopyPacketConn

func CopyPacketConn(dst internet.AbstractPacketConnWriter, src internet.AbstractPacketConnReader, options ...CopyOption) error

func DialDispatcher

func DialDispatcher(ctx context.Context, dispatcher routing.Dispatcher) (net.PacketConn, error)

func ReadUDPMsg

func ReadUDPMsg(conn *net.UDPConn, payload []byte, oob []byte) (int, int, int, *net.UDPAddr, error)

func RetrieveOriginalDest

func RetrieveOriginalDest(oob []byte) net.Destination

Types

type Config

type Config struct {
	// contains filtered or unexported fields
}

func (*Config) Descriptor

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) ProtoMessage

func (*Config) ProtoMessage()

func (*Config) ProtoReflect

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset

func (x *Config) Reset()

func (*Config) String

func (x *Config) String() string

type CopyOption

type CopyOption func(*copyHandler)

func UpdateActivity

func UpdateActivity(timer signal.ActivityUpdater) CopyOption

type Dispatcher

type Dispatcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Dispatcher) Close

func (v *Dispatcher) Close() error

func (*Dispatcher) Dispatch

func (v *Dispatcher) Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer)

func (*Dispatcher) RemoveRay

func (v *Dispatcher) RemoveRay(dest net.Destination)

type DispatcherConnectionTerminationSignalReceiver

type DispatcherConnectionTerminationSignalReceiver interface {
	io.Closer
}

type DispatcherI

type DispatcherI interface {
	common.Closable
	Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer)
}

func NewSplitDispatcher

func NewSplitDispatcher(dispatcher routing.Dispatcher, callback ResponseCallback) DispatcherI

type Hub

type Hub struct {
	// contains filtered or unexported fields
}

func ListenUDP

func ListenUDP(ctx context.Context, address net.Address, port net.Port, streamSettings *internet.MemoryStreamConfig, options ...HubOption) (*Hub, error)

func (*Hub) Addr

func (h *Hub) Addr() net.Addr

Addr implements net.Listener.

func (*Hub) Close

func (h *Hub) Close() error

Close implements net.Listener.

func (*Hub) Receive

func (h *Hub) Receive() <-chan *udp.Packet

func (*Hub) WriteTo

func (h *Hub) WriteTo(payload []byte, dest net.Destination) (int, error)

type HubOption

type HubOption func(h *Hub)

func HubCapacity

func HubCapacity(capacity int) HubOption

func HubReceiveOriginalDestination

func HubReceiveOriginalDestination(r bool) HubOption

type PacketAddrDispatcher

type PacketAddrDispatcher struct {
	// contains filtered or unexported fields
}

func (PacketAddrDispatcher) Close

func (p PacketAddrDispatcher) Close() error

func (PacketAddrDispatcher) Dispatch

func (p PacketAddrDispatcher) Dispatch(ctx context.Context, destination net.Destination, payload *buf.Buffer)

type PacketAddrDispatcherCreator

type PacketAddrDispatcherCreator struct {
	// contains filtered or unexported fields
}

func NewPacketAddrDispatcherCreator

func NewPacketAddrDispatcherCreator(ctx context.Context) PacketAddrDispatcherCreator

func (*PacketAddrDispatcherCreator) NewPacketAddrDispatcher

func (pdc *PacketAddrDispatcherCreator) NewPacketAddrDispatcher(
	dispatcher routing.Dispatcher, callback ResponseCallback,
) DispatcherI

type ResponseCallback

type ResponseCallback func(ctx context.Context, packet *udp.Packet)