ws

package

v0.0.0-...-33ac8c3 Latest Latest Go to latest Published: Mar 22, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Details

View Source

const (
	EventAuth = "auth"
	EventPing = "ping"
	EventPong = "pong"
)

View Source

const (
	ServerSystem = "system"
)

This section is empty.

func NewWsCodec() *wsCodec

func NewWsServer(cfg *dto.GatewayConfig, ce cache.Provider, tcpAddr string) gnet.EventHandler

type Server struct {
	gnet.BuiltinEventEngine
	// contains filtered or unexported fields
}

func (w *Server) OnBoot(eng gnet.Engine) gnet.Action

func (w *Server) OnClose(c gnet.Conn, err error) gnet.Action

func (w *Server) OnOpen(c gnet.Conn) (out []byte, action gnet.Action)

func (w *Server) OnShutdown(eng gnet.Engine)

func (w *Server) OnTick() (delay time.Duration, action gnet.Action)

func (w *Server) OnTraffic(c gnet.Conn) gnet.Action

type User struct {
	Id int64 `json:"id"`
}

type UserClaims struct {
	User User
	jwt.RegisteredClaims
}

func Intercept(ce cache.Provider, authHeader string) *UserClaims