Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 53 for serviceOf (0.31 sec)

  1. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go

    			rbacv1helpers.NewRule("get", "list", "watch").Groups(legacyGroup).Resources("services", "pods", "nodes").RuleOrDie(),
    			// The controller needs to be able to set a service's finalizers to be able to create an EndpointSlice
    			// resource that is owned by the service and sets blockOwnerDeletion=true in its ownerRef.
    			rbacv1helpers.NewRule("update").Groups(legacyGroup).Resources("services/finalizers").RuleOrDie(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  2. platforms/enterprise/enterprise/src/integTest/groovy/org/gradle/internal/enterprise/BaseBuildScanPluginCheckInFixture.groovy

                        def checkInService = settings.gradle.services.get($GradleEnterprisePluginCheckInService.name)
    
                        def result = checkInService.checkIn(pluginMetadata, serviceFactory)
                        if (result.unsupportedMessage == null) {
                            println "${propertyPrefix}.checkIn.supported"
                            settings.gradle.extensions.add("serviceRef", result.pluginServiceRef)
                        } else {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue May 21 11:17:11 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  3. pilot/pkg/model/config.go

    var _ = udpa.TypedStruct{}
    
    type ConfigHash uint64
    
    // ConfigKey describe a specific config item.
    // In most cases, the name is the config's name. However, for ServiceEntry it is service's FQDN.
    type ConfigKey struct {
    	Kind      kind.Kind
    	Name      string
    	Namespace string
    }
    
    func (key ConfigKey) HashCode() ConfigHash {
    	h := hash.New()
    	h.Write([]byte{byte(key.Kind)})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 08:51:03 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  4. istioctl/pkg/validate/validate_test.go

    metadata:
      resourceVersion: ""`
    	udpService = `
    kind: Service
    metadata:
      name: hello
    spec:
      ports:
        -
          protocol: udp`
    	skippedService = `
    kind: Service
    metadata:
      name: hello
      namespace: istio-system
    spec:
      ports:
        -
          name: http
          port: 9080`
    	validPortNamingSvc = `
    apiVersion: v1
    kind: Service
    metadata:
      name: hello
    spec:
      ports:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jul 25 08:08:36 UTC 2023
    - 21.5K bytes
    - Viewed (0)
  5. pkg/apis/core/v1/helper/helpers.go

    	return strings.HasPrefix(string(name), v1.ResourceAttachableVolumesPrefix)
    }
    
    // IsServiceIPSet aims to check if the service's ClusterIP is set or not
    // the objective is not to perform validation here
    func IsServiceIPSet(service *v1.Service) bool {
    	return service.Spec.ClusterIP != v1.ClusterIPNone && service.Spec.ClusterIP != ""
    }
    
    // GetAccessModesAsString returns a string representation of an array of access modes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 23:03:54 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  6. pkg/registry/core/service/portallocator/controller/repair.go

    				c.recorder.Eventf(svc, nil, corev1.EventTypeWarning, "PortAlreadyAllocated", "PortAllocation", "Port %d was assigned to multiple services; please recreate service", port)
    				runtime.HandleError(fmt.Errorf("the node port %d for service %s/%s was assigned to multiple services; please recreate", port, svc.Name, svc.Namespace))
    			case err.(*portallocator.ErrNotInRange):
    				// port is out of range, reallocate
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  7. pkg/proxy/endpointschangetracker.go

    	// NewlyActiveUDPServices identifies UDP Services that have just gone from 0 to
    	// non-0 endpoints. Existing conntrack entries caching the fact that these
    	// services are black holes must be deleted to ensure that traffic can immediately
    	// begin flowing to the new endpoints.
    	NewlyActiveUDPServices []ServicePortName
    
    	// List of the trigger times for all endpoints objects that changed. It's used to export the
    	// network programming latency.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  8. pkg/apis/core/helper/helpers.go

    }
    
    // IsServiceIPSet aims to check if the service's ClusterIP is set or not
    // the objective is not to perform validation here
    func IsServiceIPSet(service *core.Service) bool {
    	// This function assumes that the service is semantically validated
    	// it does not test if the IP is valid, just makes sure that it is set.
    	return len(service.Spec.ClusterIP) > 0 &&
    		service.Spec.ClusterIP != core.ClusterIPNone
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Oct 28 07:31:28 UTC 2023
    - 16.1K bytes
    - Viewed (0)
  9. pkg/registry/core/service/storage/alloc.go

    		// the validation allows it
    		if len(service.Spec.IPFamilies) < 2 {
    			if *(service.Spec.IPFamilyPolicy) != api.IPFamilyPolicySingleStack {
    				// add the alt ipfamily
    				if service.Spec.IPFamilies[0] == api.IPv4Protocol {
    					service.Spec.IPFamilies = append(service.Spec.IPFamilies, api.IPv6Protocol)
    				} else {
    					service.Spec.IPFamilies = append(service.Spec.IPFamilies, api.IPv4Protocol)
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 37.3K bytes
    - Viewed (0)
  10. cmd/signature-v4-utils_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    		if testCase.h != "" {
    			r.Header.Set("x-amz-content-sha256", testCase.h)
    		}
    		r.ParseForm()
    		got := getContentSha256Cksum(r, serviceS3)
    		if got != testCase.expected {
    			t.Errorf("Test %d: got:%s expected:%s", i+1, got, testCase.expected)
    		}
    	}
    }
    
    // Test TestCheckMetaHeaders tests the logic of checkMetaHeaders() function
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 05 21:26:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
Back to top