proxy

Documentation

Index

• func New(serviceDefService metadata.ServiceDefinitionService, ...) http.Handler
• func NewForCompass(serviceDefService metadata.ServiceDefinitionService, ...) http.Handler
• type APIExtractor
• type Cache
  • func NewCache(proxyCacheTTL int) Cache
• type CacheEntry
• type Config
• type RetryableRoundTripper
  • func NewRetryableRoundTripper(roundTripper http.RoundTripper, authorizationStrategy authorization.Strategy, ...) *RetryableRoundTripper
  • func (p *RetryableRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

Functions

func New

func New(
	serviceDefService metadata.ServiceDefinitionService,
	authorizationStrategyFactory authorization.StrategyFactory,
	csrfTokenStrategyFactory csrf.TokenStrategyFactory,
	config Config) http.Handler

New creates proxy for handling user's services calls

func NewForCompass

func NewForCompass(
	serviceDefService metadata.ServiceDefinitionService,
	authorizationStrategyFactory authorization.StrategyFactory,
	csrfTokenStrategyFactory csrf.TokenStrategyFactory,
	config Config) http.Handler

Types

type APIExtractor

type APIExtractor interface {
	Get(identifier model.APIIdentifier) (*model.API, apperrors.AppError)
}

type Cache

type Cache interface {
	// Get returns entry from the cache
	Get(appName, serviceName, apiName string) (*CacheEntry, bool)
	// Put adds entry to the cache
	Put(appName, serviceName, apiName string, reverseProxy *httputil.ReverseProxy, authorizationStrategy authorization.Strategy, csrfTokenStrategy csrf.TokenStrategy, clientCertificate clientcert.ClientCertificate) *CacheEntry
}

Cache is an interface for caching Proxies

func NewCache

func NewCache(proxyCacheTTL int) Cache

NewCache creates new cache with specified TTL

type CacheEntry

type CacheEntry struct {
	Proxy                 *httputil.ReverseProxy
	AuthorizationStrategy *authorizationStrategyWrapper
	CSRFTokenStrategy     csrf.TokenStrategy
}

CacheEntry stores information about proxy configuration in cache

type Config

type Config struct {
	ProxyTimeout  int
	Application   string
	ProxyCacheTTL int
}

Config stores Proxy config

type RetryableRoundTripper

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

func NewRetryableRoundTripper

func NewRetryableRoundTripper(roundTripper http.RoundTripper, authorizationStrategy authorization.Strategy, csrfTokenStrategy csrf.TokenStrategy, clientCertificate clientcert.ClientCertificate, timeout int, skipTLSVerify bool) *RetryableRoundTripper

func (*RetryableRoundTripper) RoundTrip

func (p *RetryableRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)