k8s/Kubernetes-ericchiang/k8s-行业智能，新时代，新科技，新码农

<h1> Kubernetes </h1>的简单Go客户端
 <p> <a href="https://godoc.org/github.com/ericchiang/k8s"> <img src="https://godoc.org/github.com/ericchiang/k8s?status.svg" alt="GoDoc" /> </a> <a href="https://travis-ci.org/ericchiang/k8s"> <img src="https://travis-ci.org/ericchiang/k8s.svg?branch=master" alt="Build Status" /> </a> </p>
 <p>使用Kubernetes的<a href="https://developers.google.com/protocol-buffers/">协议缓冲区</a>支持生成的精简的Go客户端。此程序包的行为类似于<a href="https://github.com/kubernetes/client-go">官方Kubernetes的Go客户端</a>，但只导入两个外部依赖项。 </p>
 <pre><code class="language-go">package main

import (
    "context"
    "fmt"
    "log"

"github.com/ericchiang/k8s"
    corev1 "github.com/ericchiang/k8s/apis/core/v1"
)

func main() {
    client, err := k8s.NewInClusterClient()
    if err != nil {
        log.Fatal(err)
    }

var nodes corev1.NodeList
    if err := client.List(context.Background(), "", &nodes); err != nil {
        log.Fatal(err)
    }
    for _, node := range nodes.Items {
        fmt.Printf("name=%q schedulable=%t\n", *node.Metadata.Name, !*node.Spec.Unschedulable)
    }
}
</code></pre>
 <h2>要求</h2>
 <ul>
 <li> Go 1.7+（此软件包使用1.7中添加的“context”功能）</li>
 <li> Kubernetes 1.3+（1.3中添加了protobuf支持）</li>
 <li> <a href="https://godoc.org/github.com/golang/protobuf/proto"> github.com/golang/protobuf/proto </a>（protobuf序列化）</li>
 <li> <a href="https://godoc.org/golang.org/x/net/http2"> golang.org/x/net/http2 </a>（HTTP / 2支持）</li>
 </ul>
 <h2>用法</h2>
 <h3>创建，更新，删除</h3>
 <p>传递给<code>Create</code>,<code>Update</code>和<code>Delete</code>的对象类型决定了所执行的资源。 </p>
 <pre><code class="language-go">configMap := &corev1.ConfigMap{
    Metadata: &metav1.ObjectMeta{
        Name:      k8s.String("my-configmap"),
        Namespace: k8s.String("my-namespace"),
    },
    Data: map[string]string{"hello": "world"},
}

if err := client.Create(ctx, configMap); err != nil {
    // handle error
}

configMap.Data["hello"] = "kubernetes"

if err := client.Update(ctx, configMap); err != nil {
    // handle error
}

if err := client.Delete(ctx, configMap); err != nil {
    // handle error
}
</code></pre>
 <h3>获取，列表，注册</h3>
 <p>获取资源需要提供命名空间（对于命名空间对象）和名称。 </p>
 <pre><code class="language-go">// Get the "cluster-info" configmap from the "kube-public" namespace
var configMap corev1.ConfigMap
err := client.Get(ctx, "kube-public", "cluster-info", &configMap)
</code></pre>
 <p>执行列表操作时，还需要列出或监视的命名空间。 </p>
 <pre><code class="language-go">// Pods from the "custom-namespace"
var pods corev1.PodList
err := client.List(ctx, "custom-namespace", &pods)
</code></pre>
 <p>特殊值<code>AllNamespaces</code>表示应对所有群集资源执行列表或监视。 </p>
 <pre><code class="language-go">// Pods in all namespaces
var pods corev1.PodList
err := client.List(ctx, k8s.AllNamespaces, &pods)
</code></pre>
 <p>手表需要一个示例类型来确定他们正在观看的资源。 <code>Watch</code>返回一个可用于接收事件流的类型。这些事件包括相同类型的资源和事件的类型（添加，修改，删除）。 </p>
 <pre><code class="language-go">// Watch configmaps in the "kube-system" namespace
var configMap corev1.ConfigMap
watcher, err := client.Watch(ctx, "kube-system", &configMap)
if err != nil {
    // handle error
}
defer watcher.Close()

for {
    cm := new(corev1.ConfigMap)
    eventType, err := watcher.Next(cm)
    if err != nil {
        // watcher encountered and error, exit or create a new watcher
    }
    fmt.Println(eventType, *cm.Metadata.Name)
}
</code></pre>
 <p>使用主命名空间初始化集群内和集群外客户端。这是列出或观看时使用的建议值。 </p>
 <pre><code class="language-go">client, err := k8s.NewInClusterClient()
if err != nil {
    // handle error
}

// List pods in the namespace the client is running in.
var pods corev1.PodList
err := client.List(ctx, client.Namespace, &pods)
</code></pre>
 <h3>自定义资源</h3>
 <p>客户端操作支持用户定义的资源，例如<a href="https://kubernetes.io/docs/tasks/access-kubernetes-api/extend-api-custom-resource-definitions/"> CustomResourceDefinitions </a>和<a href="https://kubernetes.io/docs/concepts/api-extension/apiserver-aggregation/">聚合API服务器</a>提供的资源。要使用自定义资源，请定义等效的Go结构，然后将其注册到<code>k8s</code>包。默认情况下，客户端在编码和解码自定义资源时将使用JSON序列化。 </p>
 <pre><code class="language-go">import (
    "github.com/ericchiang/k8s"
    metav1 "github.com/ericchiang/k8s/apis/meta/v1"
)

type MyResource struct {
    Metadata *metav1.ObjectMeta `json:"metadata"`
    Foo      string             `json:"foo"`
    Bar      int                `json:"bar"`
}

// Required for MyResource to implement k8s.Resource
func (m *MyResource) GetMetadata() *metav1.ObjectMeta {
    return m.Metadata
}

type MyResourceList struct {
    Metadata *metav1.ListMeta `json:"metadata"`
    Items    []MyResource     `json:"items"`
}

// Require for MyResourceList to implement k8s.ResourceList
func (m *MyResourceList) GetMetadata() *metav1.ListMeta {
    return m.Metadata
}

func init() {
    // Register resources with the k8s package.
    k8s.Register("resource.example.com", "v1", "myresources", true, &MyResource{})
    k8s.RegisterList("resource.example.com", "v1", "myresources", true, &MyResourceList{})
}
</code></pre>
 <p>注册后，库可以像使用其他任何资源一样使用自定义资源。 </p>
 <pre><code class="language-go">func do(ctx context.Context, client *k8s.Client, namespace string) error {
    r := &MyResource{
        Metadata: &metav1.ObjectMeta{
            Name:      k8s.String("my-custom-resource"),
            Namespace: &namespace,
        },
        Foo: "hello, world!",
        Bar: 42,
    }
    if err := client.Create(ctx, r); err != nil {
        return fmt.Errorf("create: %v", err)
    }
    r.Bar = -8
    if err := client.Update(ctx, r); err != nil {
        return fmt.Errorf("update: %v", err)
    }
    if err := client.Delete(ctx, r); err != nil {
        return fmt.Errorf("delete: %v", err)
    }
    return nil
}
</code></pre>
 <p>如果自定义类型实现<a href="https://godoc.org/github.com/golang/protobuf/proto#Message"> <code>proto.Message</code> </a>，则客户端在编码和解码类型时将更喜欢protobuf。 </p>
 <h3>标签选择器</h3>
 <p>可以为任何列表操作提供标签选择器。 </p>
 <pre><code class="language-go">l := new(k8s.LabelSelector)
l.Eq("tier", "production")
l.In("app", "database", "frontend")

var pods corev1.PodList
err := client.List(ctx, "custom-namespace", &pods, l.Selector())
</code></pre>
 <h3>子资源</h3>
 <p>使用<code>Subresource</code>选项访问子资源。 </p>
 <pre><code class="language-go">err := client.Update(ctx, &pod, k8s.Subresource("status"))
</code></pre>
 <h3>创建群集外客户端</h3>
 <p>可以通过手动创建<code>http.Client</code>或解析<a href="https://godoc.org/github.com/ericchiang/k8s#Config"> <code>Config</code> </a>对象来构建群集外客户端。以下是从kubeconfig创建客户端的示例：</p>
 <pre><code class="language-go">import (
    "io/ioutil"

"github.com/ericchiang/k8s"

"github.com/ghodss/yaml"
)

// loadClient parses a kubeconfig from a file and returns a Kubernetes
// client. It does not support extensions or client auth providers.
func loadClient(kubeconfigPath string) (*k8s.Client, error) {
    data, err := ioutil.ReadFile(kubeconfigPath)
    if err != nil {
        return nil, fmt.Errorf("read kubeconfig: %v", err)
    }

// Unmarshal YAML into a Kubernetes config object.
    var config k8s.Config
    if err := yaml.Unmarshal(data, &config); err != nil {
        return nil, fmt.Errorf("unmarshal kubeconfig: %v", err)
    }
    return k8s.NewClient(&config)
}
</code></pre>
 <h3>错误</h3>
 <p> Kubernetes API返回的错误格式为<a href="https://godoc.org/github.com/ericchiang/k8s/api/unversioned#Status"> <code>unversioned.Status</code> </a>对象，客户端显示为<a href="https://godoc.org/github.com/ericchiang/k8s#APIError"> <code>*k8s.APIError</code> </a> s。需要检查错误代码或故障详细信息的程序可以使用类型转换来访问此信息。 </p>
 <pre><code class="language-go">// createConfigMap creates a configmap in the client's default namespace
// but does not return an error if a configmap of the same name already
// exists.
func createConfigMap(client *k8s.Client, name string, values map[string]string) error {
    cm := &v1.ConfigMap{
        Metadata: &metav1.ObjectMeta{
            Name:      &name,
            Namespace: &client.Namespace,
        },
        Data: values,
    }

err := client.Create(context.TODO(), cm)

// If an HTTP error was returned by the API server, it will be of type
    // *k8s.APIError. This can be used to inspect the status code.
    if apiErr, ok := err.(*k8s.APIError); ok {
        // Resource already exists. Carry on.
        if apiErr.Code == http.StatusConflict {
            return nil
        }
    }
    return fmt.Errorf("create configmap: %v", err)
}
</code></pre>