websockets

type Config struct {
	MaxConnections        int    `json:"maxConnections"`
	HandshakeTimeout      string `json:"handshakeTimeout"`
	ReadTimeout           string `json:"readTimeout"`
	ReadBufferSize        string `json:"readBufferSize"`
	WriteTimeout          string `json:"writeTimeout"`
	WriteBufferSize       string `json:"writeBufferSize"`
	EnableCompression     bool   `json:"enableCompression"`
	MaxRequestMessageSize string `json:"maxRequestMessageSize"`
}

type Connection interface {
	ReadMessage() (messageType MessageType, p []byte, err error)
	WriteMessage(messageType MessageType, data []byte) (err error)
	WriteControl(messageType MessageType, data []byte, deadline time.Time) error
	NextWriter(messageType MessageType) (io.WriteCloser, error)
	SetWriteDeadline(t time.Time) error
	NextReader() (messageType MessageType, r io.Reader, err error)
	SetReadDeadline(t time.Time) error
	SetReadLimit(limit int64)
	CloseHandler() func(code int, text string) error
	SetCloseHandler(h func(code int, text string) error)
	PingHandler() func(appData string) error
	SetPingHandler(h func(appData string) error)
	PongHandler() func(appData string) error
	SetPongHandler(h func(appData string) error)
	UnderlyingConn() net.Conn
	EnableWriteCompression(enable bool)
	SetCompressionLevel(level int) error
	Subprotocol() (protocol string)
	Close() (err error)
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
}

type MessageType int

type Request struct {
	Service string          `json:"service"`
	Fn      string          `json:"fn"`
	Header  http.Header     `json:"header"`
	Payload json.RawMessage `json:"payload"`
}

type Response struct {
	Succeed bool        `json:"succeed"`
	Payload interface{} `json:"result"`
}

type Service struct {
	service.Abstract
	// contains filtered or unexported fields
}

type SubProtocolHandler interface {
	Name() (name string)
	Build(options SubProtocolHandlerOptions) (err error)
	Handle(ctx context.Context, conn Connection)
	Service() (service service.Service)
	Close() (err error)
}

type SubProtocolHandlerOptions struct {
	AppId                 string
	AppName               string
	AppVersion            versions.Version
	Log                   logs.Logger
	Config                configures.Config
	ReadTimeout           time.Duration
	WriteTimeout          time.Duration
	MaxRequestMessageSize int64
	Discovery             service.EndpointDiscovery `json:"-"`
}

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

type Task struct {
	*workers.AbstractLongTask
	// contains filtered or unexported fields
}

type WebsocketConnection struct {
	*websocket.Conn
}