- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 589 for seni (0.06 sec)
-
docs/en/docs/tutorial/request-files.md
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Mar 13 19:02:19 UTC 2024 - 10.2K bytes - Viewed (0) -
docs/logging/README.md
"accessKey": "minioadmin" } ``` ### Kafka Target Assuming that you already have Apache Kafka configured and running. ``` mc admin config set myminio/ audit_kafka KEY: audit_kafka[:name] send audit logs to kafka endpoints ARGS: brokers* (csv) comma separated list of Kafka broker addresses topic (string) Kafka topic used for bucket notifications
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 17:15:03 UTC 2024 - 10.4K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
timer := time.AfterFunc(time.Minute, func() { once.Do(func() { t.Error("test timed out; terminating pipe") stop() }) }) defer timer.Stop() f(t, c1, c2) } // testBasicIO tests that the data sent on c1 is properly received on c2. func testBasicIO(t *testing.T, c1, c2 net.Conn) { want := make([]byte, 1<<20) rand.New(rand.NewSource(0)).Read(want) dataCh := make(chan []byte) go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/audit/v1/types.go
// The stage for events generated once the response headers are sent, but before the response body // is sent. This stage is only generated for long-running requests (e.g. watch). StageResponseStarted Stage = "ResponseStarted" // The stage for events generated once the response body has been completed, and no more bytes // will be sent. StageResponseComplete Stage = "ResponseComplete"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 27 20:24:10 UTC 2023 - 14.5K bytes - Viewed (0) -
src/os/exec/exec.go
// subprocess that inherited them and is still holding them open // (see https://go.dev/issue/23019). // // We close the goroutine pipes only after we have sent any signals we're // going to send to the process (via Signal or Kill above): if we send // SIGKILL to the process, we would prefer for it to die of SIGKILL, not // SIGPIPE. (However, this may still cause any orphaned subprocesses to // terminate with SIGPIPE.)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:53 UTC 2024 - 41.4K bytes - Viewed (0) -
src/net/http/httputil/persist.go
cc.mu.Lock() defer cc.mu.Unlock() if err != nil { cc.we = err return err } cc.nwritten++ return nil } // Pending returns the number of unanswered requests // that have been sent on the connection. func (cc *ClientConn) Pending() int { cc.mu.Lock() defer cc.mu.Unlock() return cc.nwritten - cc.nread } // Read reads the next response from the wire. A valid response might be
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
docs/ja/docs/tutorial/dependencies/dependencies-with-yield.md
operation -->> dep: Raise other exception end operation ->> client: Return response to client Note over client,operation: Response is already sent, can't change it anymore opt Tasks operation -->> tasks: Send background tasks end opt Raise other exception tasks -->> dep: Raise other exception end Note over dep: After yield opt Handle other exception
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 12.5K bytes - Viewed (0) -
src/encoding/gob/codec_test.go
} } type String string type PtrInterfaceItem struct { Str1 any // basic Str2 any // derived } // We'll send pointers; should receive values. // Also check that we can register T but send *T. func TestInterfacePointer(t *testing.T) { b := new(bytes.Buffer) str1 := "howdy" str2 := String("kiddo") item1 := &PtrInterfaceItem{ &str1, &str2,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Aug 19 23:03:14 UTC 2023 - 36.9K bytes - Viewed (0) -
doc/go_mem.html
<h3 id="chan">Channel communication</h3> <p> Channel communication is the main method of synchronization between goroutines. Each send on a particular channel is matched to a corresponding receive from that channel, usually in a different goroutine. </p> <p class="rule"> A send on a channel is synchronized before the completion of the corresponding receive from that channel. </p> <p> This program: </p>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
src/runtime/signal_unix.go
pendingPreemptSignals.Add(1) } // If multiple threads are preempting the same M, it may send many // signals to the same M such that it hardly make progress, causing // live-lock problem. Apparently this could happen on darwin. See // issue #37741. // Only send a signal if there isn't already one pending. signalM(mp, sigPreempt) } if GOOS == "darwin" || GOOS == "ios" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 16:04:54 UTC 2024 - 45K bytes - Viewed (0)