- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 279 for notified (0.2 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
if err != nil { t.Errorf("unexpected error establishing watch: %v", err) return } for event := range w.ResultChan() { switch event.Type { case watch.Added, watch.Modified, watch.Deleted: // all expected default: t.Errorf("unexpected watch event: %#v", event) } } }(i) } // Let all the established watches soak request loops soak
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
internal/cachevalue/cache.go
// updateFn must return an updated value. // If an error is returned the cached value is not set. // Only one caller will call this function at any time, others will be blocking. // The returned value can no longer be modified once returned. // Should be set before calling Get(). updateFn func(ctx context.Context) (T, error) // ttl for a cached value. ttl time.Duration opts Opts
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/server_test.go
// The responses for fetching the object when If-Modified-Since // and If-Unmodified-Since headers set are validated. // If-Modified-Since - Return the object only if it has been modified since the specified time, else return a 304 (not modified). // If-Unmodified-Since - Return the object only if it has not been modified since the specified time, else return a 412 (precondition failed).
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintCheckerTest.kt
import org.junit.Test import java.io.File import java.io.InputStream import java.io.OutputStream class ConfigurationCacheFingerprintCheckerTest { @Test fun `first modified init script is reported`() { assertThat( invalidationReasonForInitScriptsChange( from = listOf( File("init.gradle.kts") to TestHashCodes.hashCodeFrom(1),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 18.5K bytes - Viewed (0) -
src/crypto/tls/common.go
// On the client side, it can't be empty. On the server side, it can be // empty if Config.ClientAuth is not RequireAnyClientCert or // RequireAndVerifyClientCert. // // PeerCertificates and its contents should not be modified. PeerCertificates []*x509.Certificate // VerifiedChains is a list of one or more chains where the first element is // PeerCertificates[0] and the last element is from Config.RootCAs (on the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 59.1K bytes - Viewed (0) -
src/go/ast/example_test.go
// (the comments associated with the variable declaration), and create // the new comments list. f.Comments = cmap.Filter(f).Comments() // Print the modified AST. var buf strings.Builder if err := format.Node(&buf, fset, f); err != nil { panic(err) } fmt.Printf("%s", buf.String()) // Output: // // This is the package comment. // package main
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 21:44:50 UTC 2024 - 6.1K bytes - Viewed (0) -
src/hash/crc64/crc64.go
slicing8TableECMA = makeSlicingBy8Table(makeTable(ECMA)) } // MakeTable returns a [Table] constructed from the specified polynomial. // The contents of this [Table] must not be modified. func MakeTable(poly uint64) *Table { buildSlicing8TablesOnce() switch poly { case ISO: return &slicing8TableISO[0] case ECMA: return &slicing8TableECMA[0] default: return makeTable(poly) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 18 22:36:41 UTC 2024 - 5.2K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
wantDeleted.Insert(c.Name) } } else if diff := cmp.Diff(c.Resource, n.Resource, protocmp.Transform()); diff != "" { // Resource was modified wantChanged.Insert(c.Name) } else { // No diff. Ideally delta doesn't send any update here wantUnchanged.Insert(c.Name) } } for _, v := range sotwRes { if _, f := curByName[v.Name]; !f {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
staging/src/k8s.io/api/admissionregistration/v1/generated.proto
// Allowed values are "Exact" or "Equivalent". // // - Exact: match a request only if it exactly matches a specified rule. // For example, if deployments can be modified via apps/v1, apps/v1beta1, and extensions/v1beta1, // but "rules" only included `apiGroups:["apps"], apiVersions:["v1"], resources: ["deployments"]`,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 51.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
func (tc *testContext) updateAPIServer(t *testing.T, objects []metav1.Object, updates change) []metav1.Object { modified := update(t, objects, updates) for i := range modified { obj := modified[i] if diff := cmp.Diff(objects[i], obj); diff != "" { t.Logf("Updating %T %q, diff (-old, +new):\n%s", obj, obj.GetName(), diff) switch obj := obj.(type) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0)