Operator是CoreOS推出的旨在简化复杂有状态应用管理的框架，它是一个感知应用状态的控制器，通过扩展Kubernetes API来自动创建、管理和配置应用实例。

Operator原理

Operator基于Third Party Resources扩展了新的应用资源，并通过控制器来保证应用处于预期状态。比如etcd operator通过下面的三个步骤模拟了管理etcd集群的行为：

1. 通过Kubernetes API观察集群的当前状态；
2. 分析当前状态与期望状态的差别；

3. 调用etcd集群管理API或Kubernetes API消除这些差别。

   
   
   image.png

如何创建Operator

Operator是一个感知应用状态的控制器，所以实现一个Operator最关键的就是把管理应用状态的所有操作封装到配置资源和控制器中。通常来说Operator需要包括以下功能：

• Operator自身以deployment的方式部署
• Operator自动创建一个Third Party Resources资源类型，用户可以用该类型创建应用实例
• Operator应该利用Kubernetes内置的Serivce/ReplicaSet等管理应用
• Operator应该向后兼容，并且在Operator自身退出或删除时不影响应用的状态
• Operator应该支持应用版本更新
• Operator应该测试Pod失效、配置错误、网络错误等异常情况

如何使用Operator

为了方便描述，以Etcd Operator为例，具体的链接可以参考-Etcd Operator。
在Kubernetes部署Operator： 通过在Kubernetes集群中创建一个deploymet实例，来部署对应的Operator。具体的Yaml示例如下：

apiVersion: v1
kind: ServiceAccount
metadata:
  name: admin
  namespace: default

---
kind: ClusterRoleBinding
apiVersion: rbac.authorization.k8s.io/v1alpha1
metadata:
  name: admin
subjects:
  - kind: ServiceAccount
    name: admin
    namespace: default
roleRef:
  kind: ClusterRole
  name: cluster-admin
  apiGroup: rbac.authorization.k8s.io
---
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
  name: etcd-operator
spec:
  replicas: 1
  template:
    metadata:
      labels:
        name: etcd-operator
    spec:
      serviceAccountName: admin
      containers:
      - name: etcd-operator
        image: quay.io/coreos/etcd-operator:v0.4.2
        env:
        - name: MY_POD_NAMESPACE
          valueFrom:
            fieldRef:
              fieldPath: metadata.namespace
        - name: MY_POD_NAME
          valueFrom:
            fieldRef:
              fieldPath: metadata.name

# kubectl create -f deployment.yaml
serviceaccount "admin" created
clusterrolebinding "admin" created
deployment "etcd-operator" created

# kubectl  get pod 
NAME                            READY     STATUS    RESTARTS   AGE
etcd-operator-334633986-3nzk1   1/1       Running   0          31s

查看operator是否部署成功：

# kubectl get thirdpartyresources
NAME                      DESCRIPTION             VERSION(S)
cluster.etcd.coreos.com   Managed etcd clusters   v1beta1

对应的有状态服务yaml文件示例如下：

apiVersion: "etcd.coreos.com/v1beta1"
kind: "Cluster"
metadata:
  name: "example-etcd-cluster"
spec:
  size: 3
  version: "3.1.8"

部署对应的有状态服务：

# kubectl create -f example-etcd-cluster.yaml
Cluster "example-etcd-cluster" created

# kubectl get  cluster
NAME                                        KIND
example-etcd-cluster   Cluster.v1beta1.etcd.coreos.com

# kubectl get  service
NAME                          CLUSTER-IP      EXTERNAL-IP   PORT(S) 
example-etcd-cluster          None            <none>        2379/TCP,2380/TCP   
example-etcd-cluster-client   10.105.90.190   <none>        2379/TCP

# kubectl get pod
NAME                            READY     STATUS    RESTARTS   AGE
example-etcd-cluster-0002       1/1       Running   0          5h
example-etcd-cluster-0003       1/1       Running   0          4h
example-etcd-cluster-0004       1/1       Running   0          4h

其他示例

• Prometheus Operator
• Rook Operator
• Tectonic Operators

相关示例

• https://github.com/sapcc/kubernetes-operators
• https://github.com/kbst/memcached
• https://github.com/Yolean/kubernetes-kafka
• https://github.com/krallistic/kafka-operator
• https://github.com/huawei-cloudfederation/redis-operator
• https://github.com/upmc-enterprises/elasticsearch-operator
• https://github.com/pires/nats-operator
• https://github.com/rosskukulinski/rethinkdb-operator
• https://istio.io/

后续补充自己的demo及内容。。