tomlng

Documentation

Overview

package TomlNgng provides in toml engine implementation

Index

• func New(r *plugin.Registry, options Options) (engine.Engine, error)
• type Backend
• type EngineTomlConfig
• type Frontend
• type FrontendMiddleware
• type MiddlewareFrontend
• type Options
• type TomlNg
  • func (m *TomlNg) AddApiHandlers(app *scroll.App)
  • func (m *TomlNg) AddConfigPath(in string) error
  • func (m *TomlNg) Close()
  • func (m *TomlNg) DeleteBackend(bk engine.BackendKey) error
  • func (m *TomlNg) DeleteFrontend(fk engine.FrontendKey) error
  • func (m *TomlNg) DeleteHost(k engine.HostKey) error
  • func (m *TomlNg) DeleteListener(lk engine.ListenerKey) error
  • func (m *TomlNg) DeleteMiddleware(mk engine.MiddlewareKey) error
  • func (m *TomlNg) DeleteServer(sk engine.ServerKey) error
  • func (m *TomlNg) GetBackend(bk engine.BackendKey) (*engine.Backend, error)
  • func (m *TomlNg) GetBackends() ([]engine.Backend, error)
  • func (m *TomlNg) GetFrontend(k engine.FrontendKey) (*engine.Frontend, error)
  • func (m *TomlNg) GetFrontends() ([]engine.Frontend, error)
  • func (m *TomlNg) GetHost(k engine.HostKey) (*engine.Host, error)
  • func (m *TomlNg) GetHosts() ([]engine.Host, error)
  • func (m *TomlNg) GetListener(lk engine.ListenerKey) (*engine.Listener, error)
  • func (m *TomlNg) GetListeners() ([]engine.Listener, error)
  • func (n *TomlNg) GetLogSeverity() string
  • func (m *TomlNg) GetMiddleware(mk engine.MiddlewareKey) (*engine.Middleware, error)
  • func (m *TomlNg) GetMiddlewares(fk engine.FrontendKey) ([]engine.Middleware, error)
  • func (m *TomlNg) GetRegistry() *plugin.Registry
  • func (m *TomlNg) GetServer(sk engine.ServerKey) (*engine.Server, error)
  • func (m *TomlNg) GetServers(bk engine.BackendKey) ([]engine.Server, error)
  • func (m *TomlNg) ReadConfig(r io.Reader) (err error)
  • func (n *TomlNg) SetLogSeverity(sev string) error
  • func (m *TomlNg) Subscribe(changes chan interface{}, cancelC chan bool) error
  • func (m *TomlNg) UpsertBackend(b engine.Backend) error
  • func (m *TomlNg) UpsertFrontend(f engine.Frontend, d time.Duration) error
  • func (m *TomlNg) UpsertHost(h engine.Host) error
  • func (m *TomlNg) UpsertListener(l engine.Listener) error
  • func (m *TomlNg) UpsertMiddleware(fk engine.FrontendKey, md engine.Middleware, d time.Duration) error
  • func (m *TomlNg) UpsertServer(bk engine.BackendKey, srv engine.Server, d time.Duration) error

Functions

func New

func New(r *plugin.Registry, options Options) (engine.Engine, error)

Types

type Backend

type Backend struct {
	engine.Backend
	Settings engine.HTTPBackendSettings
}

type EngineTomlConfig

type EngineTomlConfig struct {
	Listeners   map[string]engine.Listener
	Frontends   map[string]Frontend
	Backends    map[string]Backend
	Servers     map[string][]engine.Server
	Middlewares map[string]MiddlewareFrontend
}

type Frontend

type Frontend struct {
	engine.Frontend
	Settings    engine.HTTPFrontendSettings
	Middlewares []FrontendMiddleware
}

type FrontendMiddleware

type FrontendMiddleware struct {
	MiddlewareId string
	Priority     int
}

type MiddlewareFrontend

type MiddlewareFrontend struct {
	Type       string
	Middleware toml.Primitive
}

type Options

type Options struct {
	MainConfigFilepath string
	ConfigPaths        []string
	WatchConfigChanges bool
}

type TomlNg

type TomlNg struct {
	Hosts     map[engine.HostKey]engine.Host
	Frontends map[engine.FrontendKey]engine.Frontend
	Backends  map[engine.BackendKey]engine.Backend
	Listeners map[engine.ListenerKey]engine.Listener

	Middlewares      map[engine.FrontendKey][]engine.Middleware
	KnownMiddlewares map[string]engine.Middleware
	Servers          map[engine.BackendKey][]engine.Server

	Registry *plugin.Registry
	ChangesC chan interface{}
	ErrorsC  chan error
	// contains filtered or unexported fields
}

func (*TomlNg) AddApiHandlers

func (m *TomlNg) AddApiHandlers(app *scroll.App)

func (*TomlNg) AddConfigPath

func (m *TomlNg) AddConfigPath(in string) error

func (*TomlNg) Close

func (m *TomlNg) Close()

func (*TomlNg) DeleteBackend

func (m *TomlNg) DeleteBackend(bk engine.BackendKey) error

func (*TomlNg) DeleteFrontend

func (m *TomlNg) DeleteFrontend(fk engine.FrontendKey) error

func (*TomlNg) DeleteHost

func (m *TomlNg) DeleteHost(k engine.HostKey) error

func (*TomlNg) DeleteListener

func (m *TomlNg) DeleteListener(lk engine.ListenerKey) error

func (*TomlNg) DeleteMiddleware

func (m *TomlNg) DeleteMiddleware(mk engine.MiddlewareKey) error

func (*TomlNg) DeleteServer

func (m *TomlNg) DeleteServer(sk engine.ServerKey) error

func (*TomlNg) GetBackend

func (m *TomlNg) GetBackend(bk engine.BackendKey) (*engine.Backend, error)

func (*TomlNg) GetBackends

func (m *TomlNg) GetBackends() ([]engine.Backend, error)

func (*TomlNg) GetFrontend

func (m *TomlNg) GetFrontend(k engine.FrontendKey) (*engine.Frontend, error)

func (*TomlNg) GetFrontends

func (m *TomlNg) GetFrontends() ([]engine.Frontend, error)

func (*TomlNg) GetHost

func (m *TomlNg) GetHost(k engine.HostKey) (*engine.Host, error)

func (*TomlNg) GetHosts

func (m *TomlNg) GetHosts() ([]engine.Host, error)

func (*TomlNg) GetListener

func (m *TomlNg) GetListener(lk engine.ListenerKey) (*engine.Listener, error)

func (*TomlNg) GetListeners

func (m *TomlNg) GetListeners() ([]engine.Listener, error)

func (*TomlNg) GetLogSeverity

func (n *TomlNg) GetLogSeverity() string

func (*TomlNg) GetMiddleware

func (m *TomlNg) GetMiddleware(mk engine.MiddlewareKey) (*engine.Middleware, error)

func (*TomlNg) GetMiddlewares

func (m *TomlNg) GetMiddlewares(fk engine.FrontendKey) ([]engine.Middleware, error)

func (*TomlNg) GetRegistry

func (m *TomlNg) GetRegistry() *plugin.Registry

func (*TomlNg) GetServer

func (m *TomlNg) GetServer(sk engine.ServerKey) (*engine.Server, error)

func (*TomlNg) GetServers

func (m *TomlNg) GetServers(bk engine.BackendKey) ([]engine.Server, error)

func (*TomlNg) ReadConfig

func (m *TomlNg) ReadConfig(r io.Reader) (err error)

func (*TomlNg) SetLogSeverity

func (n *TomlNg) SetLogSeverity(sev string) error

func (*TomlNg) Subscribe

func (m *TomlNg) Subscribe(changes chan interface{}, cancelC chan bool) error

func (*TomlNg) UpsertBackend

func (m *TomlNg) UpsertBackend(b engine.Backend) error

func (*TomlNg) UpsertFrontend

func (m *TomlNg) UpsertFrontend(f engine.Frontend, d time.Duration) error

func (*TomlNg) UpsertHost

func (m *TomlNg) UpsertHost(h engine.Host) error

func (*TomlNg) UpsertListener

func (m *TomlNg) UpsertListener(l engine.Listener) error

func (*TomlNg) UpsertMiddleware

func (m *TomlNg) UpsertMiddleware(fk engine.FrontendKey, md engine.Middleware, d time.Duration) error

func (*TomlNg) UpsertServer

func (m *TomlNg) UpsertServer(bk engine.BackendKey, srv engine.Server, d time.Duration) error