part

Documentation

Index

• Variables
• 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 Recorder
  • func (t *Recorder) Start(filePath string) error
  • func (t *Recorder) Stop()
• type Server
  • func New_server() *Server
  • func Play(filePath string, perReadSize int, maxReadSize int) (s *Server, close func())
  • func (t *Server) Interface() *mq.Msgq
  • func (t *Server) Len() int64
  • func (t *Server) WS(w http.ResponseWriter, r *http.Request) (o chan uintptr)
• type Uinterface

Variables

var (
	ErrSerIsNil  = errors.New("ErrSerIsNil")
	ErrFileNoSet = errors.New("ErrFileNoSet")
	ErrhadStart  = errors.New("ErrhadStart")
	ErrIsExist   = errors.New("ErrIsExist")
)

Types

type Client

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

	TO     int
	Header map[string]string
	Proxy  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 Recorder

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

func (*Recorder) Start

func (t *Recorder) Start(filePath string) error

func (*Recorder) Stop

func (t *Recorder) Stop()

type Server

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

func New_server

func New_server() *Server

func Play

func Play(filePath string, perReadSize int, maxReadSize int) (s *Server, close func())

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() int64

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
}