- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 163 for NamespacedName (0.62 sec)
-
pilot/pkg/serviceregistry/kube/controller/controller.go
outMap[se.namespacedName] = mcsService } // Add the ServiceImport info. for _, si := range c.imports.ImportedServices() { mcsService := outMap[si.namespacedName] mcsService.Cluster = c.Cluster() mcsService.Name = si.namespacedName.Name mcsService.Namespace = si.namespacedName.Namespace mcsService.Imported = true mcsService.ClusterSetVIP = si.clusterSetVIP outMap[si.namespacedName] = mcsService }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/gatewayclass.go
return f })) return gc } func (c *ClassController) Run(stop <-chan struct{}) { // Ensure we initially reconcile the current state c.queue.Add(types.NamespacedName{}) c.queue.Run(stop) } func (c *ClassController) Reconcile(types.NamespacedName) error { err := istiomultierror.New() for class := range builtinClasses { err = multierror.Append(err, c.reconcileClass(class)) } return err.ErrorOrNil() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 20:48:23 UTC 2024 - 4K bytes - Viewed (0) -
pilot/pkg/model/extensions.go
if matcher.ShouldAttachPolicy(gvk.WasmPlugin, p.NamespacedName(), p) { return matchTrafficSelectors(p.Match, li) } // If it doesn't match one of the above cases, the plugin is not bound to this workload return false } func (p *WasmPluginWrapper) NamespacedName() types.NamespacedName { return types.NamespacedName{Name: p.Name, Namespace: p.Namespace} }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 11K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/run.go
testFn(ctx, fromInstance, destDeployments) }) }) }) } type gatewayInstance struct { types.NamespacedName GatewayClass string } func (gi gatewayInstance) ServiceName() types.NamespacedName { return types.NamespacedName{ Namespace: gi.Namespace, Name: gi.Name + "-" + gi.GatewayClass, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 27 22:08:42 UTC 2023 - 13K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matchers.go
func ServiceName(n echo.NamespacedName) Matcher { return func(i echo.Instance) bool { return n == i.NamespacedName() } } // AnyServiceName matches instances if they have the same Service and Namespace as any of the provided instances. func AnyServiceName(expected echo.NamespacedNames) Matcher { return func(instance echo.Instance) bool { serviceName := instance.NamespacedName() for _, expectedName := range expected {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/util_test.go
} }) } } func TestPodKeyByProxy(t *testing.T) { testCases := []struct { name string proxy *model.Proxy expectedKey types.NamespacedName }{ { name: "invalid id: bad format", proxy: &model.Proxy{ ID: "invalid", Metadata: &model.NodeMetadata{ Namespace: "default", }, }, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 20:45:12 UTC 2023 - 5K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
sc.destinationRulesByNames = make(map[types.NamespacedName]*config.Config) for _, c := range configs { c := c sc.destinationRulesByNames[types.NamespacedName{Name: c.Name, Namespace: c.Namespace}] = &c } } func (sc *SidecarScope) DestinationRuleByName(name, namespace string) *config.Config { if sc == nil { return nil } return sc.destinationRulesByNames[types.NamespacedName{ Name: name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/accessor.go
// which is cluster-scoped, so namespace is usually left blank. // But we leave the door open to add a namespaced vesion in the future GetPolicyName() types.NamespacedName GetParamRef() *v1.ParamRef GetMatchResources() *v1.MatchResources
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 1.2K bytes - Viewed (0)