Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 277 for mkchan (0.05 sec)

  1. internal/grid/README.md

    1. The handler function has this signature.
    2.  
    3. Sample handler:
    4. ```go
    5. handler := func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
    6. fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
    7. fmt.Println("Subroute:", GetSubroute(ctx))
    8. for {
    9. select {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  2. cmd/handler-api.go

    1. xioutil "github.com/minio/minio/internal/ioutil"
    2. "github.com/minio/minio/internal/logger"
    3. "github.com/minio/minio/internal/mcontext"
    4. )
    5.  
    6. type apiConfig struct {
    7. mu sync.RWMutex
    8.  
    9. requestsPool chan struct{}
    10. clusterDeadline time.Duration
    11. listQuorum string
    12. corsAllowOrigins []string
    13. replicationPriority string
    14. replicationMaxWorkers int
    15. replicationMaxLWorkers int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/collect/testing/testers/Platform.java

    1. */
    2.  
    3. package com.google.common.collect.testing.testers;
    4.  
    5. import com.google.common.annotations.GwtCompatible;
    6. import java.util.Locale;
    7.  
    8. /**
    9. * This class is emulated in GWT.
    10. *
    11. * @author Hayward Chan
    12. */
    13. @GwtCompatible
    14. final class Platform {
    15.  
    16. /** Format the template with args, only supports the placeholder {@code %s}. */
    17. static String format(String template, Object... args) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Dec 04 17:37:03 UTC 2017
    - 1.3K bytes
    - Viewed (0)
  4. cmd/grid.go

    1. // globalGridStart is a channel that will block startup of grid connections until closed.
    2. var globalGridStart = make(chan struct{})
    3.  
    4. // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    5. var globalLockGridStart = make(chan struct{})
    6.  
    7. func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    8. hosts, local := eps.GridHosts()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. kotlin-js-store/yarn.lock

    1. integrity sha512-rE9RkUPI7I9mAxByQWkGJFXfFD6lE4gC5nPuZdobf/QdTEJI6EU4yIay/cfU/xV4ZxlM5JiTv7zWYgA64NpS5Q==
    2. dependencies:
    3. which "^1.2.1"
    4.  
    5. karma-mocha@2.0.1:
    6. version "2.0.1"
    7. resolved "https://registry.yarnpkg.com/karma-mocha/-/karma-mocha-2.0.1.tgz#4b0254a18dfee71bdbe6188d9a6861bf86b0cd7d"
    8. integrity sha512-Tzd5HBjm8his2OA4bouAsATYEpZrp9vC7z5E5j4C5Of5Rrs1jY67RAwXNcVmd/Bnk1wgvQRou0zGVLey44G4tQ==
    9. dependencies:
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 87.4K bytes
    - Viewed (0)
  6. docs/de/docs/alternatives.md

    1. Alle Kern-Webaspekte zu handhaben. Und fügt Funktionen obenauf.
    2.  
    3. Die Klasse `FastAPI` selbst erbt direkt von der Klasse `Starlette`.
    4.  
    5. Alles, was Sie also mit Starlette machen können, können Sie direkt mit **FastAPI** machen, da es sich im Grunde um Starlette auf Steroiden handelt.
    6.  
    7. ///
    8.  
    9. ### <a href="https://www.uvicorn.org/" class="external-link" target="_blank">Uvicorn</a>
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 20 19:20:23 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  7. internal/http/listener.go

    1. lidx int
    2. }
    3.  
    4. // httpListener - HTTP listener capable of handling multiple server addresses.
    5. type httpListener struct {
    6. opts TCPOptions
    7. listeners []net.Listener // underlying TCP listeners.
    8. acceptCh chan acceptResult // channel where all TCP listeners write accepted connection.
    9. ctx context.Context
    10. ctxCanceler context.CancelFunc
    11. }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. cmd/speedtest.go

    1. enableSha256 bool
    2. enableMultipart bool
    3. creds auth.Credentials
    4. }
    5.  
    6. // Get the max throughput and iops numbers.
    7. func objectSpeedTest(ctx context.Context, opts speedTestOpts) chan madmin.SpeedTestResult {
    8. ch := make(chan madmin.SpeedTestResult, 1)
    9. go func() {
    10. defer xioutil.SafeClose(ch)
    11.  
    12. concurrency := opts.concurrencyStart
    13.  
    14. if opts.autotune {
    15. // if we have less drives than concurrency then choose
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. internal/grid/grid.go

    1. func getDeadline(d time.Duration) time.Duration {
    2. if d < time.Millisecond {
    3. return 0
    4. }
    5. if d > MaxDeadline {
    6. return MaxDeadline
    7. }
    8. return d
    9. }
    10.  
    11. type writerWrapper struct {
    12. ch chan<- []byte
    13. ctx context.Context
    14. }
    15.  
    16. func (w *writerWrapper) Write(p []byte) (n int, err error) {
    17. buf := GetByteBufferCap(len(p))
    18. buf = buf[:len(p)]
    19. copy(buf, p)
    20. select {
    21. case w.ch <- buf:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  10. cni/pkg/install/install_test.go

    1. t.Fatal(err)
    2. }
    3.  
    4. // Listen for isReady to be set to true
    5. ticker := time.NewTicker(500 * time.Millisecond)
    6. defer ticker.Stop()
    7. readyChan := make(chan bool)
    8. go func(ctx context.Context, tick <-chan time.Time) {
    9. for {
    10. select {
    11. case <-ctx.Done():
    12. return
    13. case <-tick:
    14. if isReady.Load().(bool) {
    15. readyChan <- true
    16. }
    17. }
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 11.1K bytes
    - Viewed (0)
Back to top