- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 52 for NamespacedName (0.3 sec)
-
pilot/pkg/model/telemetry.go
type Telemetry struct { Name string `json:"name"` Namespace string `json:"namespace"` Spec *tpb.Telemetry `json:"spec"` } func (t *Telemetry) NamespacedName() types.NamespacedName { return types.NamespacedName{Name: t.Name, Namespace: t.Namespace} } // Telemetries organizes Telemetry configuration by namespace. type Telemetries struct { // Maps from namespace to the Telemetry configs.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 18:14:09 UTC 2024 - 35.2K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
events kclient.EventRecorder repairedPods map[types.NamespacedName]types.UID } func NewRepairController(client kube.Client, cfg config.RepairConfig) (*Controller, error) { c := &Controller{ cfg: cfg, client: client, events: kclient.NewEventRecorder(client, "cni-repair"), repairedPods: map[types.NamespacedName]types.UID{}, } fieldSelectors := []string{} if cfg.FieldSelectors != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
security/pkg/server/ca/node_auth_test.go
TrustDomain: "cluster.local", Namespace: p.namespace, ServiceAccount: p.account, }.String() } func TestSingleClusterNodeAuthorization(t *testing.T) { allowZtunnel := map[types.NamespacedName]struct{}{ {Name: "ztunnel", Namespace: "istio-system"}: {}, } ztunnelCaller := security.KubernetesInfo{ PodName: "ztunnel-a", PodNamespace: "istio-system", PodUID: "12345",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.5K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
func PodOnNodeFromDaemonset(node string, name, namespace string, client kube.Client) (types.NamespacedName, error) { ds, err := client.Kube().AppsV1().DaemonSets(namespace).Get(context.Background(), name, metav1.GetOptions{}) if err != nil { return types.NamespacedName{}, err } selector := ds.Spec.Selector if selector == nil { return types.NamespacedName{}, fmt.Errorf("selector is required") } sel := selector.MatchLabels
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
func TestClusterLocal(t *testing.T) { framework.NewTest(t). RequireIstioVersion("1.11"). Run(func(t framework.TestContext) { serviceA = match.ServiceName(echo.NamespacedName{Name: common.ServiceA, Namespace: echos.Namespace}) serviceB = match.ServiceName(echo.NamespacedName{Name: common.ServiceB, Namespace: echos.Namespace}) // Don't export service B in any cluster. All requests should stay in-cluster. for _, ht := range hostTypes {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/model/telemetry_test.go
actual := getInterval(tc.input, tc.defaultVal) assert.Equal(t, tc.expected, actual) }) } } func Test_appendApplicableTelemetries(t *testing.T) { namespacedName := types.NamespacedName{ Name: "my-telemetry", Namespace: "my-namespace", } emptyStackDriverTracing := &tpb.Tracing{ Match: &tpb.Tracing_TracingSelector{ Mode: tpb.WorkloadMode_CLIENT, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 39.6K bytes - Viewed (0) -
tests/integration/security/file_mounted_certs/main_test.go
return nil } func createCustomInstances(apps *deployment.SingleNamespaceView) error { for index, namespacedName := range apps.EchoNamespace.All.NamespacedNames() { switch { case namespacedName.Name == "client": client = apps.EchoNamespace.All[index] case namespacedName.Name == "server": server = apps.EchoNamespace.All[index] } } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 13.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
func (f fakeInstance) Instances() echo.Instances { return echo.Instances{f} } func (f fakeInstance) ID() resource.ID { panic("implement me") } func (f fakeInstance) NamespacedName() echo.NamespacedName { return f.Config().NamespacedName() } func (f fakeInstance) PortForName(name string) echo.Port { return f.Config().Ports.MustForName(name) } func (f fakeInstance) Config() echo.Config {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source.go
policies atomic.Pointer[[]PolicyHook[P, B, E]] // Whether the cache of policies is dirty and needs to be recompiled policiesDirty atomic.Bool lock sync.Mutex compiledPolicies map[types.NamespacedName]compiledPolicyEntry[E] // Temporary until we use the dynamic informer factory paramsCRDControllers map[schema.GroupVersionKind]*paramInfo } type paramInfo struct { mapping meta.RESTMapping
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 21 23:07:34 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/model/service.go
MeshExternal bool // ResourceVersion represents the internal version of this object. ResourceVersion string } func (s *Service) NamespacedName() types.NamespacedName { return types.NamespacedName{Name: s.Attributes.Name, Namespace: s.Attributes.Namespace} } func (s *Service) Key() string { if s == nil { return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0)