mock

Documentation

Index

• func NewClientCmd(ctx context.Context) *cobra.Command
• func NewServerCmd(ctx context.Context) *cobra.Command
• type ClientDemo
  • func (c *ClientDemo) Start(userID, protocol, addr string)
• type ClientHandler
  • func (h *ClientHandler) Disconnect(id string) error
  • func (h *ClientHandler) Receive(ag goim.Agent, payload []byte)
• type ServerDemo
  • func (s *ServerDemo) Start(id, protocol, addr string)
• type ServerHandler
  • func (h *ServerHandler) Accept(conn goim.Conn, timeout time.Duration) (string, goim.Metadata, error)
  • func (h *ServerHandler) Disconnect(id string) error
  • func (h *ServerHandler) Receive(ag goim.Agent, payload []byte)
• type StartOptions
• type TCPDialer
  • func (d *TCPDialer) DialAndHandshake(ctx goim.DialerContext) (net.Conn, error)
• type WebsocketDialer
  • func (d *WebsocketDialer) DialAndHandshake(ctx goim.DialerContext) (net.Conn, error)

Functions

func NewClientCmd

func NewClientCmd(ctx context.Context) *cobra.Command

NewCmd NewCmd

func NewServerCmd

func NewServerCmd(ctx context.Context) *cobra.Command

NewCmd NewCmd

Types

type ClientDemo

type ClientDemo struct {
}

func (*ClientDemo) Start

func (c *ClientDemo) Start(userID, protocol, addr string)

入口方法

type ClientHandler

type ClientHandler struct {
}

func (*ClientHandler) Disconnect

func (h *ClientHandler) Disconnect(id string) error

Disconnect default listener

func (*ClientHandler) Receive

func (h *ClientHandler) Receive(ag goim.Agent, payload []byte)

Receive default listener

type ServerDemo

type ServerDemo struct{}

func (*ServerDemo) Start

func (s *ServerDemo) Start(id, protocol, addr string)

type ServerHandler

type ServerHandler struct {
}

ServerHandler ServerHandler

func (*ServerHandler) Accept

func (h *ServerHandler) Accept(conn goim.Conn, timeout time.Duration) (string, goim.Metadata, error)

Accept this connection

func (*ServerHandler) Disconnect

func (h *ServerHandler) Disconnect(id string) error

Disconnect default listener

func (*ServerHandler) Receive

func (h *ServerHandler) Receive(ag goim.Agent, payload []byte)

Receive default listener

type StartOptions

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

StartOptions StartOptions

type TCPDialer

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

func (*TCPDialer) DialAndHandshake

func (d *TCPDialer) DialAndHandshake(ctx goim.DialerContext) (net.Conn, error)

DialAndHandshake DialAndHandshake

type WebsocketDialer

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

WebsocketDialer WebsocketDialer

func (*WebsocketDialer) DialAndHandshake

func (d *WebsocketDialer) DialAndHandshake(ctx goim.DialerContext) (net.Conn, error)

DialAndHandshake DialAndHandshake