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"`
	OriginCheckPolicy     OriginCheckPolicyConfig `json:"originCheckPolicy"`
	ConnectionTTL         string                  `json:"connectionTTL"`
	EnableEcho            bool                    `json:"enableEcho"`
}

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 []byte) error
	SetPingHandler(h func(appData []byte) error)
	PongHandler() func(appData []byte) error
	SetPongHandler(h func(appData []byte) error)
	EnableWriteCompression(enable bool)
	SetCompressionLevel(level int) error
	Subprotocol() (protocol string)
	Close() (err error)
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
}

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

type MessageType int

type Option func(options *Options)

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

type OriginCheckPolicyConfig struct {
	Mode    string          `json:"mode"`
	Options json.RawMessage `json:"options"`
}

type Registration interface {
	services.Component
	Get(ctx context.Context, id []byte) (endpointId []byte, has bool, err error)
	Set(ctx context.Context, id []byte, endpointId []byte, ttl time.Duration) (err error)
	Remove(ctx context.Context, id []byte) (err error)
}

type Request struct {
	Endpoint string            `json:"endpoint"`
	Fn       string            `json:"fn"`
	Header   transports.Header `json:"header"`
	Payload  json.RawMessage   `json:"payload"`
}

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

type SendOption func(options *SendOptions)

type SendOptions struct {
	EndpointId []byte
}

type SendParam struct {
	ConnectionId string `json:"connectionId" avro:"connectionId"`
	Message      []byte `json:"message" avro:"message"`
}

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

type SubProtocolHandlerOptions struct {
	Log                   logs.Logger
	Config                configures.Config
	ReadTimeout           time.Duration
	WriteTimeout          time.Duration
	MaxRequestMessageSize int64
}

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

type WebsocketConnection struct {
	*websocket.Conn
	// contains filtered or unexported fields
}