server

Documentation

Overview

Package server @Title handler.go @Description @Author peanut996 @Update peanut996 2021/5/24 16:11

Index

• func NewSIOHandlers() map[string]interface{}
• func ToString(c sio.Conn) string
• type Server
  • func NewServer() *Server
  • func (s *Server) AcceptSession(session *Session) error
  • func (s *Server) Auth(session *Session) (bool, error)
  • func (s *Server) Consume(consumeFunc func(event *api.SingleInvokeRequest))
  • func (s *Server) ConsumeEvent(event *api.SingleInvokeRequest)
  • func (s *Server) DebugMapVars(c *gin.Context)
  • func (s *Server) DisconnectSession(conn sio.Conn) *Session
  • func (s *Server) HandleInvoke(c *gin.Context)
  • func (s *Server) HandleInvokeEvent(scene, event string, data interface{})
  • func (s *Server) Init(cfg *cfgargs.SrvConfig)
  • func (s *Server) MountHandlers()
  • func (s *Server) OnConnect(f func(sio.Conn) error)
  • func (s *Server) OnDisconnect(f func(sio.Conn, string))
  • func (s *Server) OnError(f func(sio.Conn, error))
  • func (s *Server) Produce(event *api.SingleInvokeRequest)
  • func (s *Server) Run(cfg *cfgargs.SrvConfig) error
  • func (s *Server) SetNameSpace(nsp string)
  • func (s *Server) SocketEventHandler(event string) interface{}
• type Session
  • func NewSession(conn sio.Conn) *Session
  • func (s *Session) GetID() string
  • func (s *Session) GetScene() string
  • func (s *Session) Push(event string, data interface{})
  • func (s *Session) SetScene(scene string)
  • func (s *Session) ToString() string

Functions

func NewSIOHandlers

func NewSIOHandlers() map[string]interface{}

func ToString

func ToString(c sio.Conn) string

Types

type Server

type Server struct {
	SocketIOToSessions map[string]*Session
	//UIDSceneToSessions map[string]*Session
	SceneToSessions map[string][]*Session

	sync.Mutex
	// contains filtered or unexported fields
}

func NewServer

func NewServer() *Server

func (*Server) AcceptSession

func (s *Server) AcceptSession(session *Session) error

AcceptSession authentication for session

func (*Server) Auth

func (s *Server) Auth(session *Session) (bool, error)

func (*Server) Consume

func (s *Server) Consume(consumeFunc func(event *api.SingleInvokeRequest))

func (*Server) ConsumeEvent

func (s *Server) ConsumeEvent(event *api.SingleInvokeRequest)

func (*Server) DebugMapVars

func (s *Server) DebugMapVars(c *gin.Context)

func (*Server) DisconnectSession

func (s *Server) DisconnectSession(conn sio.Conn) *Session

func (*Server) HandleInvoke

func (s *Server) HandleInvoke(c *gin.Context)

func (*Server) HandleInvokeEvent

func (s *Server) HandleInvokeEvent(scene, event string, data interface{})

func (*Server) Init

func (s *Server) Init(cfg *cfgargs.SrvConfig)

func (*Server) MountHandlers

func (s *Server) MountHandlers()

func (*Server) OnConnect

func (s *Server) OnConnect(f func(sio.Conn) error)

func (*Server) OnDisconnect

func (s *Server) OnDisconnect(f func(sio.Conn, string))

func (*Server) OnError

func (s *Server) OnError(f func(sio.Conn, error))

func (*Server) Produce

func (s *Server) Produce(event *api.SingleInvokeRequest)

func (*Server) Run

func (s *Server) Run(cfg *cfgargs.SrvConfig) error

func (*Server) SetNameSpace

func (s *Server) SetNameSpace(nsp string)

SetNameSpace reset namespace

func (*Server) SocketEventHandler

func (s *Server) SocketEventHandler(event string) interface{}

type Session

type Session struct {
	Conn sio.Conn
	// contains filtered or unexported fields
}

func NewSession

func NewSession(conn sio.Conn) *Session

func (*Session) GetID

func (s *Session) GetID() string

func (*Session) GetScene

func (s *Session) GetScene() string

func (*Session) Push

func (s *Session) Push(event string, data interface{})

func (*Session) SetScene

func (s *Session) SetScene(scene string)

func (*Session) ToString

func (s *Session) ToString() string