97c1300f53
* Add Get() and GetOptions. * Removed watcher. Outline of client. YAML templates * Added default service and deployment templates and types * Added API tests and cleaned up errors. * Small refactoring. Template package is no more. * Ripped out existing code in preparation to small rework * Reshuffled the source code to make it organized better * Create service and deployment in kubernetes runtime * Major cleanup and refactoring of Kubernetes runtime * Service now handles low level K8s API calls across both K8s deployment an service API objects * Runtime has a task queue that serves for queueing runtime action requests * General refactoring * No need for Lock in k8s service * Added kubernetes runtime env var to default deployment * Enable running different versions of the same service * Can't delete services through labels * Proto cruft. Added runtime.CreateOptions implementation in proto * Removed proxy service from default env variables * Make service name mandatory param to Get method * Get Delete changes from https://github.com/micro/go-micro/pull/945 * Replaced template files with global variables * Validate service names before sending K8s API request * Refactored Kubernetes API client. Fixed typos. * Added client.Resource to make API resources more explicit in code
222 lines
4.3 KiB
Go
222 lines
4.3 KiB
Go
package api
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"errors"
|
|
"fmt"
|
|
"io"
|
|
"net/http"
|
|
"net/url"
|
|
|
|
"github.com/micro/go-micro/util/log"
|
|
)
|
|
|
|
// Request is used to construct a http request for the k8s API.
|
|
type Request struct {
|
|
client *http.Client
|
|
header http.Header
|
|
params url.Values
|
|
method string
|
|
host string
|
|
namespace string
|
|
|
|
resource string
|
|
resourceName *string
|
|
body io.Reader
|
|
|
|
err error
|
|
}
|
|
|
|
// Params is the object to pass in to set paramaters
|
|
// on a request.
|
|
type Params struct {
|
|
LabelSelector map[string]string
|
|
Annotations map[string]string
|
|
}
|
|
|
|
// verb sets method
|
|
func (r *Request) verb(method string) *Request {
|
|
r.method = method
|
|
return r
|
|
}
|
|
|
|
// Get request
|
|
func (r *Request) Get() *Request {
|
|
return r.verb("GET")
|
|
}
|
|
|
|
// Post request
|
|
func (r *Request) Post() *Request {
|
|
return r.verb("POST")
|
|
}
|
|
|
|
// Put request
|
|
func (r *Request) Put() *Request {
|
|
return r.verb("PUT")
|
|
}
|
|
|
|
// Patch request
|
|
func (r *Request) Patch() *Request {
|
|
return r.verb("PATCH")
|
|
}
|
|
|
|
// Delete request
|
|
func (r *Request) Delete() *Request {
|
|
return r.verb("DELETE")
|
|
}
|
|
|
|
// Namespace is to set the namespace to operate on
|
|
func (r *Request) Namespace(s string) *Request {
|
|
r.namespace = s
|
|
return r
|
|
}
|
|
|
|
// Resource is the type of resource the operation is
|
|
// for, such as "services", "endpoints" or "pods"
|
|
func (r *Request) Resource(s string) *Request {
|
|
r.resource = s
|
|
return r
|
|
}
|
|
|
|
// Name is for targeting a specific resource by id
|
|
func (r *Request) Name(s string) *Request {
|
|
r.resourceName = &s
|
|
return r
|
|
}
|
|
|
|
// Body pass in a body to set, this is for POST, PUT and PATCH requests
|
|
func (r *Request) Body(in interface{}) *Request {
|
|
b := new(bytes.Buffer)
|
|
// if we're not sending YAML request, we encode to JSON
|
|
if r.header.Get("Content-Type") != "application/yaml" {
|
|
if err := json.NewEncoder(b).Encode(&in); err != nil {
|
|
r.err = err
|
|
return r
|
|
}
|
|
log.Debugf("Request body: %v", b)
|
|
r.body = b
|
|
return r
|
|
}
|
|
|
|
// if application/yaml is set, we assume we get a raw bytes so we just copy over
|
|
body, ok := in.(io.Reader)
|
|
if !ok {
|
|
r.err = errors.New("invalid data")
|
|
return r
|
|
}
|
|
// copy over data to the bytes buffer
|
|
if _, err := io.Copy(b, body); err != nil {
|
|
r.err = err
|
|
return r
|
|
}
|
|
|
|
log.Debugf("Request body: %v", b)
|
|
r.body = b
|
|
return r
|
|
}
|
|
|
|
// Params isused to set paramters on a request
|
|
func (r *Request) Params(p *Params) *Request {
|
|
for k, v := range p.LabelSelector {
|
|
r.params.Add("labelSelector", k+"="+v)
|
|
}
|
|
|
|
return r
|
|
}
|
|
|
|
// SetHeader sets a header on a request with
|
|
// a `key` and `value`
|
|
func (r *Request) SetHeader(key, value string) *Request {
|
|
r.header.Add(key, value)
|
|
return r
|
|
}
|
|
|
|
// request builds the http.Request from the options
|
|
func (r *Request) request() (*http.Request, error) {
|
|
var url string
|
|
switch r.resource {
|
|
case "pod", "service", "endpoint":
|
|
// /api/v1/namespaces/{namespace}/pods
|
|
url = fmt.Sprintf("%s/api/v1/namespaces/%s/%ss/", r.host, r.namespace, r.resource)
|
|
case "deployment":
|
|
// /apis/apps/v1/namespaces/{namespace}/deployments/{name}
|
|
url = fmt.Sprintf("%s/apis/apps/v1/namespaces/%s/%ss/", r.host, r.namespace, r.resource)
|
|
}
|
|
|
|
// append resourceName if it is present
|
|
if r.resourceName != nil {
|
|
url += *r.resourceName
|
|
}
|
|
|
|
// append any query params
|
|
if len(r.params) > 0 {
|
|
url += "?" + r.params.Encode()
|
|
}
|
|
|
|
// build request
|
|
req, err := http.NewRequest(r.method, url, r.body)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// set headers on request
|
|
req.Header = r.header
|
|
return req, nil
|
|
}
|
|
|
|
// Do builds and triggers the request
|
|
func (r *Request) Do() *Response {
|
|
if r.err != nil {
|
|
return &Response{
|
|
err: r.err,
|
|
}
|
|
}
|
|
|
|
req, err := r.request()
|
|
if err != nil {
|
|
return &Response{
|
|
err: err,
|
|
}
|
|
}
|
|
|
|
log.Debugf("kubernetes api request: %v", req)
|
|
|
|
res, err := r.client.Do(req)
|
|
if err != nil {
|
|
return &Response{
|
|
err: err,
|
|
}
|
|
}
|
|
|
|
log.Debugf("kubernetes api response: %v", res)
|
|
|
|
// return res, err
|
|
return newResponse(res, err)
|
|
}
|
|
|
|
// Options ...
|
|
type Options struct {
|
|
Host string
|
|
Namespace string
|
|
BearerToken *string
|
|
Client *http.Client
|
|
}
|
|
|
|
// NewRequest creates a k8s api request
|
|
func NewRequest(opts *Options) *Request {
|
|
req := &Request{
|
|
header: make(http.Header),
|
|
params: make(url.Values),
|
|
client: opts.Client,
|
|
namespace: opts.Namespace,
|
|
host: opts.Host,
|
|
}
|
|
|
|
if opts.BearerToken != nil {
|
|
req.SetHeader("Authorization", "Bearer "+*opts.BearerToken)
|
|
}
|
|
|
|
return req
|
|
}
|