server

Documentation

Index

• type RouteAppenderFactory
• type Server
  • func NewServer(staticConfiguration static.Configuration, provider provider.Provider, ...) *Server
  • func (s *Server) AddListener(listener func(config.Configuration))
  • func (s *Server) Close()
  • func (s *Server) Start(ctx context.Context)
  • func (s *Server) Stop()
  • func (s *Server) Wait()
• type TCPEntryPoint
  • func NewTCPEntryPoint(ctx context.Context, configuration *static.EntryPoint) (*TCPEntryPoint, error)
  • func (e *TCPEntryPoint) Shutdown(ctx context.Context)
• type TCPEntryPoints

Types

type RouteAppenderFactory

type RouteAppenderFactory interface {
	NewAppender(ctx context.Context, middlewaresBuilder *middleware.Builder, runtimeConfiguration *config.RuntimeConfiguration) types.RouteAppender
}

RouteAppenderFactory the route appender factory interface

type Server

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

Server is the reverse-proxy/load-balancer engine

func NewServer

func NewServer(staticConfiguration static.Configuration, provider provider.Provider, entryPoints TCPEntryPoints, tlsManager *tls.Manager) *Server

NewServer returns an initialized Server.

func (*Server) AddListener

func (s *Server) AddListener(listener func(config.Configuration))

AddListener adds a new listener function used when new configuration is provided

func (*Server) Close

func (s *Server) Close()

Close destroys the server

func (*Server) Start

func (s *Server) Start(ctx context.Context)

Start starts the server and Stop/Close it when context is Done

func (*Server) Stop

func (s *Server) Stop()

Stop stops the server

func (*Server) Wait

func (s *Server) Wait()

Wait blocks until server is shutted down.

type TCPEntryPoint

type TCPEntryPoint struct {
	RouteAppenderFactory RouteAppenderFactory
	// contains filtered or unexported fields
}

TCPEntryPoint is the TCP server

func NewTCPEntryPoint

func NewTCPEntryPoint(ctx context.Context, configuration *static.EntryPoint) (*TCPEntryPoint, error)

NewTCPEntryPoint creates a new TCPEntryPoint

func (*TCPEntryPoint) Shutdown

func (e *TCPEntryPoint) Shutdown(ctx context.Context)

Shutdown stops the TCP connections

type TCPEntryPoints

type TCPEntryPoints map[string]*TCPEntryPoint

TCPEntryPoints holds a map of TCPEntryPoint (the entrypoint names being the keys)