websocket

package

v2.0.0+incompatible Latest Latest Go to latest Published: Nov 13, 2016 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type WebSocketClient struct {
	rpc.BaseClient
	http.Header
	// contains filtered or unexported fields
}

WebSocketClient is hprose websocket client

func NewWebSocketClient(uri ...string) (client *WebSocketClient)

NewWebSocketClient is the constructor of WebSocketClient

func (client *WebSocketClient) Close()

Close the client

func (client *WebSocketClient) MaxConcurrentRequests() int

MaxConcurrentRequests returns max concurrent request count

func (client *WebSocketClient) SetMaxConcurrentRequests(value int)

SetMaxConcurrentRequests sets max concurrent request count

func (client *WebSocketClient) SetTLSClientConfig(config *tls.Config)

SetTLSClientConfig sets the tls.Config

func (client *WebSocketClient) SetURIList(uriList []string)

SetURIList sets a list of server addresses

func (client *WebSocketClient) TLSClientConfig() *tls.Config

TLSClientConfig returns the tls.Config in hprose client

type WebSocketContext struct {
	rpc.HTTPContext
	WebSocket *websocket.Conn
}

WebSocketContext is the hprose websocket context

type WebSocketService struct {
	rpc.HTTPService
	websocket.Upgrader
	// contains filtered or unexported fields
}

WebSocketService is the hprose websocket service

func NewWebSocketService() (service *WebSocketService)

NewWebSocketService is the constructor of WebSocketService

func (service *WebSocketService) ServeHTTP(
	response http.ResponseWriter, request *http.Request)

ServeHTTP is the hprose http handler method