- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 183 for Everything (0.19 sec)
-
internal/event/name.go
// Start Compound types that require expansion: ObjectAccessedAll ObjectCreatedAll ObjectRemovedAll ObjectReplicationAll ObjectRestoreAll ObjectTransitionAll ObjectScannerAll Everything ) // The number of single names should not exceed 64. // This will break masking. Use bit 63 as extension. var _ = uint64(1 << objectSingleTypesEnd) // Expand - returns expanded values of abbreviated event type.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 01 01:11:10 UTC 2024 - 10.4K bytes - Viewed (0) -
docs/en/docs/tutorial/bigger-applications.md
# Bigger Applications - Multiple Files If you are building an application or a web API, it's rarely the case that you can put everything on a single file. **FastAPI** provides a convenience tool to structure your application while keeping all the flexibility. !!! info If you come from Flask, this would be the equivalent of Flask's Blueprints. ## An example file structure Let's say you have a file structure like this: ``` . ├── app
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 18.6K bytes - Viewed (0) -
pkg/controller/deployment/progress_test.go
conditionStatus: v1.ConditionTrue, conditionReason: util.ReplicaSetUpdatedReason, lastTransition: testTime, }, { name: "DeploymentProgressing: update everything if deployment has Progressing=False", d: currentDeployment(&pds, 3, 2, 2, 2, []apps.DeploymentCondition{failedTimedOut}), allRSs: []*apps.ReplicaSet{newRSWithAvailable("bar", 0, 1, 1)},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
apiResourcesForDiscovery := []metav1.APIResource{} aggregatedAPIResourcesForDiscovery := []apidiscoveryv2.APIResourceDiscovery{} versionsForDiscoveryMap := map[metav1.GroupVersion]bool{} crds, err := c.crdLister.List(labels.Everything()) if err != nil { return err } foundVersion := false foundGroup := false for _, crd := range crds { if !apiextensionshelpers.IsCRDConditionTrue(crd, apiextensionsv1.Established) { continue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
build/common.sh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:13:15 UTC 2024 - 26.5K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller.go
// by ingress using port name. namespacedName := config.NamespacedName(curSvc).String() for _, ingress := range c.ingress.List(curSvc.GetNamespace(), klabels.Everything()) { referredSvcSet := extractServicesByPortNameType(ingress) if referredSvcSet.Contains(namespacedName) { c.queue.AddObject(ingress) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 11.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
// for all service's the pod is a part of and push an update. func (c *Controller) recomputeServiceForPod(pod *v1.Pod) { allServices := c.services.List(pod.Namespace, klabels.Everything()) cu := sets.New[model.ConfigKey]() services := getPodServices(allServices, pod) for _, svc := range services { hostname := kube.ServiceHostname(svc.Name, svc.Namespace, c.opts.DomainSuffix) c.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// This is only used for building the initial snapshot ATM. func (s *InformerHandlers) GetActiveAmbientPodSnapshot() []*corev1.Pod { var pods []*corev1.Pod for _, pod := range s.pods.List(metav1.NamespaceAll, klabels.Everything()) { ns := s.namespaces.Get(pod.Namespace, "") if ns == nil { log.Warnf("failed to find namespace %s for pod %s", pod.Namespace, pod.Name) } // Exclude ztunnels, and terminated daemonset pods
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
<-ctx.Done() } func (gcc *PodGCController) gc(ctx context.Context) { pods, err := gcc.podLister.List(labels.Everything()) if err != nil { klog.FromContext(ctx).Error(err, "Error while listing all pods") return } nodes, err := gcc.nodeLister.List(labels.Everything()) if err != nil { klog.FromContext(ctx).Error(err, "Error while listing all nodes") return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller.go
for _, gw := range dc.gateways.List(o.GetName(), klabels.Everything()) { dc.queue.AddObject(gw) } })) gateways.AddEventHandler(controllers.ObjectHandler(dc.queue.AddObject)) gatewayClasses.AddEventHandler(controllers.ObjectHandler(func(o controllers.Object) { for _, g := range dc.gateways.List(metav1.NamespaceAll, klabels.Everything()) { if string(g.Spec.GatewayClassName) == o.GetName() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 26.3K bytes - Viewed (0)