April 28, 2017 | by Stefan Schimanski and Michael Hausenblas
Welcome to the Kubernetes deep dive blog post series. We, that is, Stefan Schimanski (Engineering) and Michael Hausenblas (Advocacy), will dive into specific aspects of Kubernetes and how they’re utilized within OpenShift. If you’re interested in the inner workings of Kubernetes and how to debug it, this blog post series is for you. Also, if you want to extend Kubernetes or start contributing to the project, you might benefit from it. Familiarity with Go is an advantage but not a hard requirement to follow along.
In this installment, we start with a general introduction of the Kubernetes API Server, provide some terminology and explain the API request flow. Future posts will cover storage-related topics and extensibility points of the API Server.
On a conceptual level, Kubernetes is made up of a bunch of nodes with different roles. The control plane on the master node(s) consists of the API Server, the Controller Manager and Scheduler(s). The API Server is the central management entity and the only component that directly talks with the distributed storage component etcd. It provides the following core functionality:
The Kubernetes API is a HTTP API with JSON as its primary serialization schema, however it also supports Protocol Buffers, mainly for cluster-internal communication. For extensibility reasons Kubernetes supports multiple API versions at different API paths, such as
/apis/extensions/v1beta1. Different API versions imply different levels of stability and support:
v1alpha1is disabled by default, support for a feature may be dropped at any time without notice and should only be used in short-lived testing clusters.
v2beta3, is enabled by default, means that the code is well tested but the semantics of objects may change in incompatible ways in a subsequent beta or stable release.
v1will appear in released software for many subsequent versions.
Let’s now have a look at how the HTTP API space is constructed. At the top level we distinguish between the core group (everything below
/api/v1, for historic reasons under this path and not under
/apis/core/v1), the named groups (at path
/apis/$NAME/$VERSION) and system-wide entities such as
A part of the HTTP API space (based on v1.5) is shown in the following:
Going forward we’ll be focusing on a concrete example: batch operations. In Kubernetes 1.5, two versions of batch operations exist:
/apis/batch/v2alpha1, exposing different sets of entities that can be queried and manipulated.
Now we turn our attention to an exemplary interaction with the API (we are using Minishift and the proxy command
oc proxy --port=8080 here to get direct access to the API):
$ curl http://127.0.0.1:8080/apis/batch/v1
And further, using the new, alpha version:
$ curl http://127.0.0.1:8080/apis/batch/v2alpha1
In general the Kubernetes API supports create, update, delete, and retrieve operations at the given path via the standard HTTP verbs
GET with JSON as the default payload.
Most API objects make a distinction between the specification of the desired state of the object and the status of the object at the current time. A specification is a complete description of the desired state and is persisted in stable storage.
After this brief overview of the API Server and the HTTP API space and its properties, we now define the terms used in this context more formally. Primitives like pods, services, endpoints, deployment, etc. make up the objects of the Kubernetes type universe. We use the following terms:
Kind is the type of an entity. Each object has a field
Kind which tells a client—such as
kubectl or oc—that it represents, for example, a pod:
- name: nginx
- containerPort: 80
There are three categories of
/status, discovery uses
APIResource, error results use
API Group is a collection of
Kinds that are logically related. For example, all batch objects like
ScheduledJob are in the
batch API Group.
Version. Each API Group can exist in multiple versions. For example, a group first appears as
v1alpha1 and is then promoted to
v1beta1 and finally graduates to
v1. An object created in one version (e.g.
v1beta1) can be retrieved in each of the supported versions (for example as
v1). The API server does lossless conversion to return objects in the requested version.
Resource is the representation of a system entity sent or retrieved as JSON via HTTP; can be exposed as an individual resource (such as
.../namespaces/default) or collections of resources (like
An API Group, a Version and a Resource (GVR) uniquely defines a HTTP path:
More precisely, the actual path for jobs is
/apis/batch/v1/namespaces/$NAMESPACE/jobs because jobs are not a cluster-wide resource, in contrast to, for example, node resources. For brevity, we omit the
$NAMESPACE segment of the paths throughout the post.
Kinds may not only exist in different versions, but also in different API Groups simultaneously. For example,
Deployment started as an alpha
Kind in the extensions group and was eventually promoted to a GA version in its own group
apps.k8s.io. Hence, to identify
Kinds uniquely you need the API Group, the version and the kind name (GVK).
Now that we’ve reviewed the terminology used in the Kubernetes API we move on to how API requests are processed. The API lives in k8s.io/pkg/api and handles requests from within the cluster as well as to clients outside of the cluster.
So, what actually happens now when an HTTP request hits the Kubernetes API? On a high level, the following interactions take place:
DefaultBuildHandlerChain()(see config.go) that applies an operation on it (see below for more details on the filters). Either the filter passes and attaches respective infos to
ctx.RequestInfo, such as authenticated user or returns an appropriate HTTP response code.
routes/*) connect handlers with HTTP paths.
The complete flow looks as follows:
Again, note that for brevity, we omit the
$NAMESPACE segment of the HTTP paths in above figure.
Let’s now have a closer look at the filters that
DefaultBuildHandlerChain() in config.go sets up:
WithRequestInfo()as defined in requestinfo.go attaches a
RequestInfoto the context
WithMaxInFlightLimit()as defined in maxinflight.go limits the number of in-flight requests
WithTimeoutForNonLongRunningRequests()as defined in timeout.go times out non-long-running requests like most
DELETErequests in contrast to long-running requests like watches and proxy requests
WithPanicRecovery()as defined in wrap.go wraps an handler to recover and log panics
WithAuthentication()as defined in authentication.go tries to authenticate the given request as a user and stores the user info in the provided context. On success, the
AuthorizationHTTP header is removed from the request.
WithAudit()as defined in audit.go decorates the handler with audit logging information for all incoming requests The audit log entries contain infos such as source IP of the request, user invoking the operation, and namespace of the request.
WithImpersonation()as defined in impersonation.go handles user impersonation, by checking requests that attempt to change the user (similar to sudo).
WithAuthorization()as defined in authorization.go passes all authorized requests on to multiplexer which dispatched the request to the right handler, and returns a forbidden error otherwise.
And with this, we conclude this first installment of the API Server deep dive. Next time we’ll have a look closer look at how serialization of resources is happening as well as how objects are persisted in the distributed storage.