- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 106 for newController (0.16 sec)
-
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller_test.go
namespaceInformer.Informer().GetIndexer().Add(obj) } systemNamespaces := []string{metav1.NamespaceSystem, metav1.NamespacePublic, v1.NamespaceNodeLease, metav1.NamespaceDefault} controller := NewController(systemNamespaces, clientset, namespaceInformer) clientset.PrependReactor("create", "namespaces", func(action k8stesting.Action) (bool, runtime.Object, error) { create := action.(k8stesting.CreateAction)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 4.3K bytes - Viewed (0) -
pilot/pkg/status/manager.go
) // Manager allows multiple controllers to provide input into configuration // status without needlessly doubling the number of writes, or overwriting // one another. Each status controller calls newController, passing in // an arbitrary status modification function, and then calls EnqueueStatusUpdate // when an individual resource is ready to be updated with the relevant data. type Manager struct {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 4.2K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
xdsUpdater := opts.XDSUpdater if xdsUpdater == nil { xdsUpdater = model.NewEndpointIndexUpdater(env.EndpointIndex) } serviceDiscovery := aggregate.NewController(aggregate.Options{}) se := serviceentry.NewController( configController, xdsUpdater, env.Watcher, serviceentry.WithClusterID(opts.ClusterID)) // TODO allow passing in registry, for k8s, mem reigstry
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/kubelet/server/stats/summary_windows_test.go
cs *statsapi.ContainerStats ns *statsapi.NetworkStats }{ "/": {cs: getContainerStats()}, "/pods": {cs: getContainerStats()}, } ) assert := assert.New(t) mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() mockStatsProvider := statstest.NewMockProvider(mockCtrl) mockStatsProvider.EXPECT().GetNode().Return(node, nil).AnyTimes()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 4.4K bytes - Viewed (0) -
pilot/test/xds/fake.go
defaultKubeController = k8s } else { client.RunAndWait(stop) } registries = append(registries, k8s) mc.Add(k8sCluster, client, stop) } stop := test.NewStop(t) ingr := ingress.NewController(defaultKubeClient, mesh.NewFixedWatcher(m), kube.Options{ DomainSuffix: "cluster.local", }) defaultKubeClient.RunAndWait(stop) var gwc *gateway.Controller cg := core.NewConfigGenTest(t, core.TestOptions{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
return } defer c.policyQueue.ShutDown() for i := 0; i < workers; i++ { go wait.UntilWithContext(ctx, c.runWorker, time.Second) } <-ctx.Done() } func NewController(policyInformer informerv1.ValidatingAdmissionPolicyInformer, policyClient admissionregistrationv1.ValidatingAdmissionPolicyInterface, typeChecker *validatingadmissionpolicy.TypeChecker) (*Controller, error) { c := &Controller{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_test.go
podLogName0 = "pod-log-0" podLogName1 = "pod-log-1" podLogStats0 = makeFakeLogStats(5000) podLogStats1 = makeFakeLogStats(6000) ) mockCtrl := gomock.NewController(t) defer mockCtrl.Finish() var ( mockCadvisor = cadvisortest.NewMockInterface(mockCtrl) mockRuntimeCache = new(kubecontainertest.MockRuntimeCache)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 54.5K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller.go
"The namespace where ingress controller runs, by default it is istio-system").Get() var errUnsupportedOp = errors.New("unsupported operation: the ingress config store is a read-only view") // NewController creates a new Kubernetes controller func NewController(client kube.Client, meshWatcher mesh.Holder, options kubecontroller.Options, ) model.ConfigStoreController {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 03:53:05 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/config/analysis/incluster/controller.go
// Controller manages repeatedly running analyzers in istiod, and reporting results // via istio status fields. type Controller struct { analyzer *local.IstiodAnalyzer statusctl *status.Controller } func NewController(stop <-chan struct{}, rwConfigStore model.ConfigStoreController, kubeClient kube.Client, revision, namespace string, statusManager *status.Manager, domainSuffix string, ) (*Controller, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
return func(o *Controller) { o.networkIDCallback = cb } } // NewController creates a new ServiceEntry discovery service. func NewController(configController model.ConfigStoreController, xdsUpdater model.XDSUpdater, meshConfig mesh.Watcher, options ...Option, ) *Controller { s := newController(configController, xdsUpdater, meshConfig, options...) if configController != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0)