k8s源码分析------第三方库etcd client分析

说明:此文章为腾讯云机器自动从本人csdn博客搬迁过来。是本人授权操作。

申明:无本人授权,不可转载本文。如有转载,本人保留追究其法律责任的权利。

龚浩华,QQ 29185807,月牙寂 道长

第一时间获取文章,可以关注本人公众号 月牙寂道长 yueyajidaozhang

代码为github.com/coreos/go-etcd/etcd

注: 此版本为k8s v1.1.1 中所使用的etcd client。

首先我看下k8s中是如何使用的。位置在k8s.io\kubernetes\cmd\kube-apiserver\app\server.go

代码目录,从这里来看,代码还是非常清晰的

那么我们就从此处入口,先看client.go

先看结构体

结构体里面,比较重要的东西

1、cluster,集群管理

2、httpclient,这个将是最终的入口

我们继续

这里面主要是初始化了cluster,httpclient

其中cluster后面再详细介绍,这里我们接着看httpclient

很明显这里就是构造了一个标准库net/http中的Client

大致的初始化很简单。其实还有一个tls的初始化。为NewTLSClient,对应的httpclient初始化为initHTTPSClient

下面我们看看etcd client都提供了那些操作。

Get操作

我们看get.go

很明显,我们看到Get调用了RawGet,而RawGet调用了get

我们再跟踪get

在request.go中

继续getCancelable

还是在request.go中

主要有NewRawRequest。request.go中

其实就是对request的一些包装,包含了一些参数

我们继续看SendRequest。这个才是整个代码的核心

在下面我们看到这里当RawRequest中的Cancel不为nil的时候,会启动一个协程来接收cancel消息。 但目前我们分析的Get是没有设置的

我们继续这里有个for循环,attempt为尝试次数统计,当成功则会退出for循环,失败则会继续尝试。其中有个变量为httpPath是个关键

我们现在跟进去看看 requet.go中

我们看到了cluster,我们继续跟进去看看

从上面的cluster的代码来看其实pick就是返回cluster中的一台主机,而pick的机器则是一个随机的主机,在初始化的时候有随机,在failure的时候,又会重新随机

我们回到之前的sendrequest

这里主要的地方就是构造一个标准库net/http中的Request

再继续

我们看到我们之前提到的httpclient,接收刚刚构建的Request,然后Do。就是发起了http的请求。

进行校验头部,如果是正常的,则退出for循环

退出for循环之后,返回了一个RawResponse结构体

最后我们返回到

我们看到了结果

其实就是一个解码的过程

至此Get操作就解析完了

还有一些操作如:

AddChildDir

其实跟踪进去,最后也是到了SendRequest函数中

还有一些其他的操作,就不一一介绍了,其代码的流程是基本一致的。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

编辑于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏极客编程

Python超级明星WEB开发框架Flask简明教程

和Django大包大揽不同,Flask建立于一系列的开源软件包之上,这其中 最主要的是WSGI应用开发库Werkzeug和模板引擎Jinja:

832
来自专栏虚拟化云计算

OpenStack数据库远程对象模型

在OpenStack的各个服务之间有些数据库对象是远程操作的,远程对象所实现的效果是:一个 A 服务中的远程对象实例,可以由消息队列传送到B 服务,B 服务能够...

782
来自专栏抠抠空间

爬虫值requests库

1190
来自专栏前端之路

封装时间格式化函数

1112
来自专栏陈树义

【Struts】Struts框架配置详解

1.首先将所必须的Jar包放到项目的WebRoot/WEB-INF/lib目录下。 如果你没有这些Jar文件,你可以到Struts官网上下载:http://st...

3407
来自专栏面朝大海春暖花开

springMVC接收参数 xml/json

  如果不一样也可以,通过@RequestParam参数来进行映射下,也是可以设置默认值的

1114
来自专栏编程坑太多

requests库使用方式

1114
来自专栏爱撒谎的男孩

Struts2之动态调用

-在struts核心配置文件详解(action)中已经详细讲解了method的用法,使用这个方式可以指定Action类中的不同的方法映射请求,那么就完成了动态调...

3196
来自专栏禅林阆苑

redis学习笔记

优点: 高并发读写性能、大数据量扩展(分布式存储)、配置简单、操作与数据模型灵活高效、成本 低廉

974
来自专栏Python绿色通道

使用Python开发你的第一个服务器程序

声明:本文是用Py3.6版本,而且从此以后我的系列文章优先使用Py3.6版本,为什么说优先使用Py3.6版本呢?因为有的时候Py3.6版本确实有些问题,那我只能...

1072

扫码关注云+社区