mux

Documentation

Index

• func NewServer(listen string, advertiseHostPort string, plugins func() discovery.Plugins, ...) (rpc_server.Stoppable, error)
• func SavePID(listen string) (string, error)
• type Options
• type ReverseProxy
  • func NewReverseProxy(plugins func() discovery.Plugins) *ReverseProxy
  • func (rp *ReverseProxy) ForwardTo(u *url.URL)
  • func (rp *ReverseProxy) ServeHTTP(resp http.ResponseWriter, req *http.Request)

Functions

func NewServer

func NewServer(listen string, advertiseHostPort string,
	plugins func() discovery.Plugins, options Options) (rpc_server.Stoppable, error)

NewServer returns a tcp server listening at the listen address (e.g. ':8080'), or error

func SavePID

func SavePID(listen string) (string, error)

SavePID makes sure the directory exists and writes the pid to a file

Types

type Options

type Options struct {
	Leadership <-chan leader.Leadership
	Registry   leader.Store
}

Options capture additional configurations and objects that the mux will use

type ReverseProxy

type ReverseProxy struct {
	http.Handler
	// contains filtered or unexported fields
}

ReverseProxy is the mux reverse proxy that is able to multiplex calls to this to different backends, including socket-based plugins.

func NewReverseProxy

func NewReverseProxy(plugins func() discovery.Plugins) *ReverseProxy

NewReverseProxy creates a mux reverse proxy

func (*ReverseProxy) ForwardTo

func (rp *ReverseProxy) ForwardTo(u *url.URL)

ForwardTo sends the traffic to this url (host:port) instead of local plugins

func (*ReverseProxy) ServeHTTP

func (rp *ReverseProxy) ServeHTTP(resp http.ResponseWriter, req *http.Request)

ServeHTTP implements HTTP handler