lib

Documentation

Index

• 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) AddOrSkipTcp(l *listenerproto.RouterListener, h interfaces.TcpHandler)
  • func (c *Listener) NewHTTPListener(s *listenerproto.RouterListener, h http.HandlerFunc)
  • func (c *Listener) NewTCPListener(s *listenerproto.RouterListener, h interfaces.TcpHandler)
  • func (c *Listener) Remove(name string) error
  • func (c *Listener) RemoveTcp(name string) error
• type ListenerItems
  • func (c *ListenerItems) Add(cw int64)
  • func (c *ListenerItems) Count() int
  • func (c *ListenerItems) OnStateChange(conn net.Conn, state http.ConnState)
• type Modules
  • func (c *Modules) GetAllServices() (res []*listenerproto.ServicesItems)
  • func (c *Modules) GetInterceptor() (interceptor []listener.Interceptor)
  • func (c *Modules) GetLimiter() *limiter.Limiter
  • func (c *Modules) GetMonitor() (mm interface{})
  • func (c *Modules) GetMonitorResponse() *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) NewMonitor() (mm interface{})
  • func (c *Modules) OnPushMessage(request *global.PushRequest, onMsg listener.OnPushMessageResponse)
  • func (c *Modules) PushRouterListener(l *listenerproto.RouterListener, h httpn.HandlerFunc)
  • func (c *Modules) PushRouterTcpListener(l *listenerproto.RouterListener, h listener.TcpHandler)
  • func (c *Modules) RegisterHttpHandler(path, method string, handler httpn.Handler)
  • func (c *Modules) RegisterMultipleHandler(handler listener.MethodMultipleHandler)
  • func (c *Modules) RemoveRouterListener(name string) error
  • func (c *Modules) RemoveRouterTcpListener(name string) error
  • func (c *Modules) Run() (err error)
  • func (c *Modules) RunRouter() (err error)
  • func (c *Modules) SetMonitor(mm interface{})
  • 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) PushRouterTcpListener(l *listenerproto.RouterListener, h interfaces.TcpHandler)
  • func (c *Router) RemoveRouterListener(name string) error
  • func (c *Router) RemoveRouterTcpListener(name string) error
  • func (c *Router) Start()
• type RouterHeader
• type Server
  • func (c *Server) Listen()
  • func (c *Server) ListenTcp() error
  • func (c *Server) StopTcp() error

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) AddOrSkipTcp

func (c *Listener) AddOrSkipTcp(l *listenerproto.RouterListener, h interfaces.TcpHandler)

func (*Listener) NewHTTPListener

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

func (*Listener) NewTCPListener

func (c *Listener) NewTCPListener(s *listenerproto.RouterListener, h interfaces.TcpHandler)

func (*Listener) Remove

func (c *Listener) Remove(name string) error

func (*Listener) RemoveTcp

func (c *Listener) RemoveTcp(name string) error

type ListenerItems

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

func (*ListenerItems) Add

func (c *ListenerItems) Add(cw int64)

func (*ListenerItems) Count

func (c *ListenerItems) Count() int

func (*ListenerItems) OnStateChange

func (c *ListenerItems) OnStateChange(conn net.Conn, state http.ConnState)

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) GetLimiter

func (c *Modules) GetLimiter() *limiter.Limiter

func (*Modules) GetMonitor

func (c *Modules) GetMonitor() (mm interface{})

func (*Modules) GetMonitorResponse

func (c *Modules) GetMonitorResponse() *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) NewMonitor

func (c *Modules) NewMonitor() (mm interface{})

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) PushRouterTcpListener

func (c *Modules) PushRouterTcpListener(l *listenerproto.RouterListener, h listener.TcpHandler)

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) RemoveRouterListener

func (c *Modules) RemoveRouterListener(name string) error

func (*Modules) RemoveRouterTcpListener

func (c *Modules) RemoveRouterTcpListener(name string) error

func (*Modules) Run

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

func (*Modules) RunRouter

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

func (*Modules) SetMonitor

func (c *Modules) SetMonitor(mm interface{})

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) PushRouterTcpListener

func (c *Router) PushRouterTcpListener(l *listenerproto.RouterListener, h interfaces.TcpHandler)

func (*Router) RemoveRouterListener

func (c *Router) RemoveRouterListener(name string) error

func (*Router) RemoveRouterTcpListener

func (c *Router) RemoveRouterTcpListener(name string) error

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()

func (*Server) ListenTcp

func (c *Server) ListenTcp() error

func (*Server) StopTcp

func (c *Server) StopTcp() error