websocket

Documentation

Index

• Constants
• func DecodeRequest(data []byte) (*http.Request, uint32, error)
• func DecodeResponse(data []byte) (*http.Response, uint32, error)
• func EncodeRequest(r *http.Request, seq uint32) ([]byte, error)
• func EncodeResponse(r *http.Response, seq uint32) ([]byte, error)
• type Transport3gppWsNotif
  • func NewTransport3gppWsNotif(cfg *Transport3gppWsNotifCfg) (*Transport3gppWsNotif, error)
  • func (tr *Transport3gppWsNotif) DeregisterRespHandler(seqNum uint32)
  • func (tr *Transport3gppWsNotif) RegisterRespHandler(seqNum uint32, handler chan *http.Response) error
  • func (tr *Transport3gppWsNotif) SendRequest(req *http.Request) (*http.Response, error)
• type Transport3gppWsNotifCfg
• type Websocket
  • func NewWebsocket() (*Websocket, error)
  • func (ws *Websocket) Close()
  • func (ws *Websocket) ConnectionHandler(w http.ResponseWriter, r *http.Request)
  • func (ws *Websocket) DeregisterMsgHandler(name string) error
  • func (ws *Websocket) RegisterMsgHandler(name string, handler chan *WebsocketMsg) error
  • func (ws *Websocket) SendMessage(msg []byte) error
• type WebsocketMsg

Constants

const (
	WsStateInit  = "Init"
	WsStateReady = "Ready"
)

Functions

func DecodeRequest

func DecodeRequest(data []byte) (*http.Request, uint32, error)

func DecodeResponse

func DecodeResponse(data []byte) (*http.Response, uint32, error)

func EncodeRequest

func EncodeRequest(r *http.Request, seq uint32) ([]byte, error)

func EncodeResponse

func EncodeResponse(r *http.Response, seq uint32) ([]byte, error)

Types

type Transport3gppWsNotif

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

func NewTransport3gppWsNotif

func NewTransport3gppWsNotif(cfg *Transport3gppWsNotifCfg) (*Transport3gppWsNotif, error)

func (*Transport3gppWsNotif) DeregisterRespHandler

func (tr *Transport3gppWsNotif) DeregisterRespHandler(seqNum uint32)

func (*Transport3gppWsNotif) RegisterRespHandler

func (tr *Transport3gppWsNotif) RegisterRespHandler(seqNum uint32, handler chan *http.Response) error

func (*Transport3gppWsNotif) SendRequest

func (tr *Transport3gppWsNotif) SendRequest(req *http.Request) (*http.Response, error)

type Transport3gppWsNotifCfg

type Transport3gppWsNotifCfg struct {
	Name    string
	Ws      *Websocket
	Timeout time.Duration
}

type Websocket

type Websocket struct {
	Id          string                                       `json:"id"`
	State       string                                       `json:"state"`
	Endpoint    string                                       `json:"endpoint"`
	Uri         string                                       `json:"uri"`
	SeqNum      uint32                                       `json:"seq"`
	ConnHandler func(w http.ResponseWriter, r *http.Request) `json:"-"`
	// contains filtered or unexported fields
}

func NewWebsocket

func NewWebsocket() (*Websocket, error)

func (*Websocket) Close

func (ws *Websocket) Close()

func (*Websocket) ConnectionHandler

func (ws *Websocket) ConnectionHandler(w http.ResponseWriter, r *http.Request)

func (*Websocket) DeregisterMsgHandler

func (ws *Websocket) DeregisterMsgHandler(name string) error

func (*Websocket) RegisterMsgHandler

func (ws *Websocket) RegisterMsgHandler(name string, handler chan *WebsocketMsg) error

func (*Websocket) SendMessage

func (ws *Websocket) SendMessage(msg []byte) error

type WebsocketMsg

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