- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,811 for meth (0.14 sec)
-
pilot/pkg/xds/mesh_network_test.go
"testing" "time" corev1 "k8s.io/api/core/v1" discoveryv1 "k8s.io/api/discovery/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/util/rand" "istio.io/api/annotation" "istio.io/api/label" meshconfig "istio.io/api/mesh/v1alpha1" networking "istio.io/api/networking/v1alpha3" "istio.io/api/security/v1beta1" "istio.io/istio/pilot/pkg/features"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 24.6K bytes - Viewed (0) -
pilot/pkg/model/authorization_test.go
} environment := &Environment{ ConfigStore: store, Watcher: mesh.NewFixedWatcher(&meshconfig.MeshConfig{RootNamespace: "istio-config"}), } authzPolicies := GetAuthorizationPolicies(environment) return authzPolicies } func newConfig(name, ns string, spec config.Spec) config.Config { return config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.AuthorizationPolicy, Name: name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
if len(cb.req.Push.Mesh.InboundClusterStatName) != 0 { localCluster.cluster.AltStatName = telemetry.BuildStatPrefix(cb.req.Push.Mesh.InboundClusterStatName, string(instance.Service.Hostname), "", instance.Port.ServicePort, clusterPort, &instance.Service.Attributes) } opts := buildClusterOpts{ mesh: cb.req.Push.Mesh, mutable: localCluster, policy: nil,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
// limitations under the License. package controller import ( "sort" "strings" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" klabels "k8s.io/apimachinery/pkg/labels" "k8s.io/apimachinery/pkg/types" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/test/framework/components/istio/configmap.go
// Get the MeshConfig yaml from the config map. mcYAML, ok := cm.Data["mesh"] if !ok { return "", fmt.Errorf("mesh config was missing in istio config map for %s", c.Name()) } return mcYAML, nil } func setMeshConfigData(cm *corev1.ConfigMap, mcYAML string) { cm.Data["mesh"] = mcYAML } func yamlToMeshConfig(mcYAML string) (*meshconfig.MeshConfig, error) { // Parse the YAML.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/counter/file.go
minFileLen = 16 * 1024 ) func mappedHeader(meta string) ([]byte, error) { if len(meta) > maxMetaLen { return nil, fmt.Errorf("counter: metadata too large") } np := round(len(hdrPrefix), 4) n := round(np+4+len(meta), 32) hdr := make([]byte, n) copy(hdr, hdrPrefix) *(*uint32)(unsafe.Pointer(&hdr[np])) = uint32(n) copy(hdr[np+4:], meta) return hdr, nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/bootstrap/config.go
return ret } func getStatsOptions(meta *model.BootstrapNodeMetadata) []option.Instance { nodeIPs := meta.InstanceIPs config := meta.ProxyConfig tagAnno := meta.Annotations[annotation.SidecarExtraStatTags.Name] prefixAnno := meta.Annotations[annotation.SidecarStatsInclusionPrefixes.Name] RegexAnno := meta.Annotations[annotation.SidecarStatsInclusionRegexps.Name]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/conversion_test.go
}, }, }, } mesh := mesh.DefaultMeshConfig() mesh.IngressControllerMode = c.ingressMode if c.annotation != "" { ing.Annotations["kubernetes.io/ingress.class"] = c.annotation } if c.shouldProcess != shouldProcessIngressWithClass(mesh, &ing, c.ingressClass) { t.Errorf("got %v, want %v", !c.shouldProcess, c.shouldProcess)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 19 18:20:34 UTC 2023 - 14.9K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
if matchAmbient { log.Infof("Namespace %s is enabled in ambient mesh", namespace) } else { log.Infof("Namespace %s is disabled from ambient mesh", namespace) } for _, pod := range s.pods.List(namespace, klabels.Everything()) { // ztunnel pods are never "added to/removed from the mesh", so do not fire // spurious events for them to avoid triggering extra
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 21:31:35 UTC 2024 - 11.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime/schema" k8sv1 "sigs.k8s.io/gateway-api/apis/v1" "sigs.k8s.io/gateway-api/apis/v1beta1" "istio.io/api/label" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/config/schema/gvr"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0)