lib

Documentation

Index

• Variables
• func NewLib() listener.Listener
• type Listener
  • func NewListener(listener interfaces.Listener) *Listener
  • func (c *Listener) AddOrSkip(l *listenerproto.RouterListener, h http.HandlerFunc)
  • func (c *Listener) NewHTTPListener(s *listenerproto.RouterListener, h http.HandlerFunc)
• type ListenerItems
• type Modules
  • func (c *Modules) GetAllServices() (res []*listenerproto.ServicesItems)
  • func (c *Modules) GetInterceptor() (interceptor []listener.Interceptor)
  • func (c *Modules) GetMonitor() *listenerproto.MonitorResponse
  • func (c *Modules) GetOptions() listener.Options
  • func (c *Modules) GetServices() []string
  • func (c *Modules) GetTracer() (tr tracing.Tracing)
  • func (c *Modules) Init(opt listener.Options, interceptor ...listener.Interceptor)
  • func (c *Modules) New() listener.Listener
  • func (c *Modules) OnPushMessage(request *global.PushRequest, onMsg listener.OnPushMessageResponse)
  • func (c *Modules) PushRouterListener(l *listenerproto.RouterListener, h httpn.HandlerFunc)
  • func (c *Modules) RegisterHttpHandler(path, method string, handler httpn.Handler)
  • func (c *Modules) RegisterMultipleHandler(handler listener.MethodMultipleHandler)
  • func (c *Modules) Run() (err error)
  • func (c *Modules) RunRouter() (err error)
  • func (c *Modules) SetTracer(tr tracing.Tracing)
  • func (c *Modules) UseWebSocket(pa string, onConnected listener.WebSocketHandler, ...) error
• type Router
  • func NewRouter(listener interfaces.Listener) *Router
  • func (c *Router) PushRouterListener(l *listenerproto.RouterListener, h http.HandlerFunc)
  • func (c *Router) Start()
• type RouterHeader
• type Server
  • func (c *Server) Listen()
• type TcpKeepAliveListener
  • func (ln TcpKeepAliveListener) Accept() (c net.Conn, err error)

Variables

var BuildDate string

var Commit string

var OSBuildName string

var Version string

Functions

func NewLib

func NewLib() listener.Listener

Types

type Listener

type Listener struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewListener

func NewListener(listener interfaces.Listener) *Listener

func (*Listener) AddOrSkip

func (c *Listener) AddOrSkip(l *listenerproto.RouterListener, h http.HandlerFunc)

func (*Listener) NewHTTPListener

func (c *Listener) NewHTTPListener(s *listenerproto.RouterListener, h http.HandlerFunc)

type ListenerItems

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

type Modules

type Modules struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Modules) GetAllServices

func (c *Modules) GetAllServices() (res []*listenerproto.ServicesItems)

func (*Modules) GetInterceptor

func (c *Modules) GetInterceptor() (interceptor []listener.Interceptor)

func (*Modules) GetMonitor

func (c *Modules) GetMonitor() *listenerproto.MonitorResponse

func (*Modules) GetOptions

func (c *Modules) GetOptions() listener.Options

func (*Modules) GetServices

func (c *Modules) GetServices() []string

func (*Modules) GetTracer

func (c *Modules) GetTracer() (tr tracing.Tracing)

func (*Modules) Init

func (c *Modules) Init(opt listener.Options, interceptor ...listener.Interceptor)

func (*Modules) New

func (c *Modules) New() listener.Listener

func (*Modules) OnPushMessage

func (c *Modules) OnPushMessage(request *global.PushRequest, onMsg listener.OnPushMessageResponse)

func (*Modules) PushRouterListener

func (c *Modules) PushRouterListener(l *listenerproto.RouterListener, h httpn.HandlerFunc)

func (*Modules) RegisterHttpHandler

func (c *Modules) RegisterHttpHandler(path, method string, handler httpn.Handler)

func (*Modules) RegisterMultipleHandler

func (c *Modules) RegisterMultipleHandler(handler listener.MethodMultipleHandler)

func (*Modules) Run

func (c *Modules) Run() (err error)

func (*Modules) RunRouter

func (c *Modules) RunRouter() (err error)

func (*Modules) SetTracer

func (c *Modules) SetTracer(tr tracing.Tracing)

func (*Modules) UseWebSocket

func (c *Modules) UseWebSocket(pa string, onConnected listener.WebSocketHandler, onMsg listener.WebSocketHandlerOnMsg, onDisconnected listener.WebSocketHandler) error

type Router

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

func NewRouter

func NewRouter(listener interfaces.Listener) *Router

func (*Router) PushRouterListener

func (c *Router) PushRouterListener(l *listenerproto.RouterListener, h http.HandlerFunc)

func (*Router) Start

func (c *Router) Start()

type RouterHeader

type RouterHeader struct {
	LimiterID string
}

type Server

type Server struct {
	Server *http.Server
	// contains filtered or unexported fields
}

func (*Server) Listen

func (c *Server) Listen()

type TcpKeepAliveListener

type TcpKeepAliveListener struct {
	*net.TCPListener
}

func (TcpKeepAliveListener) Accept

func (ln TcpKeepAliveListener) Accept() (c net.Conn, err error)