|
@@ -3,161 +3,161 @@ Copyright Broadcom, Inc. All Rights Reserved.
|
|
|
SPDX-License-Identifier: APACHE-2.0
|
|
|
*/}}
|
|
|
|
|
|
-{{- if .Values.indexNode.enabled }}
|
|
|
+{{- if .Values.streamingNode.enabled }}
|
|
|
apiVersion: {{ include "common.capabilities.deployment.apiVersion" . }}
|
|
|
kind: Deployment
|
|
|
metadata:
|
|
|
- name: {{ template "milvus.index-node.fullname" . }}
|
|
|
+ name: {{ template "milvus.streaming-node.fullname" . }}
|
|
|
namespace: {{ include "common.names.namespace" . | quote }}
|
|
|
labels: {{- include "common.labels.standard" ( dict "customLabels" .Values.commonLabels "context" $ ) | nindent 4 }}
|
|
|
app.kubernetes.io/part-of: milvus
|
|
|
- app.kubernetes.io/component: index-node
|
|
|
+ app.kubernetes.io/component: streaming-node
|
|
|
{{- if .Values.commonAnnotations }}
|
|
|
annotations: {{- include "common.tplvalues.render" ( dict "value" .Values.commonAnnotations "context" $ ) | nindent 4 }}
|
|
|
{{- end }}
|
|
|
spec:
|
|
|
- {{- if not .Values.indexNode.autoscaling.hpa.enabled }}
|
|
|
- replicas: {{ .Values.indexNode.replicaCount }}
|
|
|
+ {{- if not .Values.streamingNode.autoscaling.hpa.enabled }}
|
|
|
+ replicas: {{ .Values.streamingNode.replicaCount }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.updateStrategy }}
|
|
|
- strategy: {{- toYaml .Values.indexNode.updateStrategy | nindent 4 }}
|
|
|
+ {{- if .Values.streamingNode.updateStrategy }}
|
|
|
+ strategy: {{- toYaml .Values.streamingNode.updateStrategy | nindent 4 }}
|
|
|
{{- end }}
|
|
|
- {{- $podLabels := include "common.tplvalues.merge" ( dict "values" ( list .Values.indexNode.podLabels .Values.commonLabels ) "context" . ) }}
|
|
|
+ {{- $podLabels := include "common.tplvalues.merge" ( dict "values" ( list .Values.streamingNode.podLabels .Values.commonLabels ) "context" . ) }}
|
|
|
selector:
|
|
|
matchLabels: {{- include "common.labels.matchLabels" ( dict "customLabels" $podLabels "context" $ ) | nindent 6 }}
|
|
|
app.kubernetes.io/part-of: milvus
|
|
|
- app.kubernetes.io/component: index-node
|
|
|
+ app.kubernetes.io/component: streaming-node
|
|
|
template:
|
|
|
metadata:
|
|
|
annotations:
|
|
|
checksum/common-config: {{ include (print $.Template.BasePath "/configmap.yaml") . | sha256sum }}
|
|
|
checksum/common-config-extra: {{ include (print $.Template.BasePath "/extra-configmap.yaml") . | sha256sum }}
|
|
|
- checksum/config-extra: {{ include (print $.Template.BasePath "/index-node/extra-configmap.yaml") . | sha256sum }}
|
|
|
- {{- if .Values.indexNode.podAnnotations }}
|
|
|
- {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.podAnnotations "context" $) | nindent 8 }}
|
|
|
+ checksum/config-extra: {{ include (print $.Template.BasePath "/streaming-node/extra-configmap.yaml") . | sha256sum }}
|
|
|
+ {{- if .Values.streamingNode.podAnnotations }}
|
|
|
+ {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.podAnnotations "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
labels: {{- include "common.labels.standard" ( dict "customLabels" $podLabels "context" $ ) | nindent 8 }}
|
|
|
app.kubernetes.io/part-of: milvus
|
|
|
- app.kubernetes.io/component: index-node
|
|
|
+ app.kubernetes.io/component: streaming-node
|
|
|
spec:
|
|
|
enableServiceLinks: {{ .Values.enableServiceLinks }}
|
|
|
- serviceAccountName: {{ template "milvus.index-node.serviceAccountName" . }}
|
|
|
+ serviceAccountName: {{ template "milvus.streaming-node.serviceAccountName" . }}
|
|
|
{{- include "milvus.imagePullSecrets" . | nindent 6 }}
|
|
|
- automountServiceAccountToken: {{ .Values.indexNode.automountServiceAccountToken }}
|
|
|
- {{- if .Values.indexNode.hostAliases }}
|
|
|
- hostAliases: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.hostAliases "context" $) | nindent 8 }}
|
|
|
+ automountServiceAccountToken: {{ .Values.streamingNode.automountServiceAccountToken }}
|
|
|
+ {{- if .Values.streamingNode.hostAliases }}
|
|
|
+ hostAliases: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.hostAliases "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.affinity }}
|
|
|
- affinity: {{- include "common.tplvalues.render" ( dict "value" .Values.indexNode.affinity "context" $) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.affinity }}
|
|
|
+ affinity: {{- include "common.tplvalues.render" ( dict "value" .Values.streamingNode.affinity "context" $) | nindent 8 }}
|
|
|
{{- else }}
|
|
|
affinity:
|
|
|
- podAffinity: {{- include "common.affinities.pods" (dict "type" .Values.indexNode.podAffinityPreset "component" "index-node" "customLabels" $podLabels "context" $) | nindent 10 }}
|
|
|
- podAntiAffinity: {{- include "common.affinities.pods" (dict "type" .Values.indexNode.podAntiAffinityPreset "component" "index-node" "customLabels" $podLabels "context" $) | nindent 10 }}
|
|
|
- nodeAffinity: {{- include "common.affinities.nodes" (dict "type" .Values.indexNode.nodeAffinityPreset.type "key" .Values.indexNode.nodeAffinityPreset.key "values" .Values.indexNode.nodeAffinityPreset.values) | nindent 10 }}
|
|
|
+ podAffinity: {{- include "common.affinities.pods" (dict "type" .Values.streamingNode.podAffinityPreset "component" "streaming-node" "customLabels" $podLabels "context" $) | nindent 10 }}
|
|
|
+ podAntiAffinity: {{- include "common.affinities.pods" (dict "type" .Values.streamingNode.podAntiAffinityPreset "component" "streaming-node" "customLabels" $podLabels "context" $) | nindent 10 }}
|
|
|
+ nodeAffinity: {{- include "common.affinities.nodes" (dict "type" .Values.streamingNode.nodeAffinityPreset.type "key" .Values.streamingNode.nodeAffinityPreset.key "values" .Values.streamingNode.nodeAffinityPreset.values) | nindent 10 }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.nodeSelector }}
|
|
|
- nodeSelector: {{- include "common.tplvalues.render" ( dict "value" .Values.indexNode.nodeSelector "context" $) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.nodeSelector }}
|
|
|
+ nodeSelector: {{- include "common.tplvalues.render" ( dict "value" .Values.streamingNode.nodeSelector "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.tolerations }}
|
|
|
- tolerations: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.tolerations "context" .) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.tolerations }}
|
|
|
+ tolerations: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.tolerations "context" .) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.runtimeClassName }}
|
|
|
- runtimeClassName: {{ .Values.indexNode.runtimeClassName | quote }}
|
|
|
+ {{- if .Values.streamingNode.runtimeClassName }}
|
|
|
+ runtimeClassName: {{ .Values.streamingNode.runtimeClassName | quote }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.topologySpreadConstraints }}
|
|
|
- topologySpreadConstraints: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.topologySpreadConstraints "context" .) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.topologySpreadConstraints }}
|
|
|
+ topologySpreadConstraints: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.topologySpreadConstraints "context" .) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.priorityClassName }}
|
|
|
- priorityClassName: {{ .Values.indexNode.priorityClassName | quote }}
|
|
|
+ {{- if .Values.streamingNode.priorityClassName }}
|
|
|
+ priorityClassName: {{ .Values.streamingNode.priorityClassName | quote }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.schedulerName }}
|
|
|
- schedulerName: {{ .Values.indexNode.schedulerName }}
|
|
|
+ {{- if .Values.streamingNode.schedulerName }}
|
|
|
+ schedulerName: {{ .Values.streamingNode.schedulerName }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.podSecurityContext.enabled }}
|
|
|
- securityContext: {{- include "common.compatibility.renderSecurityContext" (dict "secContext" .Values.indexNode.podSecurityContext "context" $) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.podSecurityContext.enabled }}
|
|
|
+ securityContext: {{- include "common.compatibility.renderSecurityContext" (dict "secContext" .Values.streamingNode.podSecurityContext "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
initContainers:
|
|
|
- {{- if .Values.indexNode.enableDefaultInitContainers }}
|
|
|
+ {{- if .Values.streamingNode.enableDefaultInitContainers }}
|
|
|
{{- include "milvus.waitForETCDInitContainer" . | nindent 8 }}
|
|
|
{{- include "milvus.waitForKafkaInitContainer" . | nindent 8 }}
|
|
|
{{- include "milvus.waitForS3InitContainer" . | nindent 8 }}
|
|
|
- {{- include "milvus.prepareMilvusInitContainer" (dict "component" "indexNode" "context" $) | nindent 8 }}
|
|
|
+ {{- include "milvus.prepareMilvusInitContainer" (dict "component" "streamingNode" "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.initContainers }}
|
|
|
- {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.initContainers "context" $) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.initContainers }}
|
|
|
+ {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.initContainers "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
containers:
|
|
|
- name: milvus
|
|
|
image: {{ template "milvus.image" . }}
|
|
|
imagePullPolicy: {{ .Values.milvus.image.pullPolicy }}
|
|
|
- {{- if .Values.indexNode.containerSecurityContext.enabled }}
|
|
|
- securityContext: {{- include "common.compatibility.renderSecurityContext" (dict "secContext" .Values.indexNode.containerSecurityContext "context" $) | nindent 12 }}
|
|
|
+ {{- if .Values.streamingNode.containerSecurityContext.enabled }}
|
|
|
+ securityContext: {{- include "common.compatibility.renderSecurityContext" (dict "secContext" .Values.streamingNode.containerSecurityContext "context" $) | nindent 12 }}
|
|
|
{{- end }}
|
|
|
{{- if .Values.diagnosticMode.enabled }}
|
|
|
command: {{- include "common.tplvalues.render" (dict "value" .Values.diagnosticMode.command "context" $) | nindent 12 }}
|
|
|
- {{- else if .Values.indexNode.command }}
|
|
|
- command: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.command "context" $) | nindent 12 }}
|
|
|
+ {{- else if .Values.streamingNode.command }}
|
|
|
+ command: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.command "context" $) | nindent 12 }}
|
|
|
{{- end }}
|
|
|
{{- if .Values.diagnosticMode.enabled }}
|
|
|
args: {{- include "common.tplvalues.render" (dict "value" .Values.diagnosticMode.args "context" $) | nindent 12 }}
|
|
|
- {{- else if .Values.indexNode.args }}
|
|
|
- args: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.args "context" $) | nindent 12 }}
|
|
|
+ {{- else if .Values.streamingNode.args }}
|
|
|
+ args: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.args "context" $) | nindent 12 }}
|
|
|
{{- else }}
|
|
|
args:
|
|
|
- run
|
|
|
- - indexnode
|
|
|
+ - streamingnode
|
|
|
{{- end }}
|
|
|
env:
|
|
|
- name: METRICS_PORT
|
|
|
- value: {{ .Values.indexNode.containerPorts.metrics | quote }}
|
|
|
- {{- if .Values.indexNode.extraEnvVars }}
|
|
|
- {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.extraEnvVars "context" $) | nindent 12 }}
|
|
|
+ value: {{ .Values.streamingNode.containerPorts.metrics | quote }}
|
|
|
+ {{- if .Values.streamingNode.extraEnvVars }}
|
|
|
+ {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.extraEnvVars "context" $) | nindent 12 }}
|
|
|
{{- end }}
|
|
|
envFrom:
|
|
|
- {{- if .Values.indexNode.extraEnvVarsCM }}
|
|
|
+ {{- if .Values.streamingNode.extraEnvVarsCM }}
|
|
|
- configMapRef:
|
|
|
- name: {{ include "common.tplvalues.render" (dict "value" .Values.indexNode.extraEnvVarsCM "context" $) }}
|
|
|
+ name: {{ include "common.tplvalues.render" (dict "value" .Values.streamingNode.extraEnvVarsCM "context" $) }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.extraEnvVarsSecret }}
|
|
|
+ {{- if .Values.streamingNode.extraEnvVarsSecret }}
|
|
|
- secretRef:
|
|
|
- name: {{ include "common.tplvalues.render" (dict "value" .Values.indexNode.extraEnvVarsSecret "context" $) }}
|
|
|
+ name: {{ include "common.tplvalues.render" (dict "value" .Values.streamingNode.extraEnvVarsSecret "context" $) }}
|
|
|
{{- end }}
|
|
|
ports:
|
|
|
- - containerPort: {{ .Values.indexNode.containerPorts.grpc }}
|
|
|
+ - containerPort: {{ .Values.streamingNode.containerPorts.grpc }}
|
|
|
name: grpc
|
|
|
- - containerPort: {{ .Values.indexNode.containerPorts.metrics }}
|
|
|
+ - containerPort: {{ .Values.streamingNode.containerPorts.metrics }}
|
|
|
name: http-metrics
|
|
|
- {{- if .Values.indexNode.resources }}
|
|
|
- resources: {{- toYaml .Values.indexNode.resources | nindent 12 }}
|
|
|
- {{- else if ne .Values.indexNode.resourcesPreset "none" }}
|
|
|
- resources: {{- include "common.resources.preset" (dict "type" .Values.indexNode.resourcesPreset) | nindent 12 }}
|
|
|
+ {{- if .Values.streamingNode.resources }}
|
|
|
+ resources: {{- toYaml .Values.streamingNode.resources | nindent 12 }}
|
|
|
+ {{- else if ne .Values.streamingNode.resourcesPreset "none" }}
|
|
|
+ resources: {{- include "common.resources.preset" (dict "type" .Values.streamingNode.resourcesPreset) | nindent 12 }}
|
|
|
{{- end }}
|
|
|
{{- if not .Values.diagnosticMode.enabled }}
|
|
|
- {{- if .Values.indexNode.customLivenessProbe }}
|
|
|
- livenessProbe: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.customLivenessProbe "context" $) | nindent 12 }}
|
|
|
- {{- else if .Values.indexNode.livenessProbe.enabled }}
|
|
|
- livenessProbe: {{- include "common.tplvalues.render" (dict "value" (omit .Values.indexNode.livenessProbe "enabled") "context" $) | nindent 12 }}
|
|
|
+ {{- if .Values.streamingNode.customLivenessProbe }}
|
|
|
+ livenessProbe: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.customLivenessProbe "context" $) | nindent 12 }}
|
|
|
+ {{- else if .Values.streamingNode.livenessProbe.enabled }}
|
|
|
+ livenessProbe: {{- include "common.tplvalues.render" (dict "value" (omit .Values.streamingNode.livenessProbe "enabled") "context" $) | nindent 12 }}
|
|
|
tcpSocket:
|
|
|
port: http-metrics
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.customReadinessProbe }}
|
|
|
- readinessProbe: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.customReadinessProbe "context" $) | nindent 12 }}
|
|
|
- {{- else if .Values.indexNode.readinessProbe.enabled }}
|
|
|
- readinessProbe: {{- include "common.tplvalues.render" (dict "value" (omit .Values.indexNode.readinessProbe "enabled") "context" $) | nindent 12 }}
|
|
|
+ {{- if .Values.streamingNode.customReadinessProbe }}
|
|
|
+ readinessProbe: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.customReadinessProbe "context" $) | nindent 12 }}
|
|
|
+ {{- else if .Values.streamingNode.readinessProbe.enabled }}
|
|
|
+ readinessProbe: {{- include "common.tplvalues.render" (dict "value" (omit .Values.streamingNode.readinessProbe "enabled") "context" $) | nindent 12 }}
|
|
|
httpGet:
|
|
|
path: /healthz
|
|
|
port: http-metrics
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.customStartupProbe }}
|
|
|
- startupProbe: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.customStartupProbe "context" $) | nindent 12 }}
|
|
|
- {{- else if .Values.indexNode.startupProbe.enabled }}
|
|
|
- startupProbe: {{- include "common.tplvalues.render" (dict "value" (omit .Values.indexNode.startupProbe "enabled") "context" $) | nindent 12 }}
|
|
|
+ {{- if .Values.streamingNode.customStartupProbe }}
|
|
|
+ startupProbe: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.customStartupProbe "context" $) | nindent 12 }}
|
|
|
+ {{- else if .Values.streamingNode.startupProbe.enabled }}
|
|
|
+ startupProbe: {{- include "common.tplvalues.render" (dict "value" (omit .Values.streamingNode.startupProbe "enabled") "context" $) | nindent 12 }}
|
|
|
tcpSocket:
|
|
|
port: http-metrics
|
|
|
{{- end }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.lifecycleHooks }}
|
|
|
- lifecycle: {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.lifecycleHooks "context" $) | nindent 12 }}
|
|
|
+ {{- if .Values.streamingNode.lifecycleHooks }}
|
|
|
+ lifecycle: {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.lifecycleHooks "context" $) | nindent 12 }}
|
|
|
{{- end }}
|
|
|
volumeMounts:
|
|
|
- name: empty-dir
|
|
@@ -188,11 +188,11 @@ spec:
|
|
|
mountPath: /opt/bitnami/milvus/configs/cert/minio/client
|
|
|
readOnly: true
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.extraVolumeMounts }}
|
|
|
- {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.extraVolumeMounts "context" $) | nindent 12 }}
|
|
|
+ {{- if .Values.streamingNode.extraVolumeMounts }}
|
|
|
+ {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.extraVolumeMounts "context" $) | nindent 12 }}
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.sidecars }}
|
|
|
- {{- include "common.tplvalues.render" ( dict "value" .Values.indexNode.sidecars "context" $) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.sidecars }}
|
|
|
+ {{- include "common.tplvalues.render" ( dict "value" .Values.streamingNode.sidecars "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
volumes:
|
|
|
- name: empty-dir
|
|
@@ -224,11 +224,11 @@ spec:
|
|
|
{{- end }}
|
|
|
- name: component-config-default
|
|
|
configMap:
|
|
|
- name: {{ template "milvus.index-node.configmapName" . }}
|
|
|
- {{- if or .Values.indexNode.extraConfig .Values.indexNode.extraConfigExistingConfigMap }}
|
|
|
+ name: {{ template "milvus.streaming-node.configmapName" . }}
|
|
|
+ {{- if or .Values.streamingNode.extraConfig .Values.streamingNode.extraConfigExistingConfigMap }}
|
|
|
- name: component-extra-config
|
|
|
configMap:
|
|
|
- name: {{ template "milvus.index-node.extraConfigmapName" . }}
|
|
|
+ name: {{ template "milvus.streaming-node.extraConfigmapName" . }}
|
|
|
{{- end }}
|
|
|
{{- if and (not .Values.etcd.enabled) .Values.externalEtcd.tls.enabled .Values.externalEtcd.tls.existingSecret }}
|
|
|
- name: etcd-client-certs
|
|
@@ -248,7 +248,7 @@ spec:
|
|
|
secretName: {{ .Values.externalS3.tls.existingSecret }}
|
|
|
defaultMode: 256
|
|
|
{{- end }}
|
|
|
- {{- if .Values.indexNode.extraVolumes }}
|
|
|
- {{- include "common.tplvalues.render" (dict "value" .Values.indexNode.extraVolumes "context" $) | nindent 8 }}
|
|
|
+ {{- if .Values.streamingNode.extraVolumes }}
|
|
|
+ {{- include "common.tplvalues.render" (dict "value" .Values.streamingNode.extraVolumes "context" $) | nindent 8 }}
|
|
|
{{- end }}
|
|
|
{{- end }}
|