part

Documentation

Index

• type Client
  • func New_client(config Client) (o *Client)
  • func (o *Client) Close()
  • func (o *Client) Error() error
  • func (i *Client) Handle() (o *Client)
  • func (o *Client) Heartbeat() (err error)
  • func (o *Client) Isclose() bool
• type Ping
• type Server
  • func New_server() *Server
  • func (t *Server) Interface() *mq.Msgq
  • func (t *Server) Len() uint
  • func (t *Server) WS(w http.ResponseWriter, r *http.Request) (o chan uintptr)
• type Uinterface

Types

type Client

type Client struct {
	Url      string
	SendChan chan interface{}
	RecvChan chan []byte

	TO     int
	Header map[string]string

	Ping Ping

	Msg_normal_close  string
	Func_normal_close func()
	Func_abort_close  func()
	// contains filtered or unexported fields
}

func New_client

func New_client(config Client) (o *Client)

func (*Client) Close

func (o *Client) Close()

func (*Client) Error

func (o *Client) Error() error

func (*Client) Handle

func (i *Client) Handle() (o *Client)

func (*Client) Heartbeat

func (o *Client) Heartbeat() (err error)

func (*Client) Isclose

func (o *Client) Isclose() bool

type Ping

type Ping struct {
	Msg    []byte
	Period int
	// contains filtered or unexported fields
}

type Server

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

func New_server

func New_server() *Server

func (*Server) Interface

func (t *Server) Interface() *mq.Msgq

			ws_mq.Push_tag(`send`,Uinterface{//just reply
				Id:tmp.Id,
				Data:tmp.Data,
			})
			//or
			ws_mq.Push_tag(`send`,Uinterface{//just reply
				Id:0,//send to all
				Data:tmp.Data,
			})
		}
		return false
	},
	`error`:func(data interface{})(bool){
		log.Println(data)
		return false
	},
})

func (*Server) Len

func (t *Server) Len() uint

func (*Server) WS

func (t *Server) WS(w http.ResponseWriter, r *http.Request) (o chan uintptr)

type Uinterface

type Uinterface struct {
	Id   uintptr
	Data []byte
}