- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,199 for syncAt (0.39 sec)
-
pkg/security/apparmor/helpers.go
} if container.SecurityContext != nil && container.SecurityContext.AppArmorProfile != nil { return container.SecurityContext.AppArmorProfile } // Static pods may not have had annotations synced to fields, so fallback to annotations before // the pod profile. if profile := getProfileFromPodAnnotations(pod.Annotations, container.Name); profile != nil { return profile }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 18:46:32 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/controller/ttl/ttl_controller.go
kubeClient clientset.Interface // nodeStore is a local cache of nodes. nodeStore listers.NodeLister // Nodes that need to be synced. queue workqueue.TypedRateLimitingInterface[string] // Returns true if all underlying informers are synced. hasSynced func() bool lock sync.RWMutex // Number of nodes in the cluster. nodeCount int // Desired TTL for all nodes in the cluster. desiredTTLSeconds int
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
pkg/proxy/servicechangetracker.go
type processServiceMapChangeFunc func(previous, current ServicePortMap) // serviceChange contains all changes to services that happened since proxy rules were synced. For a single object, // changes are accumulated, i.e. previous is state from before applying the changes, // current is state after applying all of the changes. type serviceChange struct { previous ServicePortMap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 8.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
return fmt.Errorf("timed out waiting for initial cache sync") } return nil } return res, testCancel, nil } // UpdateAndWait updates the given object in the test, or creates it if it doesn't exist // Depending upon object type, waits afterward until the object is synced // by the policy source // // Be aware the UpdateAndWait will modify the ResourceVersion of the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/xds/statusgen.go
// TypeDebugSyncronization requests Envoy CSDS for proxy sync status TypeDebugSyncronization = v3.DebugType + "/syncz" // TypeDebugConfigDump requests Envoy configuration for a proxy without creating one TypeDebugConfigDump = v3.DebugType + "/config_dump" // TODO: TypeURLReady - readiness events for endpoints, agent can propagate ) // StatusGen is a Generator for XDS status: connections, syncz, configdump type StatusGen struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 10 23:30:28 UTC 2024 - 5.6K bytes - Viewed (0) -
internal/http/server.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/kube/krt/singleton_test.go
cms := krt.Fetch(ctx, ConfigMaps) return ptr.Of(slices.Join(",", slices.Map(cms, func(c *corev1.ConfigMap) string { return config.NamespacedName(c).String() })...)) }, ) ConfigMapNames.AsCollection().Synced().WaitUntilSynced(stop) tt := assert.NewTracker[string](t) ConfigMapNames.Register(TrackerHandler[string](tt)) tt.WaitOrdered("add/") assert.Equal(t, *ConfigMapNames.Get(), "") cmt.Create(&corev1.ConfigMap{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator_test.go
return false, ip, err })) c, err := NewMetaAllocator(client.NetworkingV1alpha1(), serviceCIDRInformer, ipInformer, false) if err != nil { return nil, err } // we can not force the state of the informers to be synced without racing // so we run our worker here go wait.Until(c.runWorker, time.Second, c.internalStopCh) return c, nil } func TestCIDRAllocateMultiple(t *testing.T) { r, err := newTestMetaAllocator()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 13.7K bytes - Viewed (0) -
cmd/kube-controller-manager/app/options/serviceaccountcontroller.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 04:54:33 UTC 2019 - 2.2K bytes - Viewed (0) -
pkg/kube/kclient/delayed.go
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package kclient import ( "sync" "sync/atomic" klabels "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/tools/cache" "istio.io/istio/pkg/kube/controllers" "istio.io/istio/pkg/kube/kubetypes"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 31 02:32:59 UTC 2023 - 3.5K bytes - Viewed (0)