websocket

type Channel struct {
	*channel.DefaultNetChannel

	Response *gtp.Response
	Request  *gtp.Request
	// contains filtered or unexported fields
}

type CloseCode int

type CloseMessage struct {
	DefaultMessage
	CloseCode CloseCode `json:"close_code,omitempty"`
}

type DefaultHandlerTask struct {
	http.DefaultHandlerTask
	Builder DefaultMessageBuilder
}

type DefaultMessage struct {
	MessageType MessageType `json:"message_type,omitempty"`
	Message     []byte      `json:"message,omitempty"`
	Dead        *time.Time  `json:"dead,omitempty"`
}

type DefaultMessageBuilder struct{}

type DefaultServerHandlerTask struct {
	DefaultHandlerTask
}

type HandlerTask interface {
	WSPing(ctx channel.HandlerContext, message *PingMessage, params map[string]any)
	WSPong(ctx channel.HandlerContext, message *PongMessage, params map[string]any)
	WSClose(ctx channel.HandlerContext, message *CloseMessage, params map[string]any)
	WSBinary(ctx channel.HandlerContext, message *DefaultMessage, params map[string]any)
	WSText(ctx channel.HandlerContext, message *DefaultMessage, params map[string]any)
	WSConnected(ch channel.Channel, req *http.Request, resp *http.Response, params map[string]any)
	WSDisconnected(ch channel.Channel, req *http.Request, resp *http.Response, params map[string]any)
	WSErrorCaught(ctx channel.HandlerContext, req *http.Request, resp *http.Response, msg Message, err error)
}

type InvokeHandler struct {
	channel.DefaultHandler
	DefaultHandlerTask
	// contains filtered or unexported fields
}

type Message interface {
	Type() MessageType
	Encoded() []byte
	Deadline() *time.Time
}

type MessageBuilder interface {
	Text(msg string) *DefaultMessage
	Binary(msg []byte) *DefaultMessage
	Close(msg []byte, closeCode CloseCode) *CloseMessage
	Ping(msg []byte, deadline time.Time) *PingMessage
	Pong(msg []byte, deadline time.Time) *PongMessage
}

type MessageType int

type PingMessage struct {
	DefaultMessage
}

type PongMessage PingMessage

type ServerHandlerTask interface {
	HandlerTask
	WSUpgrade(req *http.Request, resp *http.Response, params map[string]any) bool
}

type WSCustomConnectConfig struct {
	Url    string
	Header http.Header
}

type WSLogStruct struct {
	LogType    string   `json:"log_type,omitempty"`
	RemoteAddr net.Addr `json:"remote_addr,omitempty"`
	LocalAddr  net.Addr `json:"local_addr,omitempty"`
	RequestURI string   `json:"request_uri,omitempty"`
	ChannelID  string   `json:"channel_id,omitempty"`
	TrackID    string   `json:"trace_id,omitempty"`
	Message    Message  `json:"message,omitempty"`
	Error      error    `json:"error,omitempty"`
}

type WSUpgradeProcessor struct {
	channel.DefaultHandler

	UpgradeCheckFunc func(req *gtp.Request, resp *gtp.Response, params map[string]any) bool
	// contains filtered or unexported fields
}