- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,951 for controller3 (0.19 sec)
-
cmd/endpoint-ellipses_test.go
true, }, { []string{"data/controller{1...11}/export{1...8}"}, []uint64{88}, [][]uint64{{11, 11, 11, 11, 11, 11, 11, 11}}, true, }, { []string{"data{1...4}"}, []uint64{4}, [][]uint64{{4}}, true, }, { []string{"data/controller1/export{1...10}, data/controller2/export{1...10}, data/controller3/export{1...10}"}, []uint64{10, 10, 10},
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.2K bytes - Viewed (0) -
pkg/controller/controller_utils.go
return func() time.Duration { return resyncPeriod } } // Expectations are a way for controllers to tell the controller manager what they expect. eg: // ControllerExpectations: { // controller1: expects 2 adds in 2 minutes // controller2: expects 2 dels in 2 minutes // controller3: expects -1 adds in 2 minutes => controller3's expectations have already been met // } // // Implementation:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
pilot/pkg/autoregistration/internal/health/controller.go
} c.healthCondition = controllers.NewQueue("healthcheck", controllers.WithMaxAttempts(maxRetries), controllers.WithGenericReconciler(c.updateWorkloadEntryHealth)) return c } func (c *Controller) Run(stop <-chan struct{}) { c.healthCondition.Run(stop) } // QueueWorkloadEntryHealth enqueues the associated WorkloadEntries health status. func (c *Controller) QueueWorkloadEntryHealth(proxy *model.Proxy, event HealthEvent) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.4K bytes - Viewed (0) -
architecture/networking/controllers.md
## Writing Controllers The `controllers` package offers a variety of helpers for writing controllers. These operate in a similar manner as [`controller-runtime`](https://github.com/kubernetes-sigs/controller-runtime) but are *far* smaller and less abstract. With a few exceptions, Istio controllers typically are split in two phases: construction and running.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 09 17:41:25 UTC 2024 - 4.9K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/controller.go
// re-convert ingress to new-vs. c.services.AddEventHandler(controllers.FromEventHandler(func(o controllers.Event) { c.onServiceEvent(o) })) return c } func (c *controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("ingress", stop, c.ingress.HasSynced, c.services.HasSynced, c.classes.HasSynced) c.queue.Run(stop) controllers.ShutdownAll(c.ingress, c.services, c.classes) }
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/autoregistration/controller.go
} } c := &Controller{ instanceID: instanceID, store: store, cleanupLimit: rate.NewLimiter(rate.Limit(20), 1), cleanupQueue: queue.NewDelayed(), adsConnections: newAdsConnections(), maxConnectionAge: maxConnAge, } c.queue = controllers.NewQueue("unregister_workloadentry", controllers.WithMaxAttempts(maxRetries),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller.go
) *Controller { o := Options{ WatchedNamespace: ns, CABundleWatcher: caBundleWatcher, Revision: revision, ServiceName: "istiod", } return newController(o, client) } func newController(o Options, client kube.Client) *Controller { c := &Controller{ o: o, client: client, } c.queue = controllers.NewQueue("validation",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 28 16:52:19 UTC 2024 - 11.3K bytes - Viewed (0) -
operator/pkg/controller/controller.go
// See the License for the specific language governing permissions and // limitations under the License. package controller import ( "sigs.k8s.io/controller-runtime/pkg/manager" "istio.io/istio/operator/pkg/controller/istiocontrolplane" ) // AddToManager adds all Controllers to the Manager func AddToManager(m manager.Manager, options *istiocontrolplane.Options) error { return istiocontrolplane.Add(m, options)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 03 18:04:16 UTC 2021 - 902 bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
"istio.io/istio/pkg/util/sets" ) // The aggregate controller does not implement serviceregistry.Instance since it may be comprised of various // providers and clusters. var ( _ model.ServiceDiscovery = &Controller{} _ model.AggregateController = &Controller{} ) // Controller aggregates data across different registries and monitors for changes type Controller struct { meshHolder mesh.Holder
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/config/memory/controller.go
// made on the client. func NewController(cs model.ConfigStore) *Controller { out := &Controller{ configStore: cs, monitor: NewMonitor(cs), } return out } // NewSyncController return an implementation of model.ConfigStoreController which processes events synchronously func NewSyncController(cs model.ConfigStore) *Controller { out := &Controller{ configStore: cs, monitor: NewSyncMonitor(cs), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 26 13:54:32 UTC 2023 - 4.7K bytes - Viewed (0)