Knative Eventing中Channel怎么注入默認(rèn) Provisioner

這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)Knative Eventing中Channel怎么注入默認(rèn) Provisioner，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

 在 Knative Eventing 中創(chuàng)建 Broker 時，如果不指定 provisioner， 系統(tǒng)會自動創(chuàng)建默認(rèn)的 provisioner， 那么這個機(jī)制是如何實現(xiàn)的呢？ 本文基于 Knative Eventing 0.5 版本，介紹了這個實現(xiàn)機(jī)制。

場景

通常的在創(chuàng)建Broker時，我們需要通過 spec.ChannelTemplate 指定使用某個具體的 Channel Provisioner。例如這樣的Broker:

apiVersion: eventing.knative.dev/v1alpha1
kind: Broker
metadata:
  name: pubsub-channel
spec:
  channelTemplate:
    provisioner:
      apiVersion: eventing.knative.dev/v1alpha1
      kind: ClusterChannelProvisioner
      name: gcp-pubsub

這里通過spec.ChannelTemplate 指定了名稱為gcp-pubsub的provisioner。那么我們也遇到過這樣的Broker：

apiVersion: eventing.knative.dev/v1alpha1
kind: Broker
metadata:
  name: default

并沒有指定使用某個具體的 channel, 但創(chuàng)建完Broker之后會發(fā)現(xiàn)已經(jīng)創(chuàng)建出來了Channel:

apiVersion: eventing.knative.dev/v1alpha1
kind: Channel
metadata:
  ...
  name: default-broker-8ml79
  namespace: default
  ownerReferences:
  - apiVersion: eventing.knative.dev/v1alpha1
    blockOwnerDeletion: true
    controller: true
    kind: Broker
    name: default
    uid: 2e4c3332-6755-11e9-a81f-00163f005e02
spec:
  provisioner:
    apiVersion: eventing.knative.dev/v1alpha1
    kind: ClusterChannelProvisioner
    name: in-memory
...

分析

我們知道 Broker創(chuàng)建之后，會通過 reconcile controller 會創(chuàng)建相應(yīng)的Channel, 也就是下面這段代碼：

// newChannel creates a new Channel for Broker 'b'.
func newChannel(b *v1alpha1.Broker, l map[string]string) *v1alpha1.Channel {
    var spec v1alpha1.ChannelSpec
    if b.Spec.ChannelTemplate != nil {
        spec = *b.Spec.ChannelTemplate
    }

    return &v1alpha1.Channel{
        ObjectMeta: metav1.ObjectMeta{
            Namespace:    b.Namespace,
            GenerateName: fmt.Sprintf("%s-broker-", b.Name),
            Labels:       l,
            OwnerReferences: []metav1.OwnerReference{
                *metav1.NewControllerRef(b, schema.GroupVersionKind{
                    Group:   v1alpha1.SchemeGroupVersion.Group,
                    Version: v1alpha1.SchemeGroupVersion.Version,
                    Kind:    "Broker",
                }),
            },
        },
        Spec: spec,
    }
}

分析上面這段代碼，我們可以很清楚得出這樣的結(jié)論：如果Broker中設(shè)置了Spec.ChannelTemplate, 那么Channel中會直接使用ChannelTemplate所對應(yīng)的provisioner。
但如果沒有設(shè)置的話， 那么Channel中的spec應(yīng)該設(shè)置為nil。但事實上設(shè)置了in-memory provisioner， 那么這個是在哪里注入的呢？

注入機(jī)制

經(jīng)過定位源代碼，我們發(fā)現(xiàn)在channel_defaults.go中，發(fā)現(xiàn)下面這段代碼：

func (c *Channel) SetDefaults(ctx context.Context) {
    if c != nil && c.Spec.Provisioner == nil {
        // The singleton may not have been set, if so ignore it and validation will reject the
        // Channel.
        if cd := ChannelDefaulterSingleton; cd != nil {
            prov, args := cd.GetDefault(c.DeepCopy())
            c.Spec.Provisioner = prov
            c.Spec.Arguments = args
        }
    }
    c.Spec.SetDefaults(ctx)
}

分析一下，我們可以看到當(dāng)c.Spec.Provisioner==nil時， 會設(shè)置默認(rèn)的Provisioner。
進(jìn)一步分析ChannelDefaulterSingleton, 我們可以在webhook中賦予了實現(xiàn)設(shè)置：

...
// Watch the default-channel-webhook ConfigMap and dynamically update the default
// ClusterChannelProvisioner.
channelDefaulter := channeldefaulter.New(logger.Desugar())
eventingv1alpha1.ChannelDefaulterSingleton = channelDefaulter
configMapWatcher.Watch(channeldefaulter.ConfigMapName, channelDefaulter.UpdateConfigMap)
...

接著分析發(fā)現(xiàn) ChannelDefaulter 實現(xiàn)了 GetDefault 方法：

// GetDefault determines the default provisioner and arguments for the provided channel.
func (cd *ChannelDefaulter) GetDefault(c *eventingv1alpha1.Channel) (*corev1.ObjectReference, *runtime.RawExtension) {
    // Because we are treating this as a singleton, be tolerant to it having not been setup at all.
    if cd == nil {
        return nil, nil
    }
    if c == nil {
        return nil, nil
    }
    config := cd.getConfig()
    if config == nil {
        return nil, nil
    }

    // TODO Don't use a single default, instead use the Channel's arguments to determine the type of
    // Channel to use (e.g. it can say whether it needs to be persistent, strictly ordered, etc.).
    dp := getDefaultProvisioner(config, c.Namespace)
    cd.logger.Info("Defaulting the ClusterChannelProvisioner", zap.Any("defaultClusterChannelProvisioner", dp))
    return dp, nil
}

并且這里是通過一個ConfigMap設(shè)置使用的默認(rèn)provisioner, 這個ConfigMap名稱為default-channel-webhook, 沒錯可以在 Knative Eventing 安裝文件中發(fā)現(xiàn)這個資源：

apiVersion: v1
data:
  default-channel-config: |
    clusterdefault:
      apiversion: eventing.knative.dev/v1alpha1
      kind: ClusterChannelProvisioner
      name: in-memory
    namespacedefaults:
      some-namespace:
        apiversion: eventing.knative.dev/v1alpha1
        kind: ClusterChannelProvisioner
        name: some-other-provisioner
kind: ConfigMap
metadata:
  name: default-channel-webhook
  namespace: knative-eventing

那么分析到此，我們梳理一下整個注入的流程：

通過上面的分析， 我們現(xiàn)在了解了默認(rèn)provisioner的注入機(jī)制， 同時我們也可以通過 webhook 修改默認(rèn)的provisioner。

上述就是小編為大家分享的Knative Eventing中Channel怎么注入默認(rèn) Provisioner了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識，歡迎關(guān)注億速云行業(yè)資訊頻道。