wgbind

Mar 22, 2024

Changes in this version

+ type ClientBind struct

+ func NewClientBind(peerQueues *QueuePair, logger *zap.Logger) *ClientBind

+ func (c *ClientBind) BatchSize() int

+ func (c *ClientBind) Close() error

+ func (c *ClientBind) Open(uint16) ([]conn.ReceiveFunc, uint16, error)

+ func (c *ClientBind) ParseEndpoint(endpoint string) (conn.Endpoint, error)

+ func (c *ClientBind) Send(bufs [][]byte, ep conn.Endpoint) error

+ func (c *ClientBind) SetMark(uint32) error

+ type Packet struct

+ Addr string

+ Data []byte

+ type PeerTraffic struct

+ FromPeers queue.Queue[ReceiveData]

+ func NewPeerTraffic(maxFromPeers int) *PeerTraffic

+ func (p *PeerTraffic) GetSendQueue(addr string, create bool) (*queue.RingQueue[[]byte], bool)

+ func (p *PeerTraffic) PopRecvData(ctx context.Context) (ReceiveData, error)

+ func (p *PeerTraffic) PushRecvData(ctx context.Context, rd ReceiveData) error

+ func (p *PeerTraffic) RemoveQueue(addr string)

+ type QueuePair struct

+ FromPeer queue.Queue[Packet]

+ ToPeer *queue.RingQueue[Packet]

+ func NewQueuePair(fromPeerMax, toPeerMax int) *QueuePair

+ type ReceiveData struct

+ Addr string

+ Packet *pb.PeerPacket

+ type ServerBind struct

+ func NewServerBind(defaultConn conn.Bind, grpcPrefix netip.Prefix, pt *PeerTraffic, l *zap.Logger) *ServerBind

+ func (b *ServerBind) BatchSize() int

+ func (b *ServerBind) Close() error

+ func (b *ServerBind) Open(port uint16) ([]conn.ReceiveFunc, uint16, error)

+ func (b *ServerBind) ParseEndpoint(s string) (conn.Endpoint, error)

+ func (b *ServerBind) Send(bufs [][]byte, ep conn.Endpoint) error

+ func (b *ServerBind) SetMark(mark uint32) error