uniserver

Documentation

Index

• type UnifiedConnectionTransport
  • func (u UnifiedConnectionTransport) Close() error
  • func (uct *UnifiedConnectionTransport) Rehandshake()
  • func (uct *UnifiedConnectionTransport) Rx(conn net.Conn, ctx context.Context)
  • func (uct *UnifiedConnectionTransport) Tx(conn net.Conn, ctx context.Context)
• type UnifiedConnectionTransportHub
  • func NewUnifiedConnectionTransportHub(Uplistener transport.UnderlayTransportListener, ctx context.Context) *UnifiedConnectionTransportHub
  • func (uic *UnifiedConnectionTransportHub) Connection(conn net.Conn, ctx context.Context) context.Context

Types

type UnifiedConnectionTransport

type UnifiedConnectionTransport struct {
	ConnID                 []byte
	Arw                    *antiReplayWindow.AntiReplayWindow
	LastConnIter           int32
	LastCOnnIterCancelFunc map[string]context.CancelFunc
	TxChan                 chan []byte
	RxChan                 chan []byte
	// contains filtered or unexported fields
}

func (UnifiedConnectionTransport) Close

func (u UnifiedConnectionTransport) Close() error

func (*UnifiedConnectionTransport) Rehandshake

func (uct *UnifiedConnectionTransport) Rehandshake()

func (*UnifiedConnectionTransport) Rx

func (uct *UnifiedConnectionTransport) Rx(conn net.Conn, ctx context.Context)

func (*UnifiedConnectionTransport) Tx

func (uct *UnifiedConnectionTransport) Tx(conn net.Conn, ctx context.Context)

type UnifiedConnectionTransportHub

type UnifiedConnectionTransportHub struct {
	Conns      sync.Map
	Uplistener transport.UnderlayTransportListener
	// contains filtered or unexported fields
}

func NewUnifiedConnectionTransportHub

func NewUnifiedConnectionTransportHub(Uplistener transport.UnderlayTransportListener, ctx context.Context) *UnifiedConnectionTransportHub

func (*UnifiedConnectionTransportHub) Connection

func (uic *UnifiedConnectionTransportHub) Connection(conn net.Conn, ctx context.Context) context.Context