app

package

v0.1.3-beta Latest Latest Go to latest Published: Dec 26, 2023 License: Apache-2.0 Imports: 15 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/go-lynx/lynx

Documentation ¶

Index ¶

func Host() string
func Name() string
func ServiceDiscovery() registry.Discovery
func ServiceRegistry() registry.Registrar
func Version() string
type Base
type Cert
type Config
type ControlPlane
type DefaultLynxPluginManager
- func (m *DefaultLynxPluginManager) GetPlugin(name string) plugin.Plugin
- func (m *DefaultLynxPluginManager) LoadPlugins(conf config.Config)
- func (m *DefaultLynxPluginManager) LoadPluginsByName(name []string, conf config.Config)
- func (m *DefaultLynxPluginManager) PreparePlug(config config.Config) []string
- func (m *DefaultLynxPluginManager) TopologicalSort(plugins []plugin.Plugin) ([]PluginWithLevel, error)
- func (m *DefaultLynxPluginManager) UnloadPlugins()
- func (m *DefaultLynxPluginManager) UnloadPluginsByName(name []string)
type Limiter
type LocalControlPlane
- func (c *LocalControlPlane) Config(fileName string, group string) (config.Source, error)
- func (c *LocalControlPlane) GrpcRateLimit() middleware.Middleware
- func (c *LocalControlPlane) HttpRateLimit() middleware.Middleware
- func (c *LocalControlPlane) Namespace() string
- func (c *LocalControlPlane) NewNodeRouter(name string) selector.NodeFilter
- func (c *LocalControlPlane) NewServiceDiscovery() registry.Discovery
- func (c *LocalControlPlane) NewServiceRegistry() registry.Registrar
type LynxApp
- func Lynx() *LynxApp
- func NewApp(c config.Config, p ...plugin.Plugin) *LynxApp
- func (a *LynxApp) Cert() Cert
- func (a *LynxApp) ControlPlane() ControlPlane
- func (a *LynxApp) ControlPlaneBootConfiguration() config.Config
- func (a *LynxApp) GlobalConfig() config.Config
- func (a *LynxApp) Helper() *log.Helper
- func (a *LynxApp) InitLogger()
- func (a *LynxApp) Logger() log.Logger
- func (a *LynxApp) PlugManager() LynxPluginManager
- func (a *LynxApp) SetCert(cert Cert)
- func (a *LynxApp) SetControlPlane(plane ControlPlane)
- func (a *LynxApp) TxManager() tx.TransactionManager
type LynxPluginManager
- func NewLynxPluginManager(p ...plugin.Plugin) LynxPluginManager
type PluginWithLevel
type Registry
type Router

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Host ¶

func Host() string

func Name ¶

func Name() string

func ServiceDiscovery ¶

func ServiceDiscovery() registry.Discovery

func ServiceRegistry ¶

func ServiceRegistry() registry.Registrar

func Version ¶

func Version() string

Types ¶

type Base ¶

type Base interface {
	Namespace() string
}

type Cert ¶

type Cert interface {
	GetCrt() []byte
	GetKey() []byte
	GetRootCA() []byte
}

type Config ¶

type Config interface {
	Config(fileName string, group string) (config.Source, error)
}

type ControlPlane ¶

type ControlPlane interface {
	Base
	Limiter
	Registry
	Router
	Config
}

type DefaultLynxPluginManager ¶

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

func (*DefaultLynxPluginManager) GetPlugin ¶

func (m *DefaultLynxPluginManager) GetPlugin(name string) plugin.Plugin

func (*DefaultLynxPluginManager) LoadPlugins ¶

func (m *DefaultLynxPluginManager) LoadPlugins(conf config.Config)

func (*DefaultLynxPluginManager) LoadPluginsByName ¶

func (m *DefaultLynxPluginManager) LoadPluginsByName(name []string, conf config.Config)

func (*DefaultLynxPluginManager) PreparePlug ¶

func (m *DefaultLynxPluginManager) PreparePlug(config config.Config) []string

PreparePlug Bootstrap plugin loading through remote or local configuration files

func (*DefaultLynxPluginManager) TopologicalSort ¶

func (m *DefaultLynxPluginManager) TopologicalSort(plugins []plugin.Plugin) ([]PluginWithLevel, error)

func (*DefaultLynxPluginManager) UnloadPlugins ¶

func (m *DefaultLynxPluginManager) UnloadPlugins()

func (*DefaultLynxPluginManager) UnloadPluginsByName ¶

func (m *DefaultLynxPluginManager) UnloadPluginsByName(name []string)

type Limiter ¶

type Limiter interface {
	HttpRateLimit() middleware.Middleware
	GrpcRateLimit() middleware.Middleware
}

type LocalControlPlane ¶

type LocalControlPlane struct {
}

func (*LocalControlPlane) Config ¶

func (c *LocalControlPlane) Config(fileName string, group string) (config.Source, error)

func (*LocalControlPlane) GrpcRateLimit ¶

func (c *LocalControlPlane) GrpcRateLimit() middleware.Middleware

func (*LocalControlPlane) HttpRateLimit ¶

func (c *LocalControlPlane) HttpRateLimit() middleware.Middleware

func (*LocalControlPlane) Namespace ¶

func (c *LocalControlPlane) Namespace() string

func (*LocalControlPlane) NewNodeRouter ¶

func (c *LocalControlPlane) NewNodeRouter(name string) selector.NodeFilter

func (*LocalControlPlane) NewServiceDiscovery ¶

func (c *LocalControlPlane) NewServiceDiscovery() registry.Discovery

func (*LocalControlPlane) NewServiceRegistry ¶

func (c *LocalControlPlane) NewServiceRegistry() registry.Registrar

type LynxApp ¶

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

func Lynx ¶

func Lynx() *LynxApp

func NewApp ¶

func NewApp(c config.Config, p ...plugin.Plugin) *LynxApp

NewApp create a lynx microservice

func (*LynxApp) Cert ¶

func (a *LynxApp) Cert() Cert

func (*LynxApp) ControlPlane ¶

func (a *LynxApp) ControlPlane() ControlPlane

func (*LynxApp) ControlPlaneBootConfiguration ¶

func (a *LynxApp) ControlPlaneBootConfiguration() config.Config

func (*LynxApp) GlobalConfig ¶

func (a *LynxApp) GlobalConfig() config.Config

func (*LynxApp) Helper ¶

func (a *LynxApp) Helper() *log.Helper

func (*LynxApp) InitLogger ¶

func (a *LynxApp) InitLogger()

func (*LynxApp) Logger ¶

func (a *LynxApp) Logger() log.Logger

func (*LynxApp) PlugManager ¶

func (a *LynxApp) PlugManager() LynxPluginManager

func (*LynxApp) SetCert ¶

func (a *LynxApp) SetCert(cert Cert)

func (*LynxApp) SetControlPlane ¶

func (a *LynxApp) SetControlPlane(plane ControlPlane)

func (*LynxApp) TxManager ¶

func (a *LynxApp) TxManager() tx.TransactionManager

type LynxPluginManager ¶

type LynxPluginManager interface {
	LoadPlugins(config.Config)
	UnloadPlugins()
	LoadPluginsByName([]string, config.Config)
	UnloadPluginsByName([]string)
	GetPlugin(name string) plugin.Plugin
	PreparePlug(config config.Config) []string
}

func NewLynxPluginManager ¶

func NewLynxPluginManager(p ...plugin.Plugin) LynxPluginManager

type PluginWithLevel ¶

type PluginWithLevel struct {
	plugin.Plugin
	// contains filtered or unexported fields
}

type Registry ¶

type Registry interface {
	NewServiceRegistry() registry.Registrar
	NewServiceDiscovery() registry.Discovery
}

type Router ¶

type Router interface {
	NewNodeRouter(name string) selector.NodeFilter
}

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
subscribe
tx

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