Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 181 - 190 of 594 for joins (0.03 seconds)

  1. internal/event/target/postgresql.go

    		}
    		if args.Database != "" {
    			params = append(params, "dbname="+args.Database)
    		}
    	}
    	connStr := strings.Join(params, " ")
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-postgresql-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  2. build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/NullabilityBreakingChangesRule.groovy

            if (!errors.isEmpty()) {
                def changes = errors + warnings
                return acceptOrReject(member, changes, Violation.error(member, changes.join(" ")))
            }
            if (!warnings.isEmpty()) {
                return Violation.warning(member, warnings.join(" "))
            }
            return null
        }
    
        private static List<Boolean> typeParametersNullabilityOf(CtClass ctClass) {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Oct 27 09:26:32 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  3. internal/crypto/sse-kms.go

    	}
    
    	keyID, kmsKey, sealedKey, ctx, err := s3.ParseMetadata(metadata)
    	if err != nil {
    		return key, err
    	}
    	if ctx == nil {
    		ctx = kms.Context{bucket: path.Join(bucket, object)}
    	} else if _, ok := ctx[bucket]; !ok {
    		ctx[bucket] = path.Join(bucket, object)
    	}
    	unsealKey, err := k.Decrypt(context.TODO(), &kms.DecryptRequest{
    		Name:           keyID,
    		Ciphertext:     kmsKey,
    		AssociatedData: ctx,
    	})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 07 23:55:37 GMT 2024
    - 8.5K bytes
    - Click Count (0)
  4. ci/official/utilities/extract_resultstore_links.py

            tests_failed = False
          else:
            tests_failed = re.search(TESTS_FAILED_RE, backtrack_line)
          if build_failed or tests_failed:
            log_fragment = '\n'.join(
                log_lines[max(k - 20, 0):min(end_line + 1, len(log_lines) - 1)])
            lines['log_fragment'] = log_fragment
            lines['status'] = (InvokeStatus.build_failed if build_failed
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Wed Nov 08 17:50:27 GMT 2023
    - 10.9K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb1/smb1/TestLocking.java

                }
                //System.out.println("numComplete=" + t.numComplete + ",numThreads=" + t.numThreads);
            }
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti].join();
                logger.info(threads[ti].getName());
            }
    
            logger.info("Test completed");
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/net/HttpHeadersTest.java

          if (!uppercaseAcronyms.contains(part)) {
            part = part.charAt(0) + Ascii.toLowerCase(part.substring(1));
          }
          parts.add(part);
        }
        return Joiner.on('-').join(parts);
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 20:10:09 GMT 2026
    - 4.1K bytes
    - Click Count (0)
  7. tests/main.py

    def get_enum_status_code():
        return "foo bar"
    
    
    @app.get("/query/frozenset")
    def get_query_type_frozenset(query: frozenset[int] = Query(...)):
        return ",".join(map(str, sorted(query)))
    
    
    @app.get("/query/list")
    def get_query_list(device_ids: list[int] = Query()) -> list[int]:
        return device_ids
    
    
    @app.get("/query/list-default")
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Tue Feb 17 09:59:14 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  8. docs/fr/docs/benchmarks.md

        * A les meilleures performances, étant donné qu'il n'a pas beaucoup de code mis à part le serveur en lui‑même.
        * On n'écrit pas une application directement avec Uvicorn. Cela signifie que le code devrait inclure, au minimum, plus ou moins tout le code offert par Starlette (ou **FastAPI**). Et si on fait cela, l'application finale aura la même surcharge que si on avait utilisé un framework, tout en minimisant la quantité de code et les bugs.
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 4.1K bytes
    - Click Count (0)
  9. cmd/iam-object-store.go

    	data, err := json.Marshal(item)
    	if err != nil {
    		return err
    	}
    	if GlobalKMS != nil {
    		data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{
    			minioMetaBucket: path.Join(minioMetaBucket, objPath),
    		})
    		if err != nil {
    			return err
    		}
    	}
    	return saveConfig(ctx, iamOS.objAPI, objPath, data)
    }
    
    func decryptData(data []byte, objPath string) ([]byte, error) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  10. build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsTask.java

                .collect(Collectors.toList());
    
            if (failures.isEmpty() == false) {
                throw new GradleException("Found invalid file permissions:\n" + String.join("\n", failures));
            }
    
            outputMarker.getParentFile().mkdirs();
            Files.write(outputMarker.toPath(), "done".getBytes("UTF-8"));
        }
    
        @OutputFile
        public File getOutputMarker() {
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Tue Jun 01 09:19:30 GMT 2021
    - 3.9K bytes
    - Click Count (0)
Back to Top