Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 53 for serviceOf (0.3 sec)

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

    	for _, service := range services {
    		for _, serviceEntryPort := range serviceEntry.Ports {
    			if hostnameToServiceInstance {
    				// Note: only convert the hostname to service instance if WorkloadSelector is not set
    				// when service entry has discovery type DNS and no endpoints.
    				// We create endpoints from service's host, do not use serviceentry.hosts
    				// as a service entry is converted into multiple services (one for each host)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  2. pkg/registry/core/service/ipallocator/controller/repair.go

    				c.recorder.Eventf(&svc, nil, v1.EventTypeWarning, "ClusterIPAlreadyAllocated", "ClusterIPAllocation", "Cluster IP [%v]:%s was assigned to multiple services; please recreate service", family, ip)
    				runtime.HandleError(fmt.Errorf("the cluster IP [%v]:%s for service %s/%s was assigned to multiple services; please recreate", family, ip, svc.Name, svc.Namespace))
    			case err.(*ipallocator.ErrNotInRange):
    				// cluster IP is out of range
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  3. cmd/object-multipart-handlers.go

    			return
    		}
    	case authTypePresigned, authTypeSigned:
    		if s3Error = reqSignatureV4Verify(r, globalSite.Region(), serviceS3); s3Error != ErrNone {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Error), r.URL)
    			return
    		}
    
    		if !skipContentSha256Cksum(r) {
    			sha256hex = getContentSha256Cksum(r, serviceS3)
    		}
    	}
    
    	if err := enforceBucketQuotaHard(ctx, bucket, size); err != nil {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  4. cmd/handler-utils.go

    	}
    	return nil
    }
    
    // Returns access credentials in the request Authorization header.
    func getReqAccessCred(r *http.Request, region string) (cred auth.Credentials) {
    	cred, _, _ = getReqAccessKeyV4(r, region, serviceS3)
    	if cred.AccessKey == "" {
    		cred, _, _ = getReqAccessKeyV2(r)
    	}
    	return cred
    }
    
    // Extract request params to be sent with event notification.
    func extractReqParams(r *http.Request) map[string]string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  5. cmd/auth-handler_test.go

    	}
    
    	// Validates all testcases.
    	for i, testCase := range testCases {
    		s3Error := isReqAuthenticated(ctx, testCase.req, globalSite.Region(), serviceS3)
    		if s3Error != testCase.s3Error {
    			if _, err := io.ReadAll(testCase.req.Body); toAPIErrorCode(ctx, err) != testCase.s3Error {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  6. pkg/config/analysis/analyzers/analyzers_test.go

    		inputFiles: []string{"testdata/service-no-port-name.yaml"},
    		analyzer:   &service.PortNameAnalyzer{},
    		expected: []message{
    			{msg.PortNameIsNotUnderNamingConvention, "Service my-namespace1/my-service1"},
    			{msg.PortNameIsNotUnderNamingConvention, "Service my-namespace1/my-service1"},
    			{msg.PortNameIsNotUnderNamingConvention, "Service my-namespace2/my-service2"},
    		},
    	},
    	{
    		name:       "namedPort",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 07:22:31 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  7. pilot/pkg/model/virtualservice.go

    	"istio.io/istio/pkg/config/visibility"
    	"istio.io/istio/pkg/maps"
    	"istio.io/istio/pkg/util/protomarshal"
    	"istio.io/istio/pkg/util/sets"
    )
    
    // SelectVirtualServices selects the virtual services by matching given services' host names.
    // This function is used by sidecar converter.
    func SelectVirtualServices(vsidx virtualServiceIndex, configNamespace string, hostsByNamespace map[string]hostClassification) []config.Config {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 11:17:03 UTC 2024
    - 17.4K bytes
    - Viewed (0)
  8. pkg/controlplane/instance.go

    	// Values to build the IP addresses used by discovery
    	// The range of IPs to be assigned to services with type=ClusterIP or greater
    	ServiceIPRange net.IPNet
    	// The IP address for the GenericAPIServer service (must be inside ServiceIPRange)
    	APIServerServiceIP net.IP
    
    	// dual stack services, the range represents an alternative IP range for service IP
    	// must be of different family than primary (ServiceIPRange)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  9. pkg/proxy/ipvs/README.md

    Chain PREROUTING (policy ACCEPT)
    target     prot opt source               destination
    KUBE-SERVICES  all  --  0.0.0.0/0            0.0.0.0/0            /* kubernetes service portals */
    
    Chain OUTPUT (policy ACCEPT)
    target     prot opt source               destination
    KUBE-SERVICES  all  --  0.0.0.0/0            0.0.0.0/0            /* kubernetes service portals */
    
    Chain POSTROUTING (policy ACCEPT)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 20 02:32:29 UTC 2021
    - 18.8K bytes
    - Viewed (0)
  10. cmd/signature-v4-parser_test.go

    	}
    	if expectedCredentials.scope.service != actualCredential.scope.service {
    		t.Errorf("Test %d: service mismatch:Expected \"%s\", got \"%s\"", testNum, expectedCredentials.scope.service, actualCredential.scope.service)
    	}
    
    	if expectedCredentials.scope.request != actualCredential.scope.request {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 27.4K bytes
    - Viewed (0)
Back to top