dispatcher

package

v1.0.4 Latest Latest Go to latest Published: Jan 14, 2026 License: AGPL-3.0 Imports: 16 Imported by: 0

Details

This section is empty.

View Source

var ErrClosed = errors.New("closed")

This section is empty.

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

func NewDispatcherToPacketConn(ctx context.Context,
	dispatcher i.FlowHandler, opts ...PacketDispatcherOption) *DispatcherToPacketConn

func (d *DispatcherToPacketConn) Close() error

func (d *DispatcherToPacketConn) ReadPacket() (*udp.Packet, error)

func (d *DispatcherToPacketConn) WritePacket(p *udp.Packet) error

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

TODO: make it as a PacketConn

func NewPacketDispatcher(ctx context.Context, dispatcher i.FlowHandler,
	opts ...PacketDispatcherOption) *PacketDispatcher

func (s *PacketDispatcher) Close() error

func (s *PacketDispatcher) DispatchPacket(destination net.Destination, payload *buf.Buffer) error

payload's ownership is transferred to the dispatcher. PacketDispatcher releases it even if DispatchPacket fails.

func (p *PacketDispatcher) SetResponseCallback(callback func(packet *udp.Packet))

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

func NewPacketDispatcher0(ctx context.Context, dispatcher i.FlowHandler) *PacketDispatcher0

func (s *PacketDispatcher0) Close() error

func (s *PacketDispatcher0) DispatchPacket(destination net.Destination, payload *buf.Buffer) error

payload's ownership is transferred to the dispatcher. PacketDispatcher0 releases it even if DispatchPacket fails.

func (p *PacketDispatcher0) SetResponseCallback(callback func(packet *udp.Packet))

type PacketDispatcherOption func(*PacketDispatcher)

func WithBufferSize(size int) PacketDispatcherOption

func WithLinkLifetime(lifetime time.Duration) PacketDispatcherOption

func WithRequestTimeout(timeout time.Duration) PacketDispatcherOption

func WithResponseCallback(callback func(packet *udp.Packet)) PacketDispatcherOption

func WithResponseTimeout(timeout time.Duration) PacketDispatcherOption