frontend

Documentation

Index

• type ReverseProxy
  • func NewReverseProxy() (r *ReverseProxy, err error)
  • func (r *ReverseProxy) AddBackend(uid, addr string)
  • func (r *ReverseProxy) AddFunc() func(obj interface{})
  • func (r *ReverseProxy) DecrementBackend(uid string)
  • func (r *ReverseProxy) DeleteBackend(uid string) (deleted bool)
  • func (r *ReverseProxy) DeleteFunc() func(obj interface{})
  • func (r *ReverseProxy) GetBackend() (backend *backend.Backend)
  • func (r *ReverseProxy) IncrementBackend(uid string)
  • func (r *ReverseProxy) Listen(address string) (err error)
  • func (r *ReverseProxy) UpdateFunc() func(oldObj, newObj interface{})
  • func (r *ReverseProxy) Watch() (err error)

Types

type ReverseProxy

type ReverseProxy struct {
	ConnectTimeout int
	Config         *tls.Config
	// contains filtered or unexported fields
}

ReverseProxy represents a reverse proxy server.

func NewReverseProxy

func NewReverseProxy() (r *ReverseProxy, err error)

NewReverseProxy initializes a ReverseProxy.

func (*ReverseProxy) AddBackend

func (r *ReverseProxy) AddBackend(uid, addr string)

AddBackend adds a backend.

func (*ReverseProxy) AddFunc

func (r *ReverseProxy) AddFunc() func(obj interface{})

AddFunc is a ResourceEventHandlerFunc.

func (*ReverseProxy) DecrementBackend

func (r *ReverseProxy) DecrementBackend(uid string)

DecrementBackend deccrements the connections count of a backend. nolint: dupl

func (*ReverseProxy) DeleteBackend

func (r *ReverseProxy) DeleteBackend(uid string) (deleted bool)

DeleteBackend deletes a backend.

func (*ReverseProxy) DeleteFunc

func (r *ReverseProxy) DeleteFunc() func(obj interface{})

DeleteFunc is a ResourceEventHandlerFunc.

func (*ReverseProxy) GetBackend

func (r *ReverseProxy) GetBackend() (backend *backend.Backend)

GetBackend gets a backend based on least connections algorithm.

func (*ReverseProxy) IncrementBackend

func (r *ReverseProxy) IncrementBackend(uid string)

IncrementBackend increments the connections count of a backend. nolint: dupl

func (*ReverseProxy) Listen

func (r *ReverseProxy) Listen(address string) (err error)

Listen starts the server on the specified address.

func (*ReverseProxy) UpdateFunc

func (r *ReverseProxy) UpdateFunc() func(oldObj, newObj interface{})

UpdateFunc is a ResourceEventHandlerFunc.

func (*ReverseProxy) Watch

func (r *ReverseProxy) Watch() (err error)

Watch uses the Kubernetes informer API to watch events for the API server.