Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 374 for queued (0.05 sec)

  1. internal/grid/grid.go

    	// This is the assumed size of bigger buffers and allocation size.
    	biggerBufMin = 32 << 10
    
    	// This is the maximum size of bigger buffers.
    	biggerBufMax = maxBufferSize
    
    	// If there is a queue, merge up to this many messages.
    	maxMergeMessages = 50
    
    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. common-protos/k8s.io/api/autoscaling/v1/generated.proto

      // +optional
      optional string apiVersion = 3;
    }
    
    // ExternalMetricSource indicates how to scale on a metric not associated with
    // any Kubernetes object (for example length of queue in cloud
    // messaging service, or QPS from loadbalancer running outside of cluster).
    message ExternalMetricSource {
      // metricName is the name of the metric in question.
      optional string metricName = 1;
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 22K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/ftp/FtpClient.java

    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.net.MalformedURLException;
    import java.net.URL;
    import java.time.Duration;
    import java.util.HashSet;
    import java.util.Queue;
    import java.util.Set;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    import org.apache.commons.lang3.StringUtils;
    import org.apache.commons.net.ftp.FTP;
    import org.apache.commons.net.ftp.FTPClient;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Sat Oct 12 01:41:37 UTC 2024
    - 25.7K bytes
    - Viewed (0)
  4. docs/de/docs/tutorial/background-tasks.md

    Sie erfordern in der Regel komplexere Konfigurationen und einen Nachrichten-/Job-Queue-Manager wie RabbitMQ oder Redis, ermöglichen Ihnen jedoch die Ausführung von Hintergrundtasks in mehreren Prozessen und insbesondere auf mehreren Servern.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  5. internal/event/target/webhook.go

    	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()
    			return nil, fmt.Errorf("unable to initialize the queue store of Webhook `%s`: %w", id, err)
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. internal/s3select/errors.go

    	}
    }
    
    func errInvalidCompression(err error, t CompressionType) *s3Error {
    	return &s3Error{
    		code:       "InvalidCompressionFormat",
    		message:    strings.ToUpper(string(t)) + " is not applicable to the queried object. Please correct the request and try again.",
    		statusCode: 400,
    		cause:      err,
    	}
    }
    
    func errInvalidDataSource(err error) *s3Error {
    	return &s3Error{
    		code:       "InvalidDataSource",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 14 16:48:36 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  7. docs/pt/docs/tutorial/header-param-models.md

    <div class="screenshot">
    <img src="/img/tutorial/header-param-models/image01.png">
    </div>
    
    ### Proibindo Cabeçalhos adicionais
    
    Em alguns casos de uso especiais (provavelmente não muito comuns), você pode querer **restringir** os cabeçalhos que você quer receber.
    
    Você pode usar a configuração dos modelos do Pydantic para proibir (`forbid`) quaisquer campos `extra`:
    
    //// tab | Python 3.10+
    
    ```Python hl_lines="10"
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Oct 22 20:41:28 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // contract.
        // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could
        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. docs/pt/docs/tutorial/cookie-param-models.md

    ///
    
    ## Proibir Cookies Adicionais
    
    Em alguns casos especiais (provavelmente não muito comuns), você pode querer **restringir** os cookies que você deseja receber.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Oct 07 20:18:07 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  10. internal/event/target/mqtt.go

    	}
    
    	var queueStore store.Store[event.Event]
    	if args.QueueDir != "" {
    		queueDir := filepath.Join(args.QueueDir, storePrefix+"-mqtt-"+id)
    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of MQTT `%s`: %w", id, err)
    		}
    	}
    
    	target := &MQTTTarget{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
Back to top