plugin

type CliReader ¶

type CliReader func(c *cli.Context) (Middleware, error)

Reader constructs the middleware from the CLI interface

type FrontendListeners ¶

type FrontendListeners struct {
	ConnTck           forward.UrlForwardingStateListener
	RbRewriteListener roundrobin.RequestRewriteListener
	RrRewriteListener roundrobin.RequestRewriteListener
}

Holds a bunch of Listeners a frontend might have. This allows callers to consolidate all their listeners in one convenient struct.

type Middleware ¶

type Middleware interface {
	NewHandler(http.Handler) (http.Handler, error)
}

type MiddlewareSpec ¶

type MiddlewareSpec struct {
	Type string
	// Reader function that returns a middleware from another middleware structure
	FromOther interface{}
	// Flags for CLI tool to generate interface
	CliFlags []cli.Flag
	// Function that construtcs a middleware from CLI parameters
	FromCli CliReader
}

Middleware specification, used to construct new middlewares and plug them into CLI API and backends

func (ms *MiddlewareSpec) FromJSON(data []byte) (Middleware, error)

type Registry ¶

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

Registry contains currently registered middlewares and used to support pluggable middlewares across all modules of the vulcand

func NewRegistry() *Registry

func (r *Registry) AddNotFoundMiddleware(notFound Middleware) error

func (r *Registry) AddSpec(s *MiddlewareSpec) error

func (r *Registry) GetCacheProvider() cacheprovider.T

func (r *Registry) GetFrontendListeners() FrontendListeners

func (r *Registry) GetIncomingConnectionTracker() conntracker.ConnectionTracker

func (r *Registry) GetNotFoundMiddleware() Middleware

func (r *Registry) GetRouter() router.Router

func (r *Registry) GetSpec(middlewareType string) *MiddlewareSpec

func (r *Registry) GetSpecs() []*MiddlewareSpec

func (r *Registry) SetCacheProvider(cacheprovider cacheprovider.T) error

func (r *Registry) SetFrontendListeners(frontendListeners FrontendListeners) error

func (r *Registry) SetIncomingConnectionTracker(connTracker conntracker.ConnectionTracker) error

func (r *Registry) SetRouter(router router.Router) error

type SpecGetter ¶

type SpecGetter func(string) *MiddlewareSpec

Function that returns middleware spec by it's type