- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,199 for syncAt (0.14 sec)
-
pkg/kubelet/types/pod_update.go
} } return "", fmt.Errorf("cannot get source of pod %q", pod.UID) } // SyncPodType classifies pod updates, eg: create, update. type SyncPodType int const ( // SyncPodSync is when the pod is synced to ensure desired state SyncPodSync SyncPodType = iota // SyncPodUpdate is when the pod is updated from source SyncPodUpdate // SyncPodCreate is when the pod is created from source SyncPodCreate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/kubelet/cm/dra/claiminfo.go
for _, claimInfo := range cache.claimInfo { if claimInfo.hasPodReference(UID) { return true } } return false } // syncToCheckpoint syncs the full claim info cache state to a checkpoint. func (cache *claimInfoCache) syncToCheckpoint() error { claimInfoStateList := make(state.ClaimInfoStateList, 0, len(cache.claimInfo)) for _, infoClaim := range cache.claimInfo {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/adsc/adsc_test.go
desc: "stream-3-completed-mcp-resources", initialRequests: ConfigInitialRequests(), validator: func(testCase testCase) error { if !testCase.inAdsc.HasSynced() { return errors.New("ADSC should be synced") } return nil }, }, { desc: "stream-4-uncompleted-mcp-resources", initialRequests: ConfigInitialRequests(), // XDS Server don't push this kind resource.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 15.4K bytes - Viewed (0) -
pkg/kube/krt/join_test.go
Labeled: Labeled{map[string]string{"app": "foo"}}, IP: "9.9.9.9", }) AllPods := krt.JoinCollection([]krt.Collection[SimplePod]{SimplePods, ExtraSimplePods.AsCollection()}) assert.Equal(t, AllPods.Synced().WaitUntilSynced(stop), true) // Assert Equal -- not EventuallyEqual -- to ensure our WaitForCacheSync is proper assert.Equal(t, fetcherSorted(AllPods)(), []SimplePod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/README.md
compatibility guarantee. ## Where does it come from? `apimachinery` is synced from https://github.com/kubernetes/kubernetes/blob/master/staging/src/k8s.io/apimachinery. Code changes are made in that location, merged into `k8s.io/kubernetes` and later synced here. ## Things you should *NOT* do 1. Add API types to this repo. This is for the machinery, not for the types.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 03 01:38:34 UTC 2021 - 1.2K bytes - Viewed (0) -
api/openapi-spec/v3/apis__networking.k8s.io__v1_openapi.json
NotOlderThan\n is interpreted as \"data at least as new as the provided `resourceVersion`\"\n and the bookmark event is send when the state is synced\n to a `resourceVersion` at least as fresh as the one provided by the ListOptions.\n If `resourceVersion` is unset, this is interpreted as \"consistent read\" and the\n bookmark event is send when the state is synced at least to the moment\n when request started being processed.\n- `resourceVersionMatch` set to any other value or unset\n Invalid error...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 324.8K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
continue } etcdEndpoints = append(etcdEndpoints, etcdEndpoint) } return etcdEndpoints, len(podList.Items), nil } // Sync synchronizes client's endpoints with the known endpoints from the etcd membership. func (c *Client) Sync() error { // Syncs the list of endpoints var cli etcdClient var lastError error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
UpdateFunc: nil, // Not needed, NodeName is immutable. DeleteFunc: g.deleteResourceSlice, }) synced = append(synced, sliceHandler.HasSynced) } go cache.WaitForNamedCacheSync("node_authorizer", wait.NeverStop, synced...) } func (g *graphPopulator) addPod(obj interface{}) { g.updatePod(nil, obj) } func (g *graphPopulator) updatePod(oldObj, obj interface{}) { pod := obj.(*corev1.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
// secretLister is able to list/get secrets and is populated by the shared informer passed to NewTokenCleaner. secretLister corelisters.SecretLister // secretSynced returns true if the secret shared informer has been synced at least once. secretSynced cache.InformerSynced queue workqueue.TypedRateLimitingInterface[string] } // NewTokenCleaner returns a new *NewTokenCleaner.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kube/kclient/client.go
// See the License for the specific language governing permissions and // limitations under the License. package kclient import ( "context" "fmt" "sync" "sync/atomic" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" klabels "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime/schema" apitypes "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/tools/cache"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0)