Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientConnection ¶
type ClientConnection struct {
// contains filtered or unexported fields
}
func (*ClientConnection) ClientId ¶
func (clientConnection *ClientConnection) ClientId() string
func (*ClientConnection) Send ¶
func (clientConnection *ClientConnection) Send(target string, arguments ...interface{})
type Context ¶
type Context struct {
// contains filtered or unexported fields
}
func (*Context) Client ¶
func (context *Context) Client() *HubConnection
func (*Context) NewStreamWriter ¶
func (context *Context) NewStreamWriter() *StreamWriter
type Hub ¶
type Hub struct { }
type HubConnection ¶
type HubConnection struct {
// contains filtered or unexported fields
}
func (*HubConnection) ClientID ¶
func (client *HubConnection) ClientID() string
func (*HubConnection) Send ¶
func (client *HubConnection) Send(target string, arguments ...interface{})
type HubProtocol ¶
type IHub ¶
type IHubInstanceReader ¶
type IHubInstanceReader interface {
// contains filtered or unexported methods
}
type IMux ¶
type IMux interface { //HandleFunc(pattern string, handler func(http.ResponseWriter, *http.Request)) //Handle(pattern string, handler http.Handler) Get(pattern string, h http.HandlerFunc) Post(pattern string, h http.HandlerFunc) }
type Invocatory ¶
type Invocatory struct {
// contains filtered or unexported fields
}
type JsonHubProtocol ¶
type JsonHubProtocol struct { }
func NewJsonHubProtocol ¶
func NewJsonHubProtocol() *JsonHubProtocol
func (*JsonHubProtocol) Deserialize ¶
func (hubProtocol *JsonHubProtocol) Deserialize(data []byte, v interface{}) error
func (*JsonHubProtocol) Serialize ¶
func (hubProtocol *JsonHubProtocol) Serialize(data interface{}) ([]byte, error)
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
type StreamWriter ¶
type StreamWriter struct {
// contains filtered or unexported fields
}
func (*StreamWriter) Write ¶
func (streamWriter *StreamWriter) Write(data interface{})
type WebsocketTransport ¶
type WebsocketTransport struct { }
func NewWebsocketTransport ¶
func NewWebsocketTransport() *WebsocketTransport
func (*WebsocketTransport) Upgrade ¶
func (wst *WebsocketTransport) Upgrade(w http.ResponseWriter, r *http.Request) (*WebsocketTransportConnection, error)
type WebsocketTransportConnection ¶
type WebsocketTransportConnection struct {
// contains filtered or unexported fields
}
func (*WebsocketTransportConnection) Close ¶
func (wstConn *WebsocketTransportConnection) Close() error
func (*WebsocketTransportConnection) ReadMessage ¶
func (wstConn *WebsocketTransportConnection) ReadMessage() ([]byte, error)
func (*WebsocketTransportConnection) WriteMessage ¶
func (wstConn *WebsocketTransportConnection) WriteMessage(message []byte) error
Click to show internal directories.
Click to hide internal directories.