- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 3,056 for controllee (0.16 sec)
-
cni/pkg/repair/repaircontroller.go
FieldSelector: strings.Join(fieldSelectors, ","), }) c.queue = controllers.NewQueue("repair pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject)) return c, nil } func (c *Controller) Run(stop <-chan struct{}) { kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced) c.queue.Run(stop) c.pods.ShutdownHandlers()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/artifacts/guestbook/redis-master-controller.yaml
Davanum Srinivas <******@****.***> 1652185809 -0400
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 502 bytes - Viewed (0) -
pkg/kube/inject/testdata/inject/truncate-canonical-name-custom-controller-pod.yaml.injected
service.istio.io/canonical-name: helloworld-helloworld-helloworld-helloworld-helloworld-hellowo service.istio.io/canonical-revision: latest name: helloworld-helloworld ownerReferences: - apiVersion: foo/v1 controller: true kind: Bar name: helloworld-helloworld-helloworld-helloworld-helloworld-hellowo-ld uid: 12345678-1234-1234-1234-123456789012 spec: containers: - image: fake.docker.io/google-samples/hello-go-gke:1.0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 16:55:16 UTC 2024 - 5.9K bytes - Viewed (0) -
pkg/controller/doc.go
See the License for the specific language governing permissions and limitations under the License. */ // Package controller contains code for controllers (like the replication // controller).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jul 16 17:48:21 UTC 2016 - 725 bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/autoserviceexportcontroller.go
client: opts.Client, mcsSupported: true, } c.queue = controllers.NewQueue("auto export", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.services = kclient.NewFiltered[*v1.Service](opts.Client, kubetypes.Filter{ObjectFilter: opts.Client.ObjectFilter()}) // Only handle add. The controller only acts on parts of the service
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.7K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/artifacts/redis-master-controller.yaml
Davanum Srinivas <******@****.***> 1652185809 -0400
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 502 bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/pod_controller.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/tools/cache" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/controllers" "istio.io/istio/pkg/queue" "istio.io/istio/pkg/test/framework/components/echo" ) var _ cache.Controller = &podController{} type podHandler func(pod *corev1.Pod) error type podHandlers struct { added podHandler updated podHandler deleted podHandler
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 2.6K bytes - Viewed (1) -
pkg/kube/krt/README.md
```text name time/op Controllers/krt-8 13.4ms ±23% Controllers/legacy-8 11.4ms ± 6% name alloc/op Controllers/krt-8 15.2MB ± 0% Controllers/legacy-8 12.9MB ± 0% ``` ### Future work #### Object optimizations One important aspect of `krt` is its ability to automatically detect if objects have changed, and only trigger dependencies if so.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 18 17:21:50 UTC 2023 - 11.8K bytes - Viewed (0) -
cmd/kube-controller-manager/app/discovery.go
// components. This includes replication controllers, service endpoints and // nodes. package app import ( "context" "k8s.io/controller-manager/controller" "k8s.io/kubernetes/cmd/kube-controller-manager/names" endpointslicecontroller "k8s.io/kubernetes/pkg/controller/endpointslice" endpointslicemirroringcontroller "k8s.io/kubernetes/pkg/controller/endpointslicemirroring" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 3.1K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
} t0 := time.Now() cl.logger.Infof("Starting Pilot K8S CRD controller") if !kube.WaitForCacheSync("crdclient", stop, cl.informerSynced) { cl.logger.Errorf("Failed to sync Pilot K8S CRD controller cache") return } cl.logger.Infof("Pilot K8S CRD controller synced in %v", time.Since(t0)) cl.queue.Run(stop) cl.logger.Infof("controller terminated") } func (cl *Client) informerSynced() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0)