- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for etcd3 (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
ws.Produces(append(mediaTypes, streamMediaTypes...)...) ws.ApiVersion(a.group.GroupVersion.String()) return ws } // calculate the storage gvk, the gvk objects are converted to before persisted to the etcd. func getStorageVersionKind(storageVersioner runtime.GroupVersioner, storage rest.Storage, typer runtime.ObjectTyper) (schema.GroupVersionKind, error) { object := storage.New() fqKinds, _, err := typer.ObjectKinds(object)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller.go
// thread safe as long as the volumes/claims there are not modified, they // must be cloned before any modification. These caches get updated both by // "xxx added/updated/deleted" events from etcd and by the controller when // it saves newer version to etcd. // Why local cache: binding a volume to a claim generates 4 events, roughly // in this order (depends on goroutine ordering): // - volume.Spec update // - volume.Status update
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 89.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/testdata/swagger.json
}, "storedVersions": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 18:37:59 UTC 2023 - 55.4K bytes - Viewed (0) -
cmd/api-errors.go
if err == errInvalidDecompressedSize { apiErr = ErrInvalidDecompressedSize } if apiErr != ErrNone { // If there was a match in the above switch case. return apiErr } // etcd specific errors, a key is always a bucket for us return // ErrNoSuchBucket in such a case. if errors.Is(err, dns.ErrNoEntriesFound) { return ErrNoSuchBucket } switch err.(type) { case StorageFull:
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 92.1K bytes - Viewed (0) -
cmd/iam-store.go
return v, ok } return cache.iamUserPolicyMap.Load(name) } // GroupNotificationHandler - updates in-memory cache on notification of // change (e.g. peer notification for object storage and etcd watch // notification). func (store *IAMStoreSys) GroupNotificationHandler(ctx context.Context, group string) error { cache := store.lock() defer store.unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
cmd/sts-handlers_test.go
testCases = append(testCases, newTestSuiteIAM(bt, false), newTestSuiteIAM(bt, true), ) } for i, testCase := range testCases { etcdStr := "" if testCase.withEtcdBackend { etcdStr = " (with etcd backend)" } t.Run( fmt.Sprintf("Test: %d, ServerType: %s%s", i+1, testCase.serverType, etcdStr), func(t *testing.T) { runAllIAMSTSTests(testCase, &check{t, testCase.serverType}) }, ) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 18:45:50 UTC 2024 - 90K bytes - Viewed (0)