- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 3,056 for controllee (0.24 sec)
-
pilot/pkg/serviceregistry/kube/controller/controller.go
) ) // Options stores the configurable attributes of a Controller. type Options struct { SystemNamespace string // MeshServiceController is a mesh-wide service Controller. MeshServiceController *aggregate.Controller DomainSuffix string // ClusterID identifies the cluster which the controller communicate with. ClusterID cluster.ID
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
"k8s.io/client-go/util/workqueue" "k8s.io/component-helpers/storage/ephemeral" "k8s.io/kubernetes/pkg/controller/volume/common" ephemeralvolumemetrics "k8s.io/kubernetes/pkg/controller/volume/ephemeral/metrics" "k8s.io/kubernetes/pkg/controller/volume/events" ) // Controller creates PVCs for ephemeral inline volumes in a pod spec. type Controller interface { Run(ctx context.Context, workers int) } type ephemeralController struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/kubemark/controller.go
nodeGroupQueueSizeLock: sync.Mutex{}, } kubemarkNodeInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ UpdateFunc: controller.kubemarkCluster.removeUnneededNodes, }) return controller, nil } // WaitForCacheSync waits until all caches in the controller are populated. func (kubemarkController *KubemarkController) WaitForCacheSync(stopCh chan struct{}) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 17 23:02:17 UTC 2020 - 14.1K bytes - Viewed (0) -
cmd/kube-controller-manager/controller-manager.go
See the License for the specific language governing permissions and limitations under the License. */ // The controller manager is responsible for monitoring replication // controllers, and creating corresponding pods to achieve the desired // state. It uses the API to listen for new controllers and to create/delete // pods. package main import ( "os" _ "time/tzdata" // for CronJob Time Zone support
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 28 21:33:00 UTC 2022 - 1.3K 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/serviceregistry/serviceentry/controller.go
func (s *Controller) AppendWorkloadHandler(h func(*model.WorkloadInstance, model.Event)) { s.workloadHandlers = append(s.workloadHandlers, h) } // Run is used by some controllers to execute background jobs after init is done. func (s *Controller) Run(stopCh <-chan struct{}) { s.edsQueue.Run(stopCh) } // HasSynced always returns true for SE func (s *Controller) HasSynced() bool { return true }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/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 OpenAPI v3 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 - 7.9K bytes - Viewed (0) -
pkg/controller/validatingadmissionpolicystatus/controller.go
) // ControllerName has "Status" in it to differentiate this controller with the other that runs in API server. const ControllerName = "validatingadmissionpolicy-status" // Controller is the ValidatingAdmissionPolicy Status controller that reconciles the Status field of each policy object. // This controller runs type checks against referred types for each policy definition. type Controller struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 5.3K bytes - Viewed (0) -
pilot/pkg/model/controller.go
) type ServiceHandler func(*Service, *Service, Event) // Controller defines an event controller loop. Proxy agent registers itself // with the controller loop and receives notifications on changes to the // service topology or changes to the configuration artifacts. // // The controller guarantees the following consistency requirement: registry // view in the controller is as AT LEAST as fresh as the moment notification
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 25 06:54:32 UTC 2023 - 4.7K bytes - Viewed (0) -
tensorflow/c/experimental/ops/gen/common/controller.cc
namespace tensorflow { namespace generator { Controller::Controller(PathConfig path_config, Env* env) : env_(env), path_config_(path_config) { // Load the Op and API definitions InitializeOpApi(); // Convert the Op and API definitions to the internal data model BuildModel(); } Controller::~Controller() { delete api_def_map_; } const void Controller::WriteFile(const string& file_path,
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 21 09:51:28 UTC 2024 - 3.2K bytes - Viewed (0)