uniclient

Documentation

Index

• type UnifiedConnectionClient
  • func NewUnifiedConnectionClient(dialer transport.UnderlayTransportDialer, ctx context.Context) *UnifiedConnectionClient
  • func (u *UnifiedConnectionClient) Close() error
  • func (u *UnifiedConnectionClient) Connect(ctx context.Context) (net.Conn, error, context.Context)
  • func (u *UnifiedConnectionClient) ReconnectListener(connctx context.Context)
  • func (u *UnifiedConnectionClient) ReconnectUnder(ctx context.Context) error
  • func (u *UnifiedConnectionClient) ReconnectUnderR(ctx context.Context) error
  • func (uct *UnifiedConnectionClient) Rx(conn net.Conn, ctx context.Context)
  • func (uct *UnifiedConnectionClient) Tx(conn net.Conn, ctx context.Context)

Types

type UnifiedConnectionClient

type UnifiedConnectionClient struct {
	ConnID []byte
	Iter   int

	RxChan     chan []byte
	TxChan     chan []byte
	IterCancel context.CancelFunc
	// contains filtered or unexported fields
}

func NewUnifiedConnectionClient

func NewUnifiedConnectionClient(dialer transport.UnderlayTransportDialer, ctx context.Context) *UnifiedConnectionClient

func (*UnifiedConnectionClient) Close

func (u *UnifiedConnectionClient) Close() error

func (*UnifiedConnectionClient) Connect

func (u *UnifiedConnectionClient) Connect(ctx context.Context) (net.Conn, error, context.Context)

func (*UnifiedConnectionClient) ReconnectListener

func (u *UnifiedConnectionClient) ReconnectListener(connctx context.Context)

func (*UnifiedConnectionClient) ReconnectUnder

func (u *UnifiedConnectionClient) ReconnectUnder(ctx context.Context) error

func (*UnifiedConnectionClient) ReconnectUnderR

func (u *UnifiedConnectionClient) ReconnectUnderR(ctx context.Context) error

func (*UnifiedConnectionClient) Rx

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

func (*UnifiedConnectionClient) Tx

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