参考链接：使用client-go自定义开发Kubernetes

1.本地运行 apiserver demo

[root@wangjq demo]# apiserver-boot run local

// :: regenerating generated code.  To disable regeneration, run with --generate=false.

/var/wangjq/golang/bin/bin/apiregister-gen --input-dirs demo/pkg/apis/... --input-dirs demo/pkg/controller/...

/var/wangjq/golang/bin/bin/conversion-gen --input-dirs demo/pkg/apis/demo/v1 --input-dirs demo/pkg/apis/demo -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt -O zz_generated.conversion --extra-peer-dirs k8s.io/apimachinery/pkg/apis/meta/v1,k8s.io/apimachinery/pkg/conversion,k8s.io/apimachinery/pkg/runtime

/var/wangjq/golang/bin/bin/deepcopy-gen --input-dirs demo/pkg/apis/demo/v1 --input-dirs demo/pkg/apis/demo -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt -O zz_generated.deepcopy

/var/wangjq/golang/bin/bin/openapi-gen --input-dirs demo/pkg/apis/demo/v1 --input-dirs demo/pkg/apis/demo -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt -i k8s.io/apimachinery/pkg/apis/meta/v1,k8s.io/apimachinery/pkg/api/resource,k8s.io/apimachinery/pkg/version,k8s.io/apimachinery/pkg/runtime,k8s.io/apimachinery/pkg/util/intstr,k8s.io/api/admission/v1beta1,k8s.io/api/admissionregistration/v1alpha1,k8s.io/api/admissionregistration/v1beta1,k8s.io/api/apps/v1,k8s.io/api/apps/v1beta1,k8s.io/api/apps/v1beta2,k8s.io/api/authentication/v1,k8s.io/api/authentication/v1beta1,k8s.io/api/authorization/v1,k8s.io/api/authorization/v1beta1,k8s.io/api/autoscaling/v1,k8s.io/api/autoscaling/v2beta1,k8s.io/api/batch/v1,k8s.io/api/batch/v1beta1,k8s.io/api/batch/v2alpha1,k8s.io/api/certificates/v1beta1,k8s.io/api/core/v1,k8s.io/api/events/v1beta1,k8s.io/api/extensions/v1beta1,k8s.io/api/imagepolicy/v1alpha1,k8s.io/api/networking/v1,k8s.io/api/policy/v1beta1,k8s.io/api/rbac/v1,k8s.io/api/rbac/v1alpha1,k8s.io/api/rbac/v1beta1,k8s.io/api/scheduling/v1alpha1,k8s.io/api/settings/v1alpha1,k8s.io/api/storage/v1,k8s.io/api/storage/v1alpha1,k8s.io/api/storage/v1beta1,k8s.io/api/core/v1 --output-package demo/pkg/openapi

/var/wangjq/golang/bin/bin/defaulter-gen --input-dirs demo/pkg/apis/demo/v1 --input-dirs demo/pkg/apis/demo -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt -O zz_generated.defaults --extra-peer-dirs= k8s.io/apimachinery/pkg/apis/meta/v1,k8s.io/apimachinery/pkg/conversion,k8s.io/apimachinery/pkg/runtime

/var/wangjq/golang/bin/bin/client-gen -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt --input-base demo/pkg/apis --input demo/v1 --clientset-path demo/pkg/client/clientset_generated --clientset-name clientset

/var/wangjq/golang/bin/bin/client-gen -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt --input-base demo/pkg/apis --input demo --clientset-path demo/pkg/client/clientset_generated --clientset-name internalclientset

/var/wangjq/golang/bin/bin/lister-gen --input-dirs demo/pkg/apis/demo/v1 --input-dirs demo/pkg/apis/demo -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt --output-package demo/pkg/client/listers_generated

/var/wangjq/golang/bin/bin/informer-gen --input-dirs demo/pkg/apis/demo/v1 --input-dirs demo/pkg/apis/demo -o /var/wangjq/golang/src --go-header-file boilerplate.go.txt --output-package demo/pkg/client/informers_generated --listers-package demo/pkg/client/listers_generated --versioned-clientset-package demo/pkg/client/clientset_generated/clientset --internal-clientset-package demo/pkg/client/clientset_generated/internalclientset

// :: CGO_ENABLED=

go build -o bin/apiserver cmd/apiserver/main.go

go build -o bin/controller-manager cmd/controller-manager/main.go

etcd

bin/apiserver --etcd-servers=http://localhost:2379 --secure-port=9443 --delegated-auth=false

W0926 ::16.495764     authorization.go:] Authorization is disabled

W0926 ::16.495828     authentication.go:] Authentication is disabled

I0926 ::16.504351     logs.go:] Defaulting fields for Bird bird-example

I0926 ::16.540151     serve.go:] Serving securely on [::]:

I0926 ::17.502752     logs.go:] Defaulting fields for Bird bird-example

to test the server run `kubectl --kubeconfig kubeconfig api-versions`

bin/controller-manager --kubeconfig=kubeconfig

-- ::18.036499 I | Running reconcile Bird for bird-example

2.验证apiserver是否运行正常

[root@wangjq demo]# kubectl --kubeconfig kubeconfig api-versions

demo.qianxin.com/v1

3.client-go源代码（创建，删除，更新，获取）

package main

import (

    birdApiv1 "demo/pkg/apis/demo/v1"

    clientset "demo/pkg/client/clientset_generated/clientset"

    "encoding/json"

    "fmt"

    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"

    schema "k8s.io/apimachinery/pkg/runtime/schema"

    restclient "k8s.io/client-go/rest"

)

var url = "127.0.0.1:9443"

var newName string = "client-go-demo"

type ResourceHandler struct {

    client *DemoClient

}

type DemoClient struct {

    Client *clientset.Clientset

}

func newResourceHandler() *ResourceHandler {

    return &ResourceHandler{client: NewDemoClient()}

}

func NewDemoClient() *DemoClient {

    c := &DemoClient{}

    c.Client = clientset.NewForConfigOrDie(&restclient.Config{

        Host: url,

        TLSClientConfig: restclient.TLSClientConfig{

            Insecure: true,

        },

        APIPath: "/apis/demo.qianxin.com",

        ContentConfig: restclient.ContentConfig{

            GroupVersion: &schema.GroupVersion{

                Group:   "demo",

                Version: "v1",

            }}})

    fmt.Println(c.Client)

    return c

}

func (c *ResourceHandler) CreateBird() {

    namespace := &birdApiv1.Bird{

        ObjectMeta: metav1.ObjectMeta{

            Name: newName,

            UID:  "aead7663-a7b6-471a-a222-a94c41a99999",

        },

        Status: birdApiv1.BirdStatus{},

        Spec: birdApiv1.BirdSpec{

            Datetime:      "2018-06-14T18:00:00Z03:00",

            AwayTeamGoals: ,

            AwayTeam:      "wangjq",

            HomeTeam:      "demo",

            HomeTeamGoals: ,

        },

    }

    _, err := c.client.Client.DemoV1().Birds("default").Create(namespace)

    if err != nil {

        panic(err)

    }

}

func (c *ResourceHandler) DeleteBird(name string) {

    if err := c.client.Client.DemoV1().Birds("default").Delete(name, &metav1.DeleteOptions{}); err != nil {

        panic(err)

    }

}

func (c *ResourceHandler) UpdateBird(name string) {

    result := c.GetBird(name)

    result.Spec.AwayTeam = "zzzzz"

    result.Spec.Datetime = "2222-12-22T22:22:00Z03:22"

    result.Spec.HomeTeam = "zzzzz"

    c.client.Client.DemoV1().Birds("default").Update(result)

}

func (c *ResourceHandler) ListBirds() {

    fmt.Println("============================ List All ============================")

    podList, _ := c.client.Client.DemoV1().Birds("default").List(metav1.ListOptions{})

    fmt.Println("podList: ", len(podList.Items))

    for key, value := range podList.Items {

        fmt.Println("第", key+, "个pod.................")

        bytes, err := json.Marshal(value)

        if err != nil {

            return

        }

        fmt.Println(string(bytes))

        fmt.Println("##################################################")

        fmt.Printf("AwayTeam: %s\n", value.Spec.AwayTeam)

        fmt.Printf("AwayTeamGoals: %s\n", value.Spec.AwayTeamGoals)

        fmt.Printf("Datetime: %s\n", value.Spec.Datetime)

        fmt.Printf("HomeTeam: %s\n", value.Spec.HomeTeam)

        fmt.Printf("HomeTeamGoals: %s\n", value.Spec.HomeTeamGoals)

        fmt.Println("##################################################")

    }

    for _, pod := range podList.Items {

        fmt.Printf("Name: %s, Status: %s, CreateTime: %s, Uid: %s\n",

            pod.ObjectMeta.Name, pod.Status, pod.ObjectMeta.CreationTimestamp, pod.GetUID())

    }

}   

func (c *ResourceHandler) GetBird(name string) *birdApiv1.Bird {

    result, err := c.client.Client.DemoV1().Birds("default").Get(name, metav1.GetOptions{})

    if err != nil {

        panic(err)

    }

    return result

}

func main() {

    resourceHandler := newResourceHandler()

    resourceHandler.ListBirds()

    resourceHandler.CreateBird()

    resourceHandler.ListBirds()

    resourceHandler.UpdateBird(newName)

    resourceHandler.ListBirds()

    resourceHandler.DeleteBird(newName)

    resourceHandler.ListBirds()

}

4.运行测试

[root@wangjq demo]# go run client-demo.go

&{0xc000292d40 0xc0002a3970}

============================ List All ============================

podList:

============================ List All ============================

podList:

第  个pod.................

{"metadata":{"name":"client-go-demo","namespace":"default","selfLink":"/apis/demo.qianxin.com/v1/namespaces/default/birds/client-go-demo","uid":"4264dd63-eb30-11e9-86cf-5098b81a3139","resourceVersion":"","generation":,"creationTimestamp":"2019-10-10T07:33:31Z"},"spec":{"datetime":"2018-06-14T18:00:00Z03:00","homeTeam":"demo","homeTeamGoals":,"awayTeam":"wangjq","awayTeamGoals":},"status":{}}

##################################################

AwayTeam: wangjq

AwayTeamGoals: %!s(int=)

Datetime: --14T18::00Z03:

HomeTeam: demo

HomeTeamGoals: %!s(int=)

##################################################

Name: client-go-demo, Status: {}, CreateTime: -- :: + HKT, Uid: 4264dd63-eb30-11e9-86cf-5098b81a3139

============================ List All ============================

podList:

第  个pod.................

{"metadata":{"name":"client-go-demo","namespace":"default","selfLink":"/apis/demo.qianxin.com/v1/namespaces/default/birds/client-go-demo","uid":"4264dd63-eb30-11e9-86cf-5098b81a3139","resourceVersion":"","generation":,"creationTimestamp":"2019-10-10T07:33:31Z"},"spec":{"datetime":"2222-12-22T22:22:00Z03:22","homeTeam":"zzzzz","homeTeamGoals":,"awayTeam":"zzzzz","awayTeamGoals":},"status":{}}

##################################################

AwayTeam: zzzzz

AwayTeamGoals: %!s(int=)

Datetime: --22T22::00Z03:

HomeTeam: zzzzz

HomeTeamGoals: %!s(int=)

##################################################

Name: client-go-demo, Status: {}, CreateTime: -- :: + HKT, Uid: 4264dd63-eb30-11e9-86cf-5098b81a3139

============================ List All ============================

podList:

最新文章

  1. Neutron分析（5）—— neutron-l3-agent中的iptables
  2. 2015 "BestCoder Cup" Champion
  3. 打印对象和toString方法
  4. jQuery（7）——jQuery与Ajax的应用
  5. [SinGuLaRiTy] 树形DP专项测试
  6. Unity 游戏框架搭建 (五) 简易消息机制
  7. mysql之数据操作
  8. mac os x下Dreamweaver如何还原初始配置
  9. 17秋 软件工程 第六次作业 Beta冲刺
  10. create react app遇到的问题
  11. 【emWin】例程三十一：窗口对象——Multipage
  12. information_schema
  13. day79
  14. jQuery Sizzle选择器（二）
  15. MySQL工具 Navicat
  16. 构建工具-----Gradle(二)-----myeclipse 10和myeclipse2015安装gradle插件----其他版本的myeclipse类似
  17. 推荐一个React 入门的教程
  18. Linux系统中ElasticSearch搜索引擎安装配置Head插件
  19. nios 使用count binary 例程 只是led不闪
  20. [转] JQuery UI Tabs 动态添加页签，并跳转到新页签

热门文章

  1. 【Go语言学习】匿名函数与闭包
  2. NFS /etc/exports参数解释
  3. redis配置密码
  4. Redis之Redis的数据类型
  5. SpringMVC学习之使用注解编写SpringMVC程序
  6. The Google File System（论文阅读笔记）
  7. Python raw_input() 函数
  8. PHP print() 函数
  9. 7.18 NOI模拟赛 因懒无名 线段树分治 线段树维护直径
  10. 使用VMware虚拟机建立Ubuntu与主机win7的文件共享与传输