Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 38 for serviceOf (0.18 sec)

  1. cmd/streaming-signature-v4.go

    		getScope(cr.seedDate, cr.region) + "\n" +
    		cr.seedSignature + "\n" +
    		emptySHA256 + "\n" +
    		hashedChunk
    
    	// Get hmac signing key.
    	signingKey := getSigningKey(cr.cred.SecretKey, cr.seedDate, cr.region, serviceS3)
    
    	// Calculate signature.
    	newSignature := getSignature(signingKey, stringToSign)
    
    	return newSignature
    }
    
    // getTrailerChunkSignature - get trailer chunk signature.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  2. cmd/signature-v4_test.go

    				},
    				"X-Amz-Date": []string{now.Format(iso8601Format)},
    				"X-Amz-Signature": []string{
    					getSignature(getSigningKey(globalActiveCred.SecretKey, now,
    						globalMinioDefaultRegion, serviceS3), "policy"),
    				},
    				"Policy": []string{"policy"},
    			},
    			expected: ErrNone,
    		},
    	}
    
    	// Run each test case individually.
    	for i, testCase := range testCases {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/envoyfilter/cluster_patch_test.go

    				Context: networking.EnvoyFilter_SIDECAR_INBOUND,
    				ObjectTypes: &networking.EnvoyFilter_EnvoyConfigObjectMatch_Cluster{
    					Cluster: &networking.EnvoyFilter_ClusterMatch{
    						Service: "service.servicens",
    					},
    				},
    			},
    			Patch: &networking.EnvoyFilter_Patch{
    				Operation: networking.EnvoyFilter_Patch_MERGE,
    				Value:     buildPatchStruct(`{"type":"EDS"}`),
    			},
    		},
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top