websocket

type Addr struct {
	*url.URL
}

type Codec struct {
	Marshal   func(v any) (data []byte, payloadType byte, err error)
	Unmarshal func(data []byte, payloadType byte, v any) (err error)
}

type Conn struct {
	PayloadType byte

	MaxPayloadBytes int
	// contains filtered or unexported fields
}

type ConnConfig struct {
	Location  *url.URL    // websocket服务端地址
	Origin    *url.URL    // websocket客户端地址
	Protocol  []string    // 协议
	Version   int         // 协议版本
	TlsConfig *tls.Config // wss的配置
	Header    http.Header // Additional header fields to be sent in WebSocket opening handshake.
	Dialer    *net.Dialer // Dialer used when opening websocket connections.
	// contains filtered or unexported fields
}

type DecodeRequestFunc func(ctx context.Context, r *Conn) (req any, err error)

type EncodeResponseFunc func(ctx context.Context, w *Conn, res any) error

type ErrorEncoder func(ctx context.Context, err error, w *Conn)

type Handler struct {
	DecodeRequest  DecodeRequestFunc
	EncodeResponse EncodeResponseFunc
	ErrorEncoder   ErrorEncoder
	Endpoint       endpoint.Endpoint
}

type ProtocolError struct {
	ErrorString string
}

type Response struct {
	Success bool   `json:"success"`
	Code    int    `json:"code"`
	Message string `json:"message,omitempty"`
	Data    any    `json:"datas,omitempty"`
}

type Server struct {
	Config  ServerConfig
	Handler http.Handler
	Limiter *limiter.Limiter
	Nacos   *nacos.Nacos
}

type ServerConfig struct {
	Name         string `mapstructure:"name"`
	Host         string `mapstructure:"host"`
	Port         string `mapstructure:"port"`
	ReadTimeout  int64  `mapstructure:"readTimeout"`
	WriteTimeout int64  `mapstructure:"writeTimeout"`
	Metadata     map[string]string
}