proxy

Documentation

Index

• func GetLoopback() selector.Node
• func SetDefault(proxy Proxy)
• func SetLoopback(let selector.Node)
• type Option
  • func WithActivateMock(fn func(client *http.Client)) Option
  • func WithDialer(d *net.Dialer) Option
  • func WithInitialNodes(nodes []selector.Node) Option
  • func WithSelector(s selector.Selector) Option
• type Proxy
  • func GetProxy() Proxy
• type ReverseProxy
  • func New(opts ...Option) *ReverseProxy
  • func (r *ReverseProxy) Apply(nodes []selector.Node)
  • func (r *ReverseProxy) Do(req *http.Request, collapsed bool, waitTimeout time.Duration) (*http.Response, error)
  • func (r *ReverseProxy) DoLoopback(req *http.Request) (*http.Response, error)
• type Tuple

Functions

func GetLoopback

func GetLoopback() selector.Node

func SetDefault

func SetDefault(proxy Proxy)

func SetLoopback

func SetLoopback(let selector.Node)

Types

type Option

type Option func(*ReverseProxy)

func WithActivateMock

func WithActivateMock(fn func(client *http.Client)) Option

WithActivateMock is activate httpmock

func WithDialer

func WithDialer(d *net.Dialer) Option

WithDialer is set custom net.Dialer

func WithInitialNodes

func WithInitialNodes(nodes []selector.Node) Option

WithInitialNodes is set initial nodes

func WithSelector

func WithSelector(s selector.Selector) Option

WithSelector is set new-selector

type Proxy

type Proxy interface {
	Do(req *http.Request, collapsed bool, waitTimeout time.Duration) (*http.Response, error)
	DoLoopback(req *http.Request) (*http.Response, error)
	Apply(nodes []selector.Node)
}

func GetProxy

func GetProxy() Proxy

type ReverseProxy

type ReverseProxy struct {
	// Rebalancer is nodes rebalancer.
	selector.Rebalancer
	*direct.Builder
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) *ReverseProxy

func (*ReverseProxy) Apply

func (r *ReverseProxy) Apply(nodes []selector.Node)

Apply is apply all nodes when any changes happen

func (*ReverseProxy) Do

func (r *ReverseProxy) Do(req *http.Request, collapsed bool, waitTimeout time.Duration) (*http.Response, error)

func (*ReverseProxy) DoLoopback

func (r *ReverseProxy) DoLoopback(req *http.Request) (*http.Response, error)

type Tuple

type Tuple struct {
	L *http.Response
	R []byte
}