}

func newClientV7(args ElasticsearchArgs) (*esClientV7, error) {
	// Client options
	elasticConfig := elasticsearch7.Config{
		Addresses:  []string{args.URL.String()},
		Transport:  args.Transport,
		MaxRetries: 10,
	}
	// Set basic auth
	if args.Username != "" && args.Password != "" {
		elasticConfig.Username = args.Username
		elasticConfig.Password = args.Password
	}
	// Create a client

}

func (target *NSQTarget) initNSQ() error {
	args := target.args

	config := nsq.NewConfig()
	if args.TLS.Enable {
		config.TlsV1 = true
		config.TlsConfig = &tls.Config{
			InsecureSkipVerify: args.TLS.SkipVerify,
		}
	}
	target.config = config

	producer, err := nsq.NewProducer(args.NSQDAddress.String(), config)
	if err != nil {

	// * an error on failure of lock request operation.
	RLock(ctx context.Context, args LockArgs) (bool, error)

	// Do write lock for given LockArgs. It should return
	// * a boolean to indicate success/failure of the operation
	// * an error on failure of lock request operation.
	Lock(ctx context.Context, args LockArgs) (bool, error)

	// Do read unlock for given LockArgs. It should return

path: CAs/public.crt {{ end }} containers: - name: minio-mc image: "{{ .Values.mcImage.repository }}:{{ .Values.mcImage.tag }}" imagePullPolicy: {{ .Values.mcImage.pullPolicy }} {{- if .Values.makeBucketJob.exitCommand }} command: ["/bin/sh", "-c"] args: ["/bin/sh /config/initialize; x=$(echo $?); {{ .Values.makeBucketJob.exitCommand }} && exit $x" ] {{- else }} command: ["/bin/sh", "/config/initialize"] {{- end }} env: - name: MINIO_ENDPOINT value: {{ template "minio.fullname" . }} - name: MINIO_PORT...

path: CAs/public.crt {{ end }} containers: - name: minio-mc image: "{{ .Values.mcImage.repository }}:{{ .Values.mcImage.tag }}" imagePullPolicy: {{ .Values.mcImage.pullPolicy }} {{- if .Values.makeBucketJob.exitCommand }} command: ["/bin/sh", "-c"] args: ["/bin/sh /config/initialize; x=$(echo $?); {{ .Values.makeBucketJob.exitCommand }} && exit $x" ] {{- else }} command: ["/bin/sh", "/config/initialize"] {{- end }} env: - name: MINIO_ENDPOINT value: {{ template "minio.fullname" . }} - name: MINIO_PORT...

.Values.serviceAccount.name }} {{- end }} containers: - name: minio-mc image: "{{ .Values.mcImage.repository }}:{{ .Values.mcImage.tag }}" imagePullPolicy: {{ .Values.mcImage.pullPolicy }} {{- if .Values.makeBucketJob.exitCommand }} command: ["/bin/sh", "-c"] args: ["/bin/sh /config/initialize; x=$(echo $?); {{ .Values.makeBucketJob.exitCommand }} && exit $x" ] {{- else }} command: ["/bin/sh", "/config/initialize"] {{- end }} env: - name: MINIO_ENDPOINT value: {{ template "minio.fullname" . }} - name: MINIO_PORT...

.Values.serviceAccount.name }} {{- end }} containers: - name: minio-mc image: "{{ .Values.mcImage.repository }}:{{ .Values.mcImage.tag }}" imagePullPolicy: {{ .Values.mcImage.pullPolicy }} {{- if .Values.makeBucketJob.exitCommand }} command: ["/bin/sh", "-c"] args: ["/bin/sh /config/initialize; x=$(echo $?); {{ .Values.makeBucketJob.exitCommand }} && exit $x" ] {{- else }} command: ["/bin/sh", "/config/initialize"] {{- end }} env: - name: MINIO_ENDPOINT value: {{ template "minio.fullname" . }} - name: MINIO_PORT...

function start_minio_3_node() {
	export MINIO_ROOT_USER=minio
	export MINIO_ROOT_PASSWORD=minio123
	export MINIO_ERASURE_SET_DRIVE_COUNT=6
	export MINIO_CI_CD=1

	start_port=$2
	args=""
	for i in $(seq 1 3); do

console-address: ":9001"
certs-dir: "/home/user/.minio/certs/"
pools: # Specify the nodes and drives with pools
  - args:
      - "https://server-example-pool1:9000/mnt/disk{1...4}/"
      - "https://server{1...2}-pool1:9000/mnt/disk{1...4}/"
      - "https://server3-pool1:9000/mnt/disk{1...4}/"
      - "https://server4-pool1:9000/mnt/disk{1...4}/"
  - args:
      - "https://server-example-pool2:9000/mnt/disk{1...4}/"

	unset MINIO_KMS_AUTO_ENCRYPTION # do not auto-encrypt objects
	unset MINIO_CI_CD
	unset CI

	args=()
	for i in $(seq 1 4); do
		args+=("http://localhost:$((start_port + i))${WORK_DIR}/mnt/disk$i/ ")
	done

	for i in $(seq 1 4); do
		"${MINIO[@]}" --address ":$((start_port + i))" ${args[@]} 2>&1 >"${WORK_DIR}/server$i.log" &
	done

	# Wait until all nodes return 403
	for i in $(seq 1 4); do