lib

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 1, 2023 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var BuildDate string
View Source
var Commit string
View Source
var OSBuildName string
View Source
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 (*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) GetGrpcServer

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

func (*Modules) GetOptions

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

func (*Modules) GetServices

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

func (*Modules) Init

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

func (*Modules) New

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

func (*Modules) PushRouterListener

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

func (*Modules) RegisterGrpcHandler

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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL