Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 475 for selbst (0.05 seconds)

  1. src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java

                request.addSystemMessage("You are a strict relevance evaluator. "
                        + "Select ONLY documents that DIRECTLY address the user's specific question topic. "
                        + "Do NOT select documents about different or merely related topics. "
                        + "Do NOT select table-of-contents or index pages that lack substantive content. "
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 72K bytes
    - Click Count (0)
  2. cmd/endpoint.go

    		// Retry infinitely on Kubernetes and Docker swarm.
    		// This is needed as the remote hosts are sometime
    		// not available immediately.
    		select {
    		case <-globalOSSignalCh:
    			return fmt.Errorf("The endpoint resolution got interrupted")
    		default:
    			for i, resolved := range resolvedList {
    				if resolved {
    					// Continue if host is already resolved.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  3. cmd/xl-storage-disk-id-check.go

    		dctx, dcancel := context.WithCancel(ctx)
    		started := time.Now()
    		go func() {
    			timeout := time.NewTimer(globalDriveConfig.GetMaxTimeout())
    			select {
    			case <-dctx.Done():
    				if !timeout.Stop() {
    					<-timeout.C
    				}
    			case <-timeout.C:
    				spent := time.Since(started)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  4. internal/config/identity/plugin/config.go

    	healthCheckTimeout  = 5 * time.Second
    )
    
    func (o *AuthNPlugin) doPeriodicHealthCheck() {
    	ticker := time.NewTicker(healthCheckInterval)
    	defer ticker.Stop()
    
    	for {
    		select {
    		case <-ticker.C:
    			now := time.Now()
    			isConnected := o.checkConnectivity(o.shutdownCtx)
    			if isConnected {
    				o.serviceMetrics.setConnSuccess(now)
    			} else {
    				o.serviceMetrics.setConnFailure(now)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  5. compat/maven-embedder/src/main/java/org/fusesource/jansi/Ansi.java

                return value + 100;
            }
        }
    
        /**
         * Display attributes, also known as
         * <a href="https://en.wikipedia.org/wiki/ANSI_escape_code#SGR_(Select_Graphic_Rendition)_parameters">SGR
         * (Select Graphic Rendition) parameters</a>.
         */
        public enum Attribute {
            RESET(0, "RESET"),
            INTENSITY_BOLD(1, "INTENSITY_BOLD"),
            INTENSITY_FAINT(2, "INTENSITY_FAINT"),
            ITALIC(3, "ITALIC_ON"),
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Sat Apr 05 11:52:05 GMT 2025
    - 23.1K bytes
    - Click Count (0)
  6. association.go

    			selectedSaveColumns = append(selectedSaveColumns, ref.ForeignKey.Name)
    		}
    	}
    
    	associationDB := association.DB.Session(&Session{}).Model(nil)
    	if !association.DB.FullSaveAssociations {
    		associationDB.Select(selectedSaveColumns)
    	}
    	if len(omitColumns) > 0 {
    		associationDB.Omit(omitColumns...)
    	}
    	associationDB = associationDB.Session(&Session{})
    
    	switch reflectValue.Kind() {
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sun Oct 26 12:09:12 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  7. docs/tr/docs/tutorial/sql-databases.md

    ### Hero’ları Okuma { #read-heroes }
    
    `select()` kullanarak veritabanından `Hero`’ları **okuyabiliriz**. Sonuçları sayfalama (pagination) yapmak için `limit` ve `offset` ekleyebiliriz.
    
    {* ../../docs_src/sql_databases/tutorial001_an_py310.py ln[48:55] hl[51:52,54] *}
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 07:53:17 GMT 2026
    - 16.8K bytes
    - Click Count (0)
  8. internal/kms/config.go

    		// when MinIO restarts
    		go func() {
    			timer := time.NewTicker(10 * time.Second)
    			defer timer.Stop()
    			defaultKey := env.Get(EnvKESDefaultKey, "")
    			for {
    				select {
    				case <-ctx.Done():
    					return
    				case <-timer.C:
    					client.DescribeKey(ctx, defaultKey)
    				}
    			}
    		}()
    
    		return &KMS{
    			Type:       MinKES,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb/SmbSessionImpl.java

        }
    
        <T extends CommonServerMessageBlockResponse> T send(CommonServerMessageBlockRequest request, T response, Set<RequestParam> params)
                throws CIFSException {
            // Select appropriate transport (multi-channel if available)
            try (SmbTransportImpl trans = selectTransport(request)) {
                if (response != null) {
                    response.clearReceived();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 68.9K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/reflect/TypeTokenTest.java

      private static class Holder<T> {
        List<T>[] matrix;
    
        void setList(List<T> list) {}
      }
    
      public void testWildcardCaptured_methodParameter_upperBound() throws Exception {
        TypeToken<Holder<?>> type = new TypeToken<Holder<?>>() {};
        ImmutableList<Parameter> parameters =
            type.method(Holder.class.getDeclaredMethod("setList", List.class)).getParameters();
        assertThat(parameters).hasSize(1);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 89.3K bytes
    - Click Count (0)
Back to Top