server

Documentation

Index

• Constants
• type Server
  • func NewServer(conn net.PacketConn, isAgent bool) *Server
  • func NewServerByAddress(address string) *Server
  • func (s *Server) CloseSocket(id string) error
  • func (s *Server) ConnectByIce(conn net.PacketConn)
  • func (s *Server) GetSocket(id string) *network.Socket
  • func (s *Server) OnClosed() error
  • func (s *Server) OnClosing() bool
  • func (s *Server) StartListen(onDisconnect network.SocketCallbackFunc)
• type Stream

Constants

const MaxStreamCount = 6

Types

type Server

type Server struct {
	Sockets  map[string]*network.Socket
	NetConn  net.PacketConn
	QuicConn *quic.Conn

	OnAcceptSocket       network.SocketCallbackFunc
	OnSocketDisConnected network.SocketCallbackFunc

	network.Config
	ice.IceWorker
	framework.CloseableObject
	// contains filtered or unexported fields
}

func NewServer

func NewServer(conn net.PacketConn, isAgent bool) *Server

NewServer 创建新的服务实例

func NewServerByAddress

func NewServerByAddress(address string) *Server

NewServerByAddress 创建新的服务实例，根据设置的地址监听

func (*Server) CloseSocket

func (s *Server) CloseSocket(id string) error

func (*Server) ConnectByIce

func (s *Server) ConnectByIce(conn net.PacketConn)

func (*Server) GetSocket

func (s *Server) GetSocket(id string) *network.Socket

func (*Server) OnClosed

func (s *Server) OnClosed() error

func (*Server) OnClosing

func (s *Server) OnClosing() bool

func (*Server) StartListen

func (s *Server) StartListen(onDisconnect network.SocketCallbackFunc)

type Stream

type Stream struct {
	Info   *network.StreamInfo
	Stream *quic.Stream
	Server *Server
}