proxy

Documentation

Overview

Package proxy is inspired by https://gist.github.com/cespare/3985516

Index

• func IsNoAuthError(err error) bool
• func NewHTTPPipe(rw http.ResponseWriter, backend backendProxy, hostKey string) (*BackendHTTPReader, *BackendHTTPWriter, error)
• func ParsePublicKey(keyFile string) (interface{}, error)
• func ParsePublicKeyFromMemory(keyFileContents string) (interface{}, error)
• type BackendHTTPReader
  • func NewBackendHTTPReader(rw http.ResponseWriter, hostKey, msgKey string, backend backendProxy, ...) *BackendHTTPReader
  • func (b *BackendHTTPReader) Close() error
  • func (b *BackendHTTPReader) Read(out []byte) (int, error)
• type BackendHTTPWriter
  • func (b *BackendHTTPWriter) Close() error
  • func (b *BackendHTTPWriter) Write(buffer []byte) (int, error)
  • func (b *BackendHTTPWriter) WriteRequest(req *http.Request, hijack bool, address, scheme string) error
• type BackendHandler
  • func (h *BackendHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)
• type Certs
• type Config
  • func GetConfig() (*Config, error)
  • func (config *Config) GetCerts() (*Certs, error)
• type FrontendHTTPHandler
  • func (h *FrontendHTTPHandler) AuthAndLookup(req *http.Request) (*jwt.Token, string, error)
  • func (h *FrontendHTTPHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)
  • func (h *FrontendHTTPHandler) ServeRemoteHTTP(token *jwt.Token, hostKey string, rw http.ResponseWriter, req *http.Request) error
• type FrontendHandler
  • func (h *FrontendHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)
• type ServiceProxyRequest
• type ServiceProxyResponse
• type Starter
  • func (s *Starter) StartProxy() error
• type StatsHandler
  • func (h *StatsHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)
• type Switcher
  • func NewSwitcher(config *Config) *Switcher
  • func (s *Switcher) Wrap(local http.Handler) http.Handler
• type TokenLookup
  • func NewTokenLookup(cattleAddr string) *TokenLookup
  • func (t *TokenLookup) Lookup(r *http.Request) (string, error)

Functions

func IsNoAuthError

func IsNoAuthError(err error) bool

func NewHTTPPipe

func NewHTTPPipe(rw http.ResponseWriter, backend backendProxy, hostKey string) (*BackendHTTPReader, *BackendHTTPWriter, error)

func ParsePublicKey

func ParsePublicKey(keyFile string) (interface{}, error)

func ParsePublicKeyFromMemory

func ParsePublicKeyFromMemory(keyFileContents string) (interface{}, error)

Types

type BackendHTTPReader

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

func NewBackendHTTPReader

func NewBackendHTTPReader(rw http.ResponseWriter, hostKey, msgKey string, backend backendProxy, messages <-chan common.Message) *BackendHTTPReader

func (*BackendHTTPReader) Close

func (b *BackendHTTPReader) Close() error

func (*BackendHTTPReader) Read

func (b *BackendHTTPReader) Read(out []byte) (int, error)

type BackendHTTPWriter

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

func (*BackendHTTPWriter) Close

func (b *BackendHTTPWriter) Close() error

func (*BackendHTTPWriter) Write

func (b *BackendHTTPWriter) Write(buffer []byte) (int, error)

func (*BackendHTTPWriter) WriteRequest

func (b *BackendHTTPWriter) WriteRequest(req *http.Request, hijack bool, address, scheme string) error

type BackendHandler

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

func (*BackendHandler) ServeHTTP

func (h *BackendHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)

type Certs

type Certs struct {
	CA   []byte
	Cert []byte
	Key  []byte
}

type Config

type Config struct {
	PublicKey                interface{}
	ListenAddr               string
	CattleAddr               string
	ParentPid                int
	ProxyProtoHTTPSPorts     map[int]bool
	CattleAccessKey          string
	CattleSecretKey          string
	TLSListenAddr            string
	MasterFile               string
	APIInterceptorConfigFile string
}

func GetConfig

func GetConfig() (*Config, error)

func (*Config) GetCerts

func (config *Config) GetCerts() (*Certs, error)

type FrontendHTTPHandler

type FrontendHTTPHandler struct {
	FrontendHandler
	HTTPSPorts  map[int]bool
	TokenLookup *TokenLookup
}

func (*FrontendHTTPHandler) AuthAndLookup

func (h *FrontendHTTPHandler) AuthAndLookup(req *http.Request) (*jwt.Token, string, error)

func (*FrontendHTTPHandler) ServeHTTP

func (h *FrontendHTTPHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)

func (*FrontendHTTPHandler) ServeRemoteHTTP

func (h *FrontendHTTPHandler) ServeRemoteHTTP(token *jwt.Token, hostKey string, rw http.ResponseWriter, req *http.Request) error

type FrontendHandler

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

func (*FrontendHandler) ServeHTTP

func (h *FrontendHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)

type ServiceProxyRequest

type ServiceProxyRequest struct {
	Service string `json:"service"`
	Port    int    `json:"port"`
	Scheme  string `json:"scheme"`
}

type ServiceProxyResponse

type ServiceProxyResponse struct {
	Token string `json:"token"`
}

type Starter

type Starter struct {
	BackendPaths       []string
	FrontendPaths      []string
	FrontendHTTPPaths  []string
	StatsPaths         []string
	CattleProxyPaths   []string
	CattleWSProxyPaths []string
	Config             *Config
}

func (*Starter) StartProxy

func (s *Starter) StartProxy() error

type StatsHandler

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

func (*StatsHandler) ServeHTTP

func (h *StatsHandler) ServeHTTP(rw http.ResponseWriter, req *http.Request)

type Switcher

type Switcher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSwitcher

func NewSwitcher(config *Config) *Switcher

func (*Switcher) Wrap

func (s *Switcher) Wrap(local http.Handler) http.Handler

type TokenLookup

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

func NewTokenLookup

func NewTokenLookup(cattleAddr string) *TokenLookup

func (*TokenLookup) Lookup

func (t *TokenLookup) Lookup(r *http.Request) (string, error)