server

type ConnNotify func(conn.Connection)

type LoggerFilter struct{}

type Options struct {
	Addr               string
	TLS                *tls.Config
	ConnNotify         ConnNotify
	OnReadTransportErr func(nodeID, projectID string)
	ConnMgr            *cmgr.ConnectionManager
	ConnNumMax         int
	AutoRoute          bool
	HandshakeTimeout   time.Duration
	Handler            mux.Handler
	Consumer           io.Writer
}

type ProtocolServer interface {
	ListenAndServeTLS() error
	Close() error
}

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

type Server struct {
	// protocol type used
	Type string
	// the server address
	Addr string
	// the tls config
	TLSConfig *tls.Config
	// ConnNotify will be called when a new connection coming
	ConnNotify ConnNotify
	// OnReadTransportErr is invoked when the connection read message err
	OnReadTransportErr func(nodeID, projectID string)
	// the local connection store
	ConnMgr *cmgr.ConnectionManager
	//auto route
	AutoRoute bool
	// handshake timeout
	HandshakeTimeout time.Duration
	// mux handler
	Handler mux.Handler
	// consumer for raw data
	Consumer io.Writer
	// extend options
	ExOpts interface{}
	// contains filtered or unexported fields
}

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