Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetCode (0.14 sec)

  1. pkg/config/analysis/analyzers/destinationrule/ca-certificates.go

    	dr := r.Message.(*v1alpha3.DestinationRule)
    	drNs := r.Metadata.FullName.Namespace
    	drName := r.Metadata.FullName.String()
    	mode := dr.GetTrafficPolicy().GetTls().GetMode()
    	if mode == v1alpha3.ClientTLSSettings_SIMPLE || mode == v1alpha3.ClientTLSSettings_MUTUAL {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 07:22:31 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. pilot/pkg/model/gateway.go

    				if gatewayConfig.Namespace == proxy.VerifiedIdentity.Namespace && parse.Namespace == proxy.VerifiedIdentity.Namespace {
    					// Same namespace is always allowed
    					verifiedCertificateReferences.Insert(rn)
    					if s.GetTls().GetMode() == networking.ServerTLSSettings_MUTUAL {
    						verifiedCertificateReferences.Insert(rn + credentials.SdsCaSuffix)
    					}
    				} else if ps.ReferenceAllowed(gvk.Secret, rn, proxy.VerifiedIdentity.Namespace) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/cluster_builder.go

    	util.AddSubsetToMetadata(subsetCluster.cluster.Metadata, subset.Name)
    	subsetCluster.cluster.Metadata = util.AddALPNOverrideToMetadata(subsetCluster.cluster.Metadata, opts.policy.GetTls().GetMode())
    	return subsetCluster.build()
    }
    
    // applyDestinationRule applies the destination rule if it exists for the Service.
    // It returns the subset clusters if any created as it applies the destination rule.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/cluster.go

    		port := int(instance.Port.TargetPort)
    		clustersToBuild[port] = append(clustersToBuild[port], instance)
    	}
    
    	bind := actualLocalHosts[0]
    	if cb.req.Push.Mesh.GetInboundTrafficPolicy().GetMode() == meshconfig.MeshConfig_InboundTrafficPolicy_PASSTHROUGH {
    		bind = ""
    	}
    	// For each workload port, we will construct a cluster
    	for epPort, instances := range clustersToBuild {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet.go

    			secretManager = secret.NewCachingSecretManager(
    				klet.kubeClient, manager.GetObjectTTLFromNodeFunc(klet.GetNode))
    			configMapManager = configmap.NewCachingConfigMapManager(
    				klet.kubeClient, manager.GetObjectTTLFromNodeFunc(klet.GetNode))
    		case kubeletconfiginternal.GetChangeDetectionStrategy:
    			secretManager = secret.NewSimpleSecretManager(klet.kubeClient)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods.go

    				// when the pod specifies an fsGroup, and if the directory is not created here, Docker will
    				// later auto-create it with the incorrect mode 0750
    				// Make extra care not to escape the volume!
    				perm, err := hu.GetMode(volumePath)
    				if err != nil {
    					return nil, cleanupAction, err
    				}
    				if err := subpather.SafeMakeDir(subPath, volumePath, perm); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top