- Reactive is key
- Reactive is key (yes, it is very very important)
- Failing fast is better than succeeding slow (say it one more time!)
- The simpler, the better
- Everything is plugglable
- Each request must be processed in its own request-scoped context
The KrakenD framework is composed of a set of packages designed as building blocks for creating pipes and processors between an exposed endpoint and one or several API resources served by your backends.
The most important packages are:
- the
config
package defines the service. - the
router
package sets up the endpoints exposed to the clients. - the
proxy
package adds the required middlewares and components for further processing of the requests to send and the received responses sent by the backends, and also to manage the connections against those backends.
The rest of the packages of the framework contain some helpers and adapters for complementary tasks, like encoding, logging or service discovery.
The config
package contains the structs required for the service description.
The ServiceConfig
struct defines the entire service. It should be initialized before using it in order to be sure that all parameters have been normalized and default values have been applied.
The config
package also defines an interface for a file config parser and a parser based on the viper library.
The router
package contains an interface and several implementations for the KrakenD router layer using the mux
router from the net/http
and the httprouter
wrapped in the gin
framework.
The router layer is responsible for setting up the HTTP(S) services, binding the endpoints defined at the ServiceConfig
struct and transforming the http request into proxy requests before delegating the task to the inner layer (proxy). Once the internal proxy layer returns a proxy response, the router layer converts it into a proper HTTP response and sends it to the user.
This layer can be easily extended in order to use any HTTP router, framework or middleware of your choice. Adding transport layer adapters for other protocols (Thrift, gRPC, AMQP, NATS, etc) is in the roadmap. As always, PRs are welcome!
The proxy
package is where the most part of the KrakenD components and features are placed. It defines two important interfaces, designed to be stacked:
- Proxy is a function that converts a given context and request into a response.
- Middleware is a function that accepts one or more proxies and returns a single proxy wrapping them.
This layer transforms the request received from the outter layer (router) into a single or several requests to your backend services, processes the responses and returns a single response.
Middlewares generates custom proxies that are chained depending on the workflow defined in the configuration until each possible branch ends in a transport-related proxy. Every one of these generated proxies is able to transform the input or even clone it several times and pass it or them to the next element in the chain. Finally, they can also modify the received response or responses adding all kinds of features to the generated pipe.
The KrakenD framework provides a default implementation of the proxy stack factory.
- The
balancing
middleware uses some type of strategy for selecting a backend host to query. - The
concurrent
middleware improves the QoS by sending several concurrent requests to the next step of the chain and returning the first succesful response using a timeout for canceling the generated workload. - The
logging
middleware logs the received request and response and also the duration of the segment execution. - The
merging
middleware is a fork-and-join middleware. It is intended to split the process of the request into several concurrent processes, each one against a different backend, and to merge all the received responses from those created pipes into a single one. It applies a timeout, as theconcurrent
one does. - The
http
middleware completes the received proxy request by replacing the parameters extracted from the user request in the definedURLPattern
.
- The
http
proxy translates a proxy request into an HTTP one, sends it to the backend API using aHTTPClientFactory
, decodes the returned HTTP response with aDecoder
, manipulates the response data with anEntityFormatter
and returns it to the caller.
The proxy
package also defines the EntityFormatter
, the block responsible for enabling a powerful and fast response manipulation.