lib

Documentation

Index

• func NewLib() listener.Listener
• 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)
  • 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) 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) UseWebSocket(pa string, onConnected listener.WebSocketHandler, ...) error

Functions

func NewLib

func NewLib() listener.Listener

Types

type Modules

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

func (*Modules) Close

func (c *Modules) Close()

func (*Modules) GetAllServices

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

func (*Modules) GetGrpcServer

func (c *Modules) GetGrpcServer() *grpc.Server

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() *proto.MonitorResponse

func (*Modules) GetOptions

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

func (*Modules) GetServices

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

func (*Modules) GetTLSCerts

func (c *Modules) GetTLSCerts() listener.TLSCerts

func (*Modules) GetTracer

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

func (*Modules) GlobalContext

func (c *Modules) GlobalContext() context.Context

func (*Modules) Init

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

func (*Modules) InitProcess

func (c *Modules) InitProcess(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) RegisterHttpHandler

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

func (*Modules) RegisterMultipleHandler

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

func (*Modules) Run

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

func (*Modules) SetMonitor

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

func (*Modules) SetTracer

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

func (*Modules) UseWebSocket

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