Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 313 for Join (0.18 sec)

  1. cmd/http-tracer.go

    		reqHeaders.Set("Host", r.Host)
    		if len(r.TransferEncoding) == 0 {
    			reqHeaders.Set("Content-Length", strconv.Itoa(int(r.ContentLength)))
    		} else {
    			reqHeaders.Set("Transfer-Encoding", strings.Join(r.TransferEncoding, ","))
    		}
    		inputBytes := reqRecorder.Size()
    		for k, v := range reqHeaders {
    			inputBytes += len(k) + len(v)
    		}
    
    		// Calculate node name
    		nodeName := r.Host
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

                final InputStreamThread it = jobProcess.getInputStreamThread();
                it.start();
    
                final Process currentProcess = jobProcess.getProcess();
                currentProcess.waitFor();
                it.join(5000);
    
                final int exitValue = currentProcess.exitValue();
    
                if (logger.isInfoEnabled()) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/job/SuggestJob.java

                final InputStreamThread it = jobProcess.getInputStreamThread();
                it.start();
    
                final Process currentProcess = jobProcess.getProcess();
                currentProcess.waitFor();
                it.join(5000);
    
                final int exitValue = currentProcess.exitValue();
    
                if (logger.isInfoEnabled()) {
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sun Jun 23 04:13:47 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. scan.go

    			continue
    		}
    
    		if len(joinFields) == 0 || len(joinFields[idx]) == 0 {
    			db.AddError(field.Set(db.Statement.Context, reflectValue, values[idx]))
    		} else { // joinFields count is larger than 2 when using join
    			var isNilPtrValue bool
    			var relValue reflect.Value
    			// does not contain raw dbname
    			nestedJoinSchemas := joinFields[idx][:len(joinFields[idx])-1]
    			// current reflect value
    			currentReflectValue := reflectValue
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  5. internal/event/target/webhook.go

    	ctx, cancel := context.WithCancel(ctx)
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-webhook-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			cancel()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. internal/crypto/sse-s3.go

    	if err != nil {
    		return key, err
    	}
    	unsealKey, err := k.Decrypt(context.TODO(), &kms.DecryptRequest{
    		Name:           keyID,
    		Ciphertext:     kmsKey,
    		AssociatedData: kms.Context{bucket: path.Join(bucket, object)},
    	})
    	if err != nil {
    		return key, err
    	}
    	err = key.Unseal(unsealKey, sealedKey, s3.String(), bucket, object)
    	return key, err
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. schema/utils.go

    					names[i] = ""
    				} else {
    					break
    				}
    			}
    		}
    
    		values := strings.Split(names[j], ":")
    		k := strings.TrimSpace(strings.ToUpper(values[0]))
    
    		if len(values) >= 2 {
    			settings[k] = strings.Join(values[1:], ":")
    		} else if k != "" {
    			settings[k] = k
    		}
    	}
    
    	return settings
    }
    
    func toColumns(val string) (results []string) {
    	if val != "" {
    		for _, v := range strings.Split(val, ",") {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Sat Aug 19 13:35:14 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  8. helm/minio/templates/deployment.yaml

                  value: {{ .Values.oidc.displayName }}
                {{- end }}
                {{- if .Values.etcd.endpoints }}
                - name: MINIO_ETCD_ENDPOINTS
                  value: {{ join "," .Values.etcd.endpoints | quote }}
                {{- if .Values.etcd.clientCert }}
                - name: MINIO_ETCD_CLIENT_CERT
                  value: "/tmp/credentials/etcd_client_cert.pem"
                {{- end }}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Oct 10 15:48:31 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  9. cmd/encryption-v1.go

    		if err != nil {
    			return err
    		}
    		oldKey, err := GlobalKMS.Decrypt(ctx, &kms.DecryptRequest{
    			Name:           keyID,
    			Ciphertext:     kmsKey,
    			AssociatedData: kms.Context{bucket: path.Join(bucket, object)},
    		})
    		if err != nil {
    			return err
    		}
    		var objectKey crypto.ObjectKey
    		if err = objectKey.Unseal(oldKey, sealedKey, crypto.S3.String(), bucket, object); err != nil {
    			return err
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Oct 13 13:06:08 UTC 2024
    - 37.2K bytes
    - Viewed (0)
  10. internal/logger/logrotate.go

    			stdErrEnc.Encode(&log.Entry{
    				Level:   ErrorKind,
    				Message: msg,
    				Time:    time.Now().UTC(),
    				Trace:   &log.Trace{Message: msg},
    			})
    		}
    	}
    
    	path := filepath.Join(w.opts.Directory, w.opts.FileNameFunc())
    	f, err := newFile(path)
    	if err != nil {
    		return fmt.Errorf("unable to create new file at %v: %w", path, err)
    	}
    
    	w.f = f
    
    	return nil
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.8K bytes
    - Viewed (0)
Back to top