Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for networkIDCallback (0.17 sec)

  1. pilot/pkg/serviceregistry/serviceentry/workloadentry.go

    		return ""
    	}
    	// 1. first check the wle.Network
    	if wle.Network != "" {
    		return network.ID(wle.Network)
    	}
    
    	// 2. fall back to the passed in getNetworkCb func.
    	if s.networkIDCallback != nil {
    		return s.networkIDCallback(wle.Address, wle.Labels)
    	}
    	return ""
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 11 03:34:47 UTC 2022
    - 1.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/controller.go

    	edsQueue queue.Instance
    
    	workloadHandlers []func(*model.WorkloadInstance, model.Event)
    
    	// callback function used to get the networkID according to workload ip and labels.
    	networkIDCallback func(IP string, labels labels.Instance) network.ID
    
    	// Indicates whether this controller is for workload entries.
    	workloadEntryController bool
    
    	meshWatcher mesh.Watcher
    
    	model.NoopAmbientIndexes
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/conversion_test.go

    				},
    				PortMap: map[string]uint32{
    					"http": 80,
    				},
    			},
    		},
    	}
    
    	for _, tt := range workloadInstanceTests {
    		t.Run(tt.name, func(t *testing.T) {
    			s := &Controller{networkIDCallback: tt.getNetworkIDCb, meshWatcher: mesh.NewFixedWatcher(mesh.DefaultMeshConfig())}
    			instance := s.convertWorkloadEntryToWorkloadInstance(tt.wle, cluster.ID(clusterID))
    			if err := compare(t, instance, tt.out); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 39K bytes
    - Viewed (0)
Back to top