Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for UInt32 (0.28 sec)

  1. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    type sandboxTemplate struct {
    	pod         *v1.Pod
    	attempt     uint32
    	createdAt   int64
    	state       runtimeapi.PodSandboxState
    	running     bool
    	terminating bool
    }
    
    // containerTemplate is a container template to create fake container.
    type containerTemplate struct {
    	pod            *v1.Pod
    	container      *v1.Container
    	sandboxAttempt uint32
    	attempt        int
    	createdAt      int64
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  2. pilot/pkg/config/kube/gateway/conversion.go

    	res := make([]*istio.HTTPRoute, 0, len(routes))
    	for _, r := range routes {
    		r = r.DeepCopy()
    		for _, m := range r.Match {
    			m.Port = uint32(port)
    		}
    		if len(r.Match) == 0 {
    			r.Match = []*istio.HTTPMatchRequest{{
    				Port: uint32(port),
    			}}
    		}
    		res = append(res, r)
    	}
    	return res
    }
    
    func augmentTCPPortMatch(routes []*istio.TCPRoute, port k8s.PortNumber) []*istio.TCPRoute {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_test.go

    			}, proxy)
    		})
    	})
    }
    
    func testPrivilegedPorts(t *testing.T, buildListeners func(t *testing.T, proxy *model.Proxy, port uint32) []*listener.Listener) {
    	privilegedPorts := []uint32{1, 80, 443, 1023}
    	unprivilegedPorts := []uint32{1024, 8080, 8443, 15443}
    	anyPorts := append(privilegedPorts, unprivilegedPorts...)
    
    	// multiple test cases to ensure that privileged ports get treated differently
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/sidecar_simulation_test.go

    		}
    		ret = append(ret, &model.ServiceInstance{
    			Service:     svc,
    			ServicePort: p,
    			Endpoint: &model.IstioEndpoint{
    				Address:         proxy.IPAddresses[0],
    				ServicePortName: p.Name,
    				EndpointPort:    uint32(targetPort),
    			},
    		})
    	}
    	return ret
    }
    
    func TestInboundClusters(t *testing.T) {
    	proxy := &model.Proxy{
    		IPAddresses: []string{"1.2.3.4"},
    		Metadata:    &model.NodeMetadata{},
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 84.7K bytes
    - Viewed (0)
Back to top