- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,140 for spent (0.34 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
// send ack so the server doesn't wait for us. sendAck(ztunClient) // second message should be the snap sent message m, fds = readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil { panic("expected snapshot sent") } sendAck(ztunClient) ztunClient.Close() // this will retry for a bit, so shouldn't flake
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/testdata/multiXdsStatusSinglePilot.txt
NAME CLUSTER CDS LDS EDS RDS ECDS ISTIOD VERSION proxy1 cluster1 STALE SYNCED SYNCED NOT SENT NOT SENT istiod1 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 300 bytes - Viewed (0) -
istioctl/pkg/writer/pilot/testdata/multiXdsStatusMultiPilot.txt
proxy1 cluster1 STALE SYNCED SYNCED NOT SENT SYNCED istiod1 1.20 proxy2 cluster2 STALE SYNCED STALE SYNCED STALE istiod2 1.19 proxy3 cluster3 NOT SENT ERROR STALE NOT SENT NOT SENT istiod3 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 522 bytes - Viewed (0) -
pkg/zdsapi/zds.proto
// Keep workload that we can't find in the fd cache. This can only be sent before SnapshotSent is sent // to signal ztunnel to not delete the workload if it has it. message KeepWorkload { string uid = 1; } // Delete a workload from the ztunnel. Ztunnel should shutdown the workload's proxy. message DelWorkload { string uid = 2; } // Let ztunnel know that a full snapshot was sent. Ztunnel should reconcile its internal state
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 22:07:03 UTC 2024 - 2.7K bytes - Viewed (0) -
fastapi/background.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Tue Apr 02 02:48:51 UTC 2024 - 1.7K bytes - Viewed (0) -
src/os/signal/example_test.go
// We must use a buffered channel or risk missing the signal // if we're not ready to receive when the signal is sent. c := make(chan os.Signal, 1) // Passing no signals to Notify means that // all signals will be sent to the channel. signal.Notify(c) // Block until any signal is received. s := <-c fmt.Println("Got signal:", s)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 18:38:23 UTC 2017 - 1001 bytes - Viewed (0) -
okhttp-sse/README.md
OkHttp Server-Sent Events ========================= Experimental support for server-sent events. API is not considered stable and may change at any time. ### Download ```kotlin testImplementation("com.squareup.okhttp3:okhttp-sse:4.12.0")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Dec 17 15:34:10 UTC 2023 - 245 bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/events/problems/ProblemAggregationEvent.java
package org.gradle.tooling.events.problems; import org.gradle.api.Incubating; /** * Represents a list of aggregated problems. These are sent at the end of the build. * All Problems that occurred more than once during the build are aggregated and sent as a {@link ProblemAggregation}. * They won't be sent in between the build only the first one. * * @since 8.8 */ @Incubating public interface ProblemAggregationEvent extends ProblemEvent {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 18 12:26:28 UTC 2024 - 1.2K bytes - Viewed (0) -
docs_src/request_files/tutorial001_02_an_py310.py
async def create_file(file: Annotated[bytes | None, File()] = None): if not file: return {"message": "No file sent"} else: return {"file_size": len(file)} @app.post("/uploadfile/") async def create_upload_file(file: UploadFile | None = None): if not file: return {"message": "No upload file sent"} else:
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 505 bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/events/problems/ProblemAggregation.java
import org.gradle.api.Incubating; import java.util.List; /** * Represents a list of aggregated problems. These are sent at the end of the build. * All Problems that occurred more than once during the build are aggregated and sent as a {@link ProblemAggregation}. * They won't be sent in between the build only the first one. * * @since 8.6 */ @Incubating public interface ProblemAggregation { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 07:24:17 UTC 2024 - 1.4K bytes - Viewed (0)