forked from krakend/krakend-ce
-
Notifications
You must be signed in to change notification settings - Fork 0
/
backend_factory.go
39 lines (37 loc) · 1.54 KB
/
backend_factory.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
package main
import (
cb "github.com/devopsfaith/krakend-circuitbreaker/gobreaker/proxy"
httpcache "github.com/devopsfaith/krakend-httpcache"
"github.com/devopsfaith/krakend-martian"
metrics "github.com/devopsfaith/krakend-metrics/gin"
"github.com/devopsfaith/krakend-oauth2-clientcredentials"
opencensus "github.com/devopsfaith/krakend-opencensus"
juju "github.com/devopsfaith/krakend-ratelimit/juju/proxy"
"github.com/devopsfaith/krakend/config"
"github.com/devopsfaith/krakend/logging"
"github.com/devopsfaith/krakend/proxy"
)
// NewBackendFactory creates a BackendFactory by stacking all the available middlewares:
// - oauth2 client credentials
// - martian
// - rate-limit
// - circuit breaker
// - metrics collector
// - opencensus collector
func NewBackendFactory(logger logging.Logger, metricCollector *metrics.Metrics) proxy.BackendFactory {
requestExecutorFactory := func(cfg *config.Backend) proxy.HTTPRequestExecutor {
var clientFactory proxy.HTTPClientFactory
if _, ok := cfg.ExtraConfig[oauth2client.Namespace]; ok {
clientFactory = oauth2client.NewHTTPClient(cfg)
} else {
clientFactory = httpcache.NewHTTPClient(cfg)
}
return opencensus.HTTPRequestExecutor(clientFactory)
}
backendFactory := martian.NewConfiguredBackendFactory(logger, requestExecutorFactory)
backendFactory = juju.BackendFactory(backendFactory)
backendFactory = cb.BackendFactory(backendFactory)
backendFactory = metricCollector.BackendFactory("backend", backendFactory)
backendFactory = opencensus.BackendFactory(backendFactory)
return backendFactory
}