- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,978 for seni (0.07 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/with_retry_after.go
return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) { params, send := shouldRespondWithRetryAfterFn() if !send || isRequestExemptFn(req) { handler.ServeHTTP(w, req) return } // If we are here this means it's time to send Retry-After response // // Copied from net/http2 library // "Connection" headers aren't allowed in HTTP/2 (RFC 7540, 8.1.2.2),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 31 14:10:46 UTC 2021 - 4.9K bytes - Viewed (0) -
internal/event/target/redis.go
} if err := target.init(); err != nil { return err } _, err := target.isActive() if err != nil { return err } return target.send(eventData) } // send - sends an event to the redis. func (target *RedisTarget) send(eventData event.Event) error { conn := target.pool.Get() defer conn.Close() if target.args.Format == event.NamespaceFormat {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.1K bytes - Viewed (0) -
docs/tr/docs/features.md
![ReDoc](https://fastapi.tiangolo.com/img/index/index-06-redoc-02.png) ### Sadece modern Python Tamamiyle standartlar **Python 3.8**'nın type hintlerine dayanıyor (Pydantic'in sayesinde). Yeni bir syntax öğrenmene gerek yok. Sadece modern Python.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
con := &ProxyConnection{ conID: connectionNumber.Inc(), upstreamError: make(chan error), // can be produced by recv and send downstreamError: make(chan error), // can be produced by recv and send deltaRequestsChan: channels.NewUnbounded[*discovery.DeltaDiscoveryRequest](), // Allow a buffer of 1. This ensures we queue up at most 2 (one in process, 1 pending) responses before forwarding.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/scheduler/framework/parallelize/error_channel.go
limitations under the License. */ package parallelize import "context" // ErrorChannel supports non-blocking send and receive operation to capture error. // A maximum of one error is kept in the channel and the rest of the errors sent // are ignored, unless the existing error is received and the channel becomes empty // again. type ErrorChannel struct { errCh chan error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 20 17:39:23 UTC 2021 - 1.6K bytes - Viewed (0) -
src/os/signal/signal_cgo_test.go
// with its controlling terminal shall cause the process group // to be sent a SIGTTOU signal. If the calling thread is // blocking SIGTTOU signals or the process is ignoring SIGTTOU // signals, the process shall be allowed to perform the // operation, and no signal is sent." // -https://pubs.opengroup.org/onlinepubs/9699919799/functions/tcsetpgrp.html //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 20 10:09:15 UTC 2024 - 10.7K bytes - Viewed (0) -
api/openapi-spec/v3/apis__rbac.authorization.k8s.io__v1_openapi.json
"description": "`sendInitialEvents=true` may be set together with `watch=true`. In that case, the watch stream will begin with synthetic events to produce the current state of objects in the collection. Once all such events have been sent, a synthetic \"Bookmark\" event will be sent. The bookmark will report the ResourceVersion (RV) corresponding to the set of objects, and be marked with `\"k8s.io/initial-events-end\": \"true\"` annotation. Afterwards, the watch stream will proceed as usual, sending watch...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 352.2K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/util.go
// is allowed to receive health status updates sent by an Istio Proxy. // // Consider a workload eligible for health status updates as long as the // WorkloadEntryHealthCheckAnnotation is present (no matter what the value is). // In case the annotation is present but the value is not "true", the proxy should be allowed // to send health status updates, config health condition should be updated accordingly,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 11 07:04:17 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/metrics-v3-logger-webhook.go
webhookFailedMessagesMD = NewCounterMD(webhookFailedMessages, "Number of messages that failed to send", allWebhookLabels...) webhookQueueLengthMD = NewGaugeMD(webhookQueueLength, "Webhook queue length", allWebhookLabels...) webhookTotalMessagesMD = NewCounterMD(webhookTotalMessages, "Total number of messages sent to this target", allWebhookLabels...) )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 14 07:27:33 UTC 2024 - 2K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
"If enabled, Pilot will send only clusters that referenced in gateway virtual services attached to gateway").Get() SendUnhealthyEndpoints = atomic.NewBool(env.Register( "PILOT_SEND_UNHEALTHY_ENDPOINTS", false, "If enabled, Pilot will include unhealthy endpoints in EDS pushes and even if they are sent Envoy does not use them for load balancing."+
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0)