Implement client metrics interceptor for continuous benchmark job (#2477

) (#2480)

* ♻️ Mount benchmark-operator-config to vald-benchmark-job Pod



* 📈 add framework for send gRPC client metrics



* style: format code with Gofumpt and Prettier

This commit fixes the style issues introduced in a532b7d according to the output
from Gofumpt and Prettier.

Details: #2477

* 📈 Add client metric interceptor



* ♻️ Change vbor chart for apply general job configuration



* Update pkg/tools/benchmark/job/usecase/benchmarkd.go




* 🐛 Fix build error and add comment



* ♻️ Fix format



---------

Signed-off-by: vankichi <[email protected]>
Signed-off-by: Kiichiro YUKAWA <[email protected]>
Co-authored-by: Kiichiro YUKAWA <[email protected]>
Co-authored-by: deepsource-autofix[bot] <62050782+deepsource-autofix[bot]@users.noreply.github.com>
Co-authored-by: Hiroto Funakoshi <[email protected]>

charts/vald-benchmark-operator/crds/valdbenchmarkoperatorrelease.yaml

@@ -86,19 +86,197 @@ spec:
                       type: string
                     tag:
                       type: string
-                job_image:
+                job:
                   type: object
                   properties:
-                    pullPolicy:
-                      type: string
-                      enum:
-                        - Always
-                        - Never
-                        - IfNotPresent
-                    repository:
-                      type: string
-                    tag:
-                      type: string
+                    client_config:
+                      type: object
+                      properties:
+                        addrs:
+                          type: array
+                          items:
+                            type: string
+                        backoff:
+                          type: object
+                          properties:
+                            backoff_factor:
+                              type: number
+                            backoff_time_limit:
+                              type: string
+                            enable_error_log:
+                              type: boolean
+                            initial_duration:
+                              type: string
+                            jitter_limit:
+                              type: string
+                            maximum_duration:
+                              type: string
+                            retry_count:
+                              type: integer
+                        call_option:
+                          type: object
+                          x-kubernetes-preserve-unknown-fields: true
+                        circuit_breaker:
+                          type: object
+                          properties:
+                            closed_error_rate:
+                              type: number
+                            closed_refresh_timeout:
+                              type: string
+                            half_open_error_rate:
+                              type: number
+                            min_samples:
+                              type: integer
+                            open_timeout:
+                              type: string
+                        connection_pool:
+                          type: object
+                          properties:
+                            enable_dns_resolver:
+                              type: boolean
+                            enable_rebalance:
+                              type: boolean
+                            old_conn_close_duration:
+                              type: string
+                            rebalance_duration:
+                              type: string
+                            size:
+                              type: integer
+                        dial_option:
+                          type: object
+                          properties:
+                            backoff_base_delay:
+                              type: string
+                            backoff_jitter:
+                              type: number
+                            backoff_max_delay:
+                              type: string
+                            backoff_multiplier:
+                              type: number
+                            enable_backoff:
+                              type: boolean
+                            initial_connection_window_size:
+                              type: integer
+                            initial_window_size:
+                              type: integer
+                            insecure:
+                              type: boolean
+                            interceptors:
+                              type: array
+                              items:
+                                type: string
+                                enum:
+                                  - TraceInterceptor
+                            keepalive:
+                              type: object
+                              properties:
+                                permit_without_stream:
+                                  type: boolean
+                                time:
+                                  type: string
+                                timeout:
+                                  type: string
+                            max_msg_size:
+                              type: integer
+                            min_connection_timeout:
+                              type: string
+                            net:
+                              type: object
+                              properties:
+                                dialer:
+                                  type: object
+                                  properties:
+                                    dual_stack_enabled:
+                                      type: boolean
+                                    keepalive:
+                                      type: string
+                                    timeout:
+                                      type: string
+                                dns:
+                                  type: object
+                                  properties:
+                                    cache_enabled:
+                                      type: boolean
+                                    cache_expiration:
+                                      type: string
+                                    refresh_duration:
+                                      type: string
+                                socket_option:
+                                  type: object
+                                  properties:
+                                    ip_recover_destination_addr:
+                                      type: boolean
+                                    ip_transparent:
+                                      type: boolean
+                                    reuse_addr:
+                                      type: boolean
+                                    reuse_port:
+                                      type: boolean
+                                    tcp_cork:
+                                      type: boolean
+                                    tcp_defer_accept:
+                                      type: boolean
+                                    tcp_fast_open:
+                                      type: boolean
+                                    tcp_no_delay:
+                                      type: boolean
+                                    tcp_quick_ack:
+                                      type: boolean
+                                tls:
+                                  type: object
+                                  properties:
+                                    ca:
+                                      type: string
+                                    cert:
+                                      type: string
+                                    enabled:
+                                      type: boolean
+                                    insecure_skip_verify:
+                                      type: boolean
+                                    key:
+                                      type: string
+                            read_buffer_size:
+                              type: integer
+                            timeout:
+                              type: string
+                            write_buffer_size:
+                              type: integer
+                        health_check_duration:
+                          type: string
+                        max_recv_msg_size:
+                          type: integer
+                        max_retry_rpc_buffer_size:
+                          type: integer
+                        max_send_msg_size:
+                          type: integer
+                        tls:
+                          type: object
+                          properties:
+                            ca:
+                              type: string
+                            cert:
+                              type: string
+                            enabled:
+                              type: boolean
+                            insecure_skip_verify:
+                              type: boolean
+                            key:
+                              type: string
+                        wait_for_ready:
+                          type: boolean
+                    image:
+                      type: object
+                      properties:
+                        pullPolicy:
+                          type: string
+                          enum:
+                            - Always
+                            - Never
+                            - IfNotPresent
+                        repository:
+                          type: string
+                        tag:
+                          type: string
                 logging:
                   type: object
                   properties:

charts/vald-benchmark-operator/templates/configmap.yaml

@@ -38,6 +38,5 @@ data:
     observability:
       {{- $observability := dict "Values" .Values.observability}}
       {{- include "vald.observability" $observability | nindent 6 }}
-    job_image:
-      image: "{{ .Values.job_image.repository }}:{{ .Values.job_image.tag }}"
-      pullPolicy: {{ .Values.job_image.pullPolicy }}
+    job:
+      {{- toYaml .Values.job | nindent 6 }}