Kubernetes应用平台API开发实战
前面文章介绍了通过基于go-restful框架开发API, client-go生成clientset, informers, listers来读取和写入自定义资源，基于kubebuilder开发CRD资源控制器。今天我们通过一个实例来看一下API整个开发过程。 开发步骤 1，通过kubebuilder来开发CRD控制器 2，通过client-gen，lister-gen，informer-gen生成clientset, informers, listers代码 3，开发models实现CRD资源的kubernets读写操作，读取列表时的排序，分页，过滤 4，开发handler实现CRD资源的API处理 CRD资源的读操作 CRD资源的读操作通过Informer来读取，减少API和Etcd集群的压力。 Informer的主要工作原理为：通过Reflector反射来监听Kubernetes对资源的操作事件，把资源对象和操作类型写入到一个DeltaFIFO的队列中。Reflector消费队列，将资源对象存储到indexer，indexer与Etcd集群的数据完全保持一致。 CRD资源的写操作 CRD资源的写通过client-go的clientset来完成对资源的Create，Update，Patch操作。 代码开发 这里我们需要实现上一篇讲的TrackingServer自定义资源的API。TrackingServer主要用于管理机器学习实验跟踪MLflow在k8s里的实例资源。 创建Informer informerFactories结构体实现了InformerFactory接口，这个接口有两个SharedInformerFactory，一个为Kubernetes资源的informerFactory，一个为本项目自定义资源的aiInformerFactory。aiscopeinformers.NewSharedInformerFactory创建了一个aiInformerFactory实例，这里的NewSharedInformerFactory为代码生成器生成的方法。通过代码生成器创建clientset客户端aiClient，作为参数来创建InformerFactory type InformerFactory interface { KubernetesSharedInformerFactory() k8sinformers.SharedInformerFactory AIScopeSharedInformerFactory() aiscopeinformers.SharedInformerFactory // Start shared informer factory one by one if they are not nil Start(stopCh <-chan struct{}) } type informerFactories struct { informerFactory k8sinformers.SharedInformerFactory aiInformerFactory aiscopeinformers.SharedInformerFactory } func NewInformerFactories(client kubernetes.Interface, aiClient versioned.Interface) InformerFactory { factory := &informerFactories{} if client != nil { factory.informerFactory = k8sinformers.
