- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 2,243 for meth (0.07 sec)
-
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
"context" "fmt" "reflect" "testing" "time" v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/kubernetes" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pilot/pkg/keycertbundle" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/mesh" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/inject" "istio.io/istio/pkg/kube/kclient"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
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/serviceregistry/kube/controller/endpoint_builder.go
HealthStatus: healthStatus, NodeName: b.nodeName, } } // return the mesh network for the endpoint IP. Empty string if not found. func (b *EndpointBuilder) endpointNetwork(endpointIP string) network.ID { // If we're building the endpoint based on proxy meta, prefer the injected ISTIO_META_NETWORK value. if b.metaNetwork != "" { return b.metaNetwork }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4.8K 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/serviceregistry/kube/conversion.go
func kubeToIstioServiceAccount(saname string, ns string, mesh *meshconfig.MeshConfig) string { return spiffe.MustGenSpiffeURI(mesh, ns, saname) } // SecureNamingSAN creates the secure naming used for SAN verification from pod metadata func SecureNamingSAN(pod *corev1.Pod, mesh *meshconfig.MeshConfig) string { return spiffe.MustGenSpiffeURI(mesh, pod.Namespace, pod.Spec.ServiceAccountName) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9.4K 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) -
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/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) -
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)