Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for register_handler (0.12 sec)

  1. pkg/kube/multicluster/fake.go

    // limitations under the License.
    
    package multicluster
    
    import (
    	"istio.io/istio/pkg/cluster"
    	"istio.io/istio/pkg/kube"
    )
    
    type Fake struct {
    	handlers []handler
    }
    
    func (f *Fake) registerHandler(h handler) {
    	f.handlers = append(f.handlers, h)
    }
    
    func (f *Fake) Add(id cluster.ID, client kube.Client, stop chan struct{}) {
    	for _, handler := range f.handlers {
    		handler.clusterAdded(&Cluster{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 19:18:21 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go

    			ObjectFilter: ec.client.ObjectFilter(),
    		})
    		// Register callbacks for events.
    		registerHandlers(ec.Controller, ec.serviceExports, "ServiceExports", ec.onServiceExportEvent, nil)
    
    		// Set the discoverability policy for the clusterset.local host.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.5K bytes
    - Viewed (0)
Back to top