remote

Documentation

Index

• type LoadBalancer
  • func NewLoadBalancer(lbMode string, remoteServers []*url.URL, cacheMgr cachemanager.CacheManager, ...) (LoadBalancer, error)
• type RemoteProxy
  • func NewRemoteProxy(remoteServer *url.URL, cacheMgr cachemanager.CacheManager, ...) (*RemoteProxy, error)
  • func (rp *RemoteProxy) IsHealthy() bool
  • func (rp *RemoteProxy) Name() string
  • func (rp *RemoteProxy) RoundTrip(req *http.Request) (*http.Response, error)
  • func (rp *RemoteProxy) ServeHTTP(rw http.ResponseWriter, req *http.Request)

Types

type LoadBalancer

type LoadBalancer interface {
	IsHealthy() bool
	ServeHTTP(rw http.ResponseWriter, req *http.Request)
}

LoadBalancer is an interface for proxying http request to remote server based on the load balance mode(round-robin or priority)

func NewLoadBalancer

func NewLoadBalancer(
	lbMode string,
	remoteServers []*url.URL,
	cacheMgr cachemanager.CacheManager,
	transportMgr transport.Interface,
	healthChecker healthchecker.HealthChecker,
	certManager interfaces.YurtCertificateManager,
	filterManager *filter.Manager,
	stopCh <-chan struct{}) (LoadBalancer, error)

NewLoadBalancer creates a loadbalancer for specified remote servers

type RemoteProxy

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

RemoteProxy is an reverse proxy for remote server

func NewRemoteProxy

func NewRemoteProxy(remoteServer *url.URL,
	cacheMgr cachemanager.CacheManager,
	transportMgr transport.Interface,
	healthChecker healthchecker.HealthChecker,
	filterManager *filter.Manager,
	stopCh <-chan struct{}) (*RemoteProxy, error)

NewRemoteProxy creates an *RemoteProxy object, and will be used by LoadBalancer

func (*RemoteProxy) IsHealthy

func (rp *RemoteProxy) IsHealthy() bool

IsHealthy returns healthy status of remote server

func (*RemoteProxy) Name

func (rp *RemoteProxy) Name() string

Name represents the address of remote server

func (*RemoteProxy) RoundTrip

func (rp *RemoteProxy) RoundTrip(req *http.Request) (*http.Response, error)

RoundTrip is used to implement http.RoundTripper for RemoteProxy.

func (*RemoteProxy) ServeHTTP

func (rp *RemoteProxy) ServeHTTP(rw http.ResponseWriter, req *http.Request)