🥇Tiri kunyora opareta yeKubernetes paGolang

Cherechedza. transl.: Vashandisi isoftware yekubatsira yeKubernetes, yakagadzirirwa kuitisa otomatiki kuita kwemaitiro echinyakare pazvinhu zvesumbu kana zvimwe zviitiko zvikaitika. Takatonyora nezvevashandi mu ichi chinyorwa, pavakataura nezvepfungwa dzinokosha uye nheyo dzebasa ravo. Asi kana izvo zvinyorwa zvaive zvakanyanya zvekuonekwa kubva kudivi rekushanda zvakagadzirirwa-zvakagadzirwa zvikamu zveKubernetes, saka kushandura kwechinyorwa chitsva chave kurongwa chatova chiono chemugadziri / DevOps injinjini inokatyamadzwa nekuitwa kwemushandisi mutsva.

Ndakafunga kunyora chinyorwa ichi nemuenzaniso wehupenyu chaihwo mushure mekuedza kwangu kutsvaga zvinyorwa pakugadzira mushandisi weKubernetes, iyo yakapfuura nekudzidza kodhi.

Muenzaniso uchatsanangurwa ndeuyu: muboka redu reKubernetes, rimwe nerimwe Namespace inomiririra nharaunda yebhokisi rejecha rechikwata, uye isu taida kudzikisira kusvika kwavari kuitira kuti zvikwata zvingotamba mumabhokisi ejecha zvawo.

Iwe unogona kuzadzisa zvaunoda nekupa mushandisi boka rine RoleBinding kune zvakananga Namespace и ClusterRole nekodzero dzekugadzirisa. Iyo YAML inomiririra ichaita seizvi:

---
kind: RoleBinding
apiVersion: rbac.authorization.k8s.io/v1beta1
metadata:
  name: kubernetes-team-1
  namespace: team-1
subjects:
- kind: Group
  name: kubernetes-team-1
  apiGroup: rbac.authorization.k8s.io
roleRef:
  kind: ClusterRole
  name: edit
apiGroup: rbac.authorization.k8s.io

(rolebinding.yamlin mbishi)

Gadzira imwe RoleBinding Iwe unogona kuzviita nemaoko, asi mushure mekuyambuka zana remazita emucherechedzo, rinova basa rinonetesa. Apa ndipo panouya Kubernetes vanoshanda-vanokutendera kuti uite otomatiki kusikwa kweKubernetes zviwanikwa zvichienderana nekuchinja kune zviwanikwa. Muchiitiko chedu tinoda kugadzira RoleBinding uchigadzira Namespace.

Chekutanga, ngatitsanangurirei basa racho mainiyo inoita iyo inodiwa setup yekumhanyisa chirevo uye yobva yadaidza chirevo chiito:

(Cherechedza. transl.: pano uye pasi pemashoko ari mukodhi anoshandurirwa muchiRussia. Pamusoro pezvo, indentation yakagadziridzwa kune nzvimbo panzvimbo pe[inokurudzirwa muGo] matebu chete nechinangwa chekuverenga zvirinani mukati meiyo Habr marongero. Mushure mekunyorwa kwega kwega kune zvinongedzo kune yekutanga paGitHub, panochengetwa Chirungu-mutauro uye ma tabo.)

func main() {
  // Устанавливаем вывод логов в консольный STDOUT
  log.SetOutput(os.Stdout)

  sigs := make(chan os.Signal, 1) // Создаем канал для получения сигналов ОС
  stop := make(chan struct{})     // Создаем канал для получения стоп-сигнала

  // Регистрируем получение SIGTERM в канале sigs
  signal.Notify(sigs, os.Interrupt, syscall.SIGTERM, syscall.SIGINT) 

  // Goroutines могут сами добавлять себя в WaitGroup,
 // чтобы завершения их выполнения дожидались
  wg := &sync.WaitGroup{} 

  runOutsideCluster := flag.Bool("run-outside-cluster", false, "Set this flag when running outside of the cluster.")
  flag.Parse()
  // Создаем clientset для взаимодействия с кластером Kubernetes
  clientset, err := newClientSet(*runOutsideCluster)

  if err != nil {
    panic(err.Error())
  }

  controller.NewNamespaceController(clientset).Run(stop, wg)

  <-sigs // Ждем сигналов (до получения сигнала более ничего не происходит)
  log.Printf("Shutting down...")

  close(stop) // Говорим goroutines остановиться
  wg.Wait()   // Ожидаем, что все остановлено
}

(main.goin mbishi)

Isu tinoita zvinotevera:

Isu tinogadzirisa mubato kune chaiwo masisitimu anoshanda masisitimu kukonzeresa kumisa zvine nyasha kweanoshanda.
Isu tinoshandisa WaitGroupkumisa zvakanaka magoroutines usati wamisa application.
Isu tinopa mukana kune cluster nekugadzira clientset.
Kutanga NamespaceController, umo pfungwa dzedu dzese dzichawanikwa.

Zvino isu tinoda hwaro hwepfungwa, uye mune yedu iyi ndiyo yakataurwa NamespaceController:

// NamespaceController следит через Kubernetes API за изменениями
// в пространствах имен и создает RoleBinding для конкретного namespace.
type NamespaceController struct {
  namespaceInformer cache.SharedIndexInformer
  kclient           *kubernetes.Clientset
}

// NewNamespaceController создает новый NewNamespaceController
func NewNamespaceController(kclient *kubernetes.Clientset) *NamespaceController {
  namespaceWatcher := &NamespaceController{}

  // Создаем информер для слежения за Namespaces
  namespaceInformer := cache.NewSharedIndexInformer(
    &cache.ListWatch{
      ListFunc: func(options metav1.ListOptions) (runtime.Object, error) {
        return kclient.Core().Namespaces().List(options)
      },
      WatchFunc: func(options metav1.ListOptions) (watch.Interface, error) {
        return kclient.Core().Namespaces().Watch(options)
      },
    },
    &v1.Namespace{},
    3*time.Minute,
    cache.Indexers{cache.NamespaceIndex: cache.MetaNamespaceIndexFunc},
  )

  namespaceInformer.AddEventHandler(cache.ResourceEventHandlerFuncs{
    AddFunc: namespaceWatcher.createRoleBinding,
  })

  namespaceWatcher.kclient = kclient
  namespaceWatcher.namespaceInformer = namespaceInformer

  return namespaceWatcher
}

(controller.goin mbishi)

Pano tinogadzirisa SharedIndexInformer, iyo ichaita (uchishandisa cache) kumirira shanduko mumazita (verenga zvakawanda nezvevanozivisa muchinyorwa "Iyo Kubernetes scheduler inoshanda sei chaizvo?"- approx. shanduro). Mushure meizvi tinobatanidza EventHandler kumuzivisi, kuitira kuti kana uchiwedzera zita (Namespace) basa rinonzi createRoleBinding.

Nhanho inotevera ndeyekutsanangura basa iri createRoleBinding:

func (c *NamespaceController) createRoleBinding(obj interface{}) {
  namespaceObj := obj.(*v1.Namespace)
  namespaceName := namespaceObj.Name

  roleBinding := &v1beta1.RoleBinding{
    TypeMeta: metav1.TypeMeta{
      Kind:       "RoleBinding",
      APIVersion: "rbac.authorization.k8s.io/v1beta1",
    },
    ObjectMeta: metav1.ObjectMeta{
      Name:      fmt.Sprintf("ad-kubernetes-%s", namespaceName),
      Namespace: namespaceName,
    },
    Subjects: []v1beta1.Subject{
      v1beta1.Subject{
        Kind: "Group",
        Name: fmt.Sprintf("ad-kubernetes-%s", namespaceName),
      },
    },
    RoleRef: v1beta1.RoleRef{
      APIGroup: "rbac.authorization.k8s.io",
        Kind:     "ClusterRole",
        Name:     "edit",
    },
  }

  _, err := c.kclient.Rbac().RoleBindings(namespaceName).Create(roleBinding)

  if err != nil {
    log.Println(fmt.Sprintf("Failed to create Role Binding: %s", err.Error()))
  } else {
    log.Println(fmt.Sprintf("Created AD RoleBinding for Namespace: %s", roleBinding.Name))
  }
}

(controller.goin mbishi)

Isu tinowana nzvimbo yezita se obj wochishandura kuita chinhu Namespace. Zvadaro tinotsanangura RoleBinding, zvichibva pafaira reYAML rataurwa pakutanga, uchishandisa chinhu chakapihwa Namespace uye kugadzira RoleBinding. Pakupedzisira, tinonyora kana kusikwa kwakabudirira.

Basa rekupedzisira rinotsanangurwa ndeiyi Run:

// Run запускает процесс ожидания изменений в пространствах имён
// и действия в соответствии с этими изменениями.
func (c *NamespaceController) Run(stopCh <-chan struct{}, wg *sync.WaitGroup) {
  // Когда эта функция завершена, пометим как выполненную
  defer wg.Done()

  // Инкрементируем wait group, т.к. собираемся вызвать goroutine
  wg.Add(1)

  // Вызываем goroutine
  go c.namespaceInformer.Run(stopCh)

  // Ожидаем получения стоп-сигнала
  <-stopCh
}

(controller.goin mbishi)

Apa tiri kutaura WaitGroupkuti titange goroutine tozofona namespaceInformer, izvo zvakambotsanangurwa. Kana chiratidzo chekumira chasvika, chinopedza basa, zivisa WaitGroup, iyo isisiri kuurayiwa, uye basa iri richabuda.

Ruzivo rwekuvaka uye nekumhanyisa chirevo ichi pane Kubernetes cluster inogona kuwanikwa mukati repositories paGitHub.

Ndizvo zvemushandisi anogadzira RoleBinding riinhi Namespace muKubernetes cluster, yakagadzirira.

Source: www.habr.com

Kunyora mushandisi weKubernetes muGolang

Voeg kukanzura mhinduro