Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,361 for controllee (0.15 sec)

  1. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/controller_ref.go

    	}
    	return ref.UID == owner.GetUID()
    }
    
    // GetControllerOf returns a pointer to a copy of the controllerRef if controllee has a controller
    func GetControllerOf(controllee Object) *OwnerReference {
    	ref := GetControllerOfNoCopy(controllee)
    	if ref == nil {
    		return nil
    	}
    	cp := *ref
    	cp.Controller = ptr.To(*ref.Controller)
    	if ref.BlockOwnerDeletion != nil {
    		cp.BlockOwnerDeletion = ptr.To(*ref.BlockOwnerDeletion)
    	}
    	return &cp
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 05:14:33 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. pilot/pkg/autoregistration/internal/health/controller.go

    	condition *v1alpha1.IstioCondition
    }
    
    // Controller knows how to update health status of a workload.
    type Controller struct {
    	stateStore *state.Store
    
    	// healthCondition is a fifo queue used for updating health check status
    	healthCondition controllers.Queue
    }
    
    // NewController returns a new Controller instance.
    func NewController(stateStore *state.Store, maxRetries int) *Controller {
    	c := &Controller{
    		stateStore: stateStore,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Sep 19 20:41:55 UTC 2023
    - 3.4K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top