mock

package
v0.0.0-...-e7f8777 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 20, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClientCmd

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

func NewServerCmd

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

Types

type ClientDemo

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

func (*ClientDemo) Start

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

type ServerDemo

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

func (*ServerDemo) Start

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

type ServerHandler

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

func (*ServerHandler) Accept

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

Accept implements qim.Acceptor

func (*ServerHandler) Disconnect

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

Disconnect implements qim.StateListener

func (*ServerHandler) Receive

func (h *ServerHandler) Receive(agent qim.Agent, payload []byte)

Receive implements qim.MessageListener

type StartOptions

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

type TCPDialer

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

func (*TCPDialer) DialAndHandshake

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

DialAndHandshake implements qim.Dialer

type WebSocketDialer

type WebSocketDialer struct {
}

func (*WebSocketDialer) DialAndHandshake

func (*WebSocketDialer) DialAndHandshake(ctx qim.DialerContext) (net.Conn, error)

DialAndHandshake implements qim.Dialer

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL