client

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, addr string, protocol string) (Client, error)
• type QuicClient
  • func NewQuicClient() *QuicClient
  • func (qs *QuicClient) Close()
  • func (qs *QuicClient) Connect(ctx context.Context) error
  • func (qs *QuicClient) GetConnId() string
  • func (qs *QuicClient) OnMessageParseHandler(handler func(net.Conn))
  • func (qs *QuicClient) OnMessageReceivedHandler(handler func([]byte))
  • func (qs *QuicClient) Send(msg []byte) error
  • func (qs *QuicClient) SendError(err error)
• type TcpClient
  • func NewTcpClient(address string) *TcpClient
  • func (ws *TcpClient) Close()
  • func (ws *TcpClient) Connect(ctx context.Context) error
  • func (ws *TcpClient) GetConnId() string
  • func (ws *TcpClient) OnMessageParseHandler(handler func(net.Conn))
  • func (ws *TcpClient) OnMessageReceivedHandler(handler func([]byte))
  • func (ws *TcpClient) Send(msg []byte) error
  • func (ws *TcpClient) SendError(err error)
• type WsClient
  • func NewWsClient(address string) *WsClient
  • func (ws *WsClient) Close()
  • func (ws *WsClient) Connect(ctx context.Context) error
  • func (ws *WsClient) GetConnId() string
  • func (ws *WsClient) OnMessageParseHandler(handler func(net.Conn))
  • func (ws *WsClient) OnMessageReceivedHandler(handler func([]byte))
  • func (ws *WsClient) OnParseMsgHandler(src *os.File)
  • func (ws *WsClient) Send(msg []byte) error
  • func (ws *WsClient) SendError(err error)

Types

type Client

type Client interface {
	Close()
	Connect(context.Context) error
	GetConnId() string
	OnMessageReceivedHandler(func([]byte))
	OnMessageParseHandler(func(net.Conn))
	SendError(err error)
	Send([]byte) error
}

func NewClient

func NewClient(ctx context.Context, addr string, protocol string) (Client, error)

type QuicClient

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

func NewQuicClient

func NewQuicClient() *QuicClient

func (*QuicClient) Close

func (qs *QuicClient) Close()

func (*QuicClient) Connect

func (qs *QuicClient) Connect(ctx context.Context) error

func (*QuicClient) GetConnId

func (qs *QuicClient) GetConnId() string

func (*QuicClient) OnMessageParseHandler

func (qs *QuicClient) OnMessageParseHandler(handler func(net.Conn))

func (*QuicClient) OnMessageReceivedHandler

func (qs *QuicClient) OnMessageReceivedHandler(handler func([]byte))

func (*QuicClient) Send

func (qs *QuicClient) Send(msg []byte) error

func (*QuicClient) SendError

func (qs *QuicClient) SendError(err error)

type TcpClient

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

func NewTcpClient

func NewTcpClient(address string) *TcpClient

func (*TcpClient) Close

func (ws *TcpClient) Close()

func (*TcpClient) Connect

func (ws *TcpClient) Connect(ctx context.Context) error

func (*TcpClient) GetConnId

func (ws *TcpClient) GetConnId() string

func (*TcpClient) OnMessageParseHandler

func (ws *TcpClient) OnMessageParseHandler(handler func(net.Conn))

func (*TcpClient) OnMessageReceivedHandler

func (ws *TcpClient) OnMessageReceivedHandler(handler func([]byte))

func (*TcpClient) Send

func (ws *TcpClient) Send(msg []byte) error

func (*TcpClient) SendError

func (ws *TcpClient) SendError(err error)

type WsClient

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

func NewWsClient

func NewWsClient(address string) *WsClient

func (*WsClient) Close

func (ws *WsClient) Close()

func (*WsClient) Connect

func (ws *WsClient) Connect(ctx context.Context) error

func (*WsClient) GetConnId

func (ws *WsClient) GetConnId() string

func (*WsClient) OnMessageParseHandler

func (ws *WsClient) OnMessageParseHandler(handler func(net.Conn))

func (*WsClient) OnMessageReceivedHandler

func (ws *WsClient) OnMessageReceivedHandler(handler func([]byte))

func (*WsClient) OnParseMsgHandler

func (ws *WsClient) OnParseMsgHandler(src *os.File)

func (*WsClient) Send

func (ws *WsClient) Send(msg []byte) error

func (*WsClient) SendError

func (ws *WsClient) SendError(err error)