- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 277 for mkchan (0.05 sec)
-
internal/grid/README.md
- The handler function has this signature.
- Sample handler:
- ```go
- handler := func(ctx context.Context, payload []byte, in <-chan []byte, out chan<- []byte) *RemoteErr {
- fmt.Println("Got request with initial payload", p, "from", GetCaller(ctx context.Context))
- fmt.Println("Subroute:", GetSubroute(ctx))
- for {
- 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) -
cmd/handler-api.go
- xioutil "github.com/minio/minio/internal/ioutil"
- "github.com/minio/minio/internal/logger"
- "github.com/minio/minio/internal/mcontext"
- )
- type apiConfig struct {
- mu sync.RWMutex
- requestsPool chan struct{}
- clusterDeadline time.Duration
- listQuorum string
- corsAllowOrigins []string
- replicationPriority string
- replicationMaxWorkers int
- 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) -
guava-testlib/src/com/google/common/collect/testing/testers/Platform.java
- */
- package com.google.common.collect.testing.testers;
- import com.google.common.annotations.GwtCompatible;
- import java.util.Locale;
- /**
- * This class is emulated in GWT.
- *
- * @author Hayward Chan
- */
- @GwtCompatible
- final class Platform {
- /** Format the template with args, only supports the placeholder {@code %s}. */
- 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) -
cmd/grid.go
- // globalGridStart is a channel that will block startup of grid connections until closed.
- var globalGridStart = make(chan struct{})
- // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
- var globalLockGridStart = make(chan struct{})
- func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
- 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) -
kotlin-js-store/yarn.lock
- integrity sha512-rE9RkUPI7I9mAxByQWkGJFXfFD6lE4gC5nPuZdobf/QdTEJI6EU4yIay/cfU/xV4ZxlM5JiTv7zWYgA64NpS5Q==
- dependencies:
- which "^1.2.1"
- karma-mocha@2.0.1:
- version "2.0.1"
- resolved "https://registry.yarnpkg.com/karma-mocha/-/karma-mocha-2.0.1.tgz#4b0254a18dfee71bdbe6188d9a6861bf86b0cd7d"
- integrity sha512-Tzd5HBjm8his2OA4bouAsATYEpZrp9vC7z5E5j4C5Of5Rrs1jY67RAwXNcVmd/Bnk1wgvQRou0zGVLey44G4tQ==
- 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) -
docs/de/docs/alternatives.md
- Alle Kern-Webaspekte zu handhaben. Und fügt Funktionen obenauf.
- Die Klasse `FastAPI` selbst erbt direkt von der Klasse `Starlette`.
- 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.
- ///
- ### <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) -
internal/http/listener.go
- lidx int
- }
- // httpListener - HTTP listener capable of handling multiple server addresses.
- type httpListener struct {
- opts TCPOptions
- listeners []net.Listener // underlying TCP listeners.
- acceptCh chan acceptResult // channel where all TCP listeners write accepted connection.
- ctx context.Context
- ctxCanceler context.CancelFunc
- }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/speedtest.go
- enableSha256 bool
- enableMultipart bool
- creds auth.Credentials
- }
- // Get the max throughput and iops numbers.
- func objectSpeedTest(ctx context.Context, opts speedTestOpts) chan madmin.SpeedTestResult {
- ch := make(chan madmin.SpeedTestResult, 1)
- go func() {
- defer xioutil.SafeClose(ch)
- concurrency := opts.concurrencyStart
- if opts.autotune {
- // 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) -
internal/grid/grid.go
- func getDeadline(d time.Duration) time.Duration {
- if d < time.Millisecond {
- return 0
- }
- if d > MaxDeadline {
- return MaxDeadline
- }
- return d
- }
- type writerWrapper struct {
- ch chan<- []byte
- ctx context.Context
- }
- func (w *writerWrapper) Write(p []byte) (n int, err error) {
- buf := GetByteBufferCap(len(p))
- buf = buf[:len(p)]
- copy(buf, p)
- select {
- 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) -
cni/pkg/install/install_test.go
- t.Fatal(err)
- }
- // Listen for isReady to be set to true
- ticker := time.NewTicker(500 * time.Millisecond)
- defer ticker.Stop()
- readyChan := make(chan bool)
- go func(ctx context.Context, tick <-chan time.Time) {
- for {
- select {
- case <-ctx.Done():
- return
- case <-tick:
- if isReady.Load().(bool) {
- readyChan <- true
- }
- }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 11.1K bytes - Viewed (0)