- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 3,056 for controllee (0.14 sec)
-
tensorflow/c/experimental/ops/gen/common/controller.h
#include "tensorflow/core/platform/env.h" #include "tensorflow/core/platform/types.h" namespace tensorflow { namespace generator { class Controller { public: explicit Controller(PathConfig path_config, Env* env = Env::Default()); virtual ~Controller(); const void WriteFile(const string& file_path, const SourceCode& code) const; const std::vector<OpSpec>& GetModelOps() const; private:
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Mon Jun 21 18:51:25 UTC 2021 - 1.8K bytes - Viewed (0) -
pkg/config/analysis/incluster/controller.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/util/concurrent" "istio.io/istio/pkg/util/sets" ) // 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,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
"k8s.io/kubernetes/pkg/controlplane/reconcilers" ) const ( kubernetesServiceName = "kubernetes" ) // Controller is the controller manager for the core bootstrap Kubernetes // controller loops, which manage creating the "kubernetes" service and // provide the IP repair check on service IPs type Controller struct { Config client kubernetes.Interface serviceLister v1listers.ServiceLister
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/controller.go
// Controller defines the controller for the gateway-api. The controller acts a bit different from most. // Rather than watching the CRs directly, we depend on the existing model.ConfigStoreController which // already watches all CRs. When there are updates, a new PushContext will be computed, which will eventually // call Controller.Reconcile(). Once this happens, we will inspect the current state of the world, and transform
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
clock clock.Clock } // NewController returns a Controller struct. func NewController(cs kubernetes.Interface) *Controller { return newController(cs, clock.RealClock{}, rate.NewLimiter(rate.Every(30*time.Minute), 1)) } func newController(cs kubernetes.Interface, cl clock.Clock, limiter *rate.Limiter) *Controller {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go
listers "k8s.io/apiextensions-apiserver/pkg/client/listers/apiextensions/v1" "k8s.io/apiextensions-apiserver/pkg/controller/openapi/builder" ) // Controller watches CustomResourceDefinitions and publishes validation schema type Controller struct { crdLister listers.CustomResourceDefinitionLister crdsSynced cache.InformerSynced // To allow injection for testing. syncFn func(string) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
"k8s.io/apimachinery/pkg/util/wait" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/cache/synctrack" "k8s.io/client-go/util/workqueue" "k8s.io/klog/v2" ) var _ Controller[runtime.Object] = &controller[runtime.Object]{} type controller[T runtime.Object] struct { informer Informer[T] queue workqueue.TypedRateLimitingInterface[string] // Returns an error if there was a transient error during reconciliation
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
for _, obj := range objs { ec.enqueuePod(logger, obj, false) } } func (ec *Controller) Run(ctx context.Context, workers int) { defer runtime.HandleCrash() defer ec.queue.ShutDown() logger := klog.FromContext(ctx) logger.Info("Starting resource claim controller") defer logger.Info("Shutting down resource claim controller") eventBroadcaster := record.NewBroadcaster(record.WithContext(ctx))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go
}, loadEncryptionConfig: encryptionconfig.LoadEncryptionConfig, } } // Run starts the controller and blocks until ctx is canceled. func (d *DynamicEncryptionConfigContent) Run(ctx context.Context) { defer utilruntime.HandleCrash() klog.InfoS("Starting controller", "name", d.name) defer klog.InfoS("Shutting down controller", "name", d.name) var wg sync.WaitGroup wg.Add(1) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.5K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/controller-role-bindings.yaml
labels: kubernetes.io/bootstrapping: rbac-defaults name: system:controller:attachdetach-controller roleRef: apiGroup: rbac.authorization.k8s.io kind: ClusterRole name: system:controller:attachdetach-controller subjects: - kind: ServiceAccount name: attachdetach-controller namespace: kube-system - apiVersion: rbac.authorization.k8s.io/v1 kind: ClusterRoleBinding metadata:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 16.9K bytes - Viewed (0)