websocket

type BinaryNetPacket struct {
	Type    NetMessageType
	Payload []byte
}

type Creator func() any

type MessageHandlerData struct {
	Handler NetMessageHandler
	Creator Creator
}

type MessagePayload any

type Middleware = func(http.Handler) http.Handler

type NetMessageHandler func(SessionID, MessagePayload) error

type NetMessageHandlerMap map[NetMessageType]*MessageHandlerData

type NetMessageType uint32

type NetPacketMarshaler func(messageType NetMessageType, message MessagePayload) ([]byte, error)

type NetPacketUnmarshaler func(buf []byte) (*MessageHandlerData, MessagePayload, error)

type Option func(*Server)

type PayloadType uint8

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

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

type SessionHooks interface {
	// contains filtered or unexported methods
}

type SessionID string

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

type SessionObserver interface {
	// OnSessionAdded 在新会话被添加时调用。
	OnSessionAdded(session *Session)
	// OnSessionRemoved 在会话被移除时调用。
	OnSessionRemoved(session *Session)
}

type SocketConnectHandler func(sessionId SessionID, queries url.Values, connect bool)

type SocketRawDataHandler func(sessionId SessionID, buf []byte) error

type TextNetPacket struct {
	Type    NetMessageType `json:"type" xml:"type"`
	Payload string         `json:"payload" xml:"payload"`
}