Documentation
¶
Index ¶
- func NewLib(options ...listener.Option) listener.Listener
- func WithEndToEndEncryption(opts listener.EndToEndOption) listener.Option
- func WithTracer(tr tracingInterface.Tracing) listener.Option
- type Modules
- func (c *Modules) Close()
- func (c *Modules) GetAllServices() (res []*proto.ServicesItems)
- func (c *Modules) GetGrpcServer() *grpc.Server
- func (c *Modules) GetInterceptor() (interceptor []listener.Interceptor)
- func (c *Modules) GetLimiter() *limiter.Limiter
- func (c *Modules) GetMonitor() (mm interface{})
- func (c *Modules) GetMonitorResponse() *proto.MonitorResponse
- func (c *Modules) GetOptions() listener.Options
- func (c *Modules) GetServices() []string
- func (c *Modules) GetTLSCerts() listener.TLSCerts
- func (c *Modules) GetTracer() (tr tracingInterface.Tracing)
- func (c *Modules) GlobalContext() context.Context
- func (c *Modules) Init(opt listener.Options, interceptor ...listener.Interceptor) listener.Listener
- func (c *Modules) InitProcess(opt listener.Options, interceptor ...listener.Interceptor)
- func (c *Modules) New() listener.Listener
- func (c *Modules) NewMonitor() (mm interface{})
- func (c *Modules) RegisterHttpHandler(path, method string, handler netHttp.Handler)
- func (c *Modules) RegisterHttpPrefixHandler(path, method string, handler netHttp.Handler)
- func (c *Modules) RegisterMultipleHandler(handler listener.MethodMultipleHandler)
- func (c *Modules) Run() (err error)
- func (c *Modules) SetMonitor(mm interface{})
- func (c *Modules) SetTracer(tr tracingInterface.Tracing)
- func (c *Modules) UseEndToEndEncryption(opts listener.EndToEndOption) listener.Listener
- func (c *Modules) UseGrpcEncryption(codec encoding.Codec)
- func (c *Modules) UseWebSocket(pa string, onConnected listener.WebSocketHandler, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithEndToEndEncryption ¶
func WithEndToEndEncryption(opts listener.EndToEndOption) listener.Option
func WithTracer ¶
func WithTracer(tr tracingInterface.Tracing) listener.Option
Types ¶
type Modules ¶
func (*Modules) GetAllServices ¶
func (c *Modules) GetAllServices() (res []*proto.ServicesItems)
func (*Modules) GetGrpcServer ¶
func (*Modules) GetInterceptor ¶
func (c *Modules) GetInterceptor() (interceptor []listener.Interceptor)
func (*Modules) GetLimiter ¶
func (*Modules) GetMonitor ¶
func (c *Modules) GetMonitor() (mm interface{})
func (*Modules) GetMonitorResponse ¶
func (c *Modules) GetMonitorResponse() *proto.MonitorResponse
func (*Modules) GetOptions ¶
func (*Modules) GetServices ¶
func (*Modules) GetTLSCerts ¶
func (*Modules) GetTracer ¶
func (c *Modules) GetTracer() (tr tracingInterface.Tracing)
func (*Modules) GlobalContext ¶
func (*Modules) InitProcess ¶
func (c *Modules) InitProcess(opt listener.Options, interceptor ...listener.Interceptor)
func (*Modules) NewMonitor ¶
func (c *Modules) NewMonitor() (mm interface{})
func (*Modules) RegisterHttpHandler ¶
func (*Modules) RegisterHttpPrefixHandler ¶
func (*Modules) RegisterMultipleHandler ¶
func (c *Modules) RegisterMultipleHandler(handler listener.MethodMultipleHandler)
func (*Modules) SetMonitor ¶
func (c *Modules) SetMonitor(mm interface{})
func (*Modules) SetTracer ¶
func (c *Modules) SetTracer(tr tracingInterface.Tracing)
func (*Modules) UseEndToEndEncryption ¶
func (c *Modules) UseEndToEndEncryption(opts listener.EndToEndOption) listener.Listener
func (*Modules) UseGrpcEncryption ¶
func (*Modules) UseWebSocket ¶
func (c *Modules) UseWebSocket(pa string, onConnected listener.WebSocketHandler, onMsg listener.WebSocketHandlerOnMsg, onDisconnected listener.WebSocketHandler) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.