Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for WasmPlugins (0.66 sec)

  1. pilot/pkg/networking/core/extension/wasmplugin_test.go

    	testCases := []struct {
    		name        string
    		wasmPlugins []*model.WasmPluginWrapper
    		names       []string
    		expectedECs []*core.TypedExtensionConfig
    	}{
    		{
    			name:        "empty",
    			wasmPlugins: []*model.WasmPluginWrapper{},
    			names:       []string{someAuthNFilter.Name},
    			expectedECs: []*core.TypedExtensionConfig{},
    		},
    		{
    			name: "authn",
    			wasmPlugins: []*model.WasmPluginWrapper{
    				someAuthNFilter,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/extension/wasmplugin.go

    func InsertedExtensionConfigurations(
    	wasmPlugins []*model.WasmPluginWrapper,
    	names []string, pullSecrets map[string][]byte,
    ) []*core.TypedExtensionConfig {
    	result := make([]*core.TypedExtensionConfig, 0)
    	if len(wasmPlugins) == 0 {
    		return result
    	}
    	hasName := sets.New(names...)
    	for _, p := range wasmPlugins {
    		if !hasName.Contains(p.ResourceName) {
    			continue
    		}
    		switch {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. pilot/pkg/xds/ecds.go

    	// TODO: we get the WasmPlugins here to get the secrets reference in order to decide whether ECDS push is needed,
    	//       and we will get it again at extension config build. Avoid getting it twice if this becomes a problem.
    	watched := sets.New(resourceNames...)
    	wasmPlugins := push.WasmPlugins(proxy)
    	referencedSecrets := sets.String{}
    	for _, wps := range wasmPlugins {
    		for _, wp := range wps {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Jan 16 18:25:42 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/extension_config_builder.go

    	envoyFilterPatches := push.EnvoyFilters(proxy)
    	extensions := envoyfilter.InsertedExtensionConfigurations(envoyFilterPatches, extensionConfigNames)
    	wasmPlugins := push.WasmPluginsByName(proxy, parseExtensionName(extensionConfigNames))
    	extensions = append(extensions, extension.InsertedExtensionConfigurations(wasmPlugins, extensionConfigNames, pullSecrets)...)
    	return extensions
    }
    
    func parseExtensionName(names []string) []types.NamespacedName {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. pilot/pkg/model/push_context_test.go

    				extensions.PluginPhase_AUTHN: {
    					convertToWasmPluginWrapper(wasmPlugins["authn-med-prio-all"]),
    					convertToWasmPluginWrapper(wasmPlugins["authn-low-prio-all-network"]),
    					convertToWasmPluginWrapper(wasmPlugins["authn-low-prio-all"]),
    					convertToWasmPluginWrapper(wasmPlugins["global-authn-low-prio-ingress"]),
    				},
    			},
    		},
    		{
    			name: "testns-2",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 95.3K bytes
    - Viewed (0)
  6. pkg/config/schema/kubeclient/resources.gen.go

    		}
    	case gvr.WasmPlugin:
    		l = func(options metav1.ListOptions) (runtime.Object, error) {
    			return c.Istio().ExtensionsV1alpha1().WasmPlugins(opts.Namespace).List(context.Background(), options)
    		}
    		w = func(options metav1.ListOptions) (watch.Interface, error) {
    			return c.Istio().ExtensionsV1alpha1().WasmPlugins(opts.Namespace).Watch(context.Background(), options)
    		}
    	case gvr.WorkloadEntry:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 13:57:51 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  7. pkg/config/schema/collections/collections.agent.gen.go

    		ValidateProto: validation.ValidateVirtualService,
    	}.MustBuild()
    
    	WasmPlugin = resource.Builder{
    		Identifier: "WasmPlugin",
    		Group:      "extensions.istio.io",
    		Kind:       "WasmPlugin",
    		Plural:     "wasmplugins",
    		Version:    "v1alpha1",
    		Proto:      "istio.extensions.v1alpha1.WasmPlugin", StatusProto: "istio.meta.v1alpha1.IstioStatus",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  8. pkg/config/schema/gvr/resources.gen.go

    	WasmPlugin                     = schema.GroupVersionResource{Group: "extensions.istio.io", Version: "v1alpha1", Resource: "wasmplugins"}
    	WorkloadEntry                  = schema.GroupVersionResource{Group: "networking.istio.io", Version: "v1alpha3", Resource: "workloadentries"}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 17:37:32 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  9. pilot/pkg/model/push_context.go

    }
    
    // pre computes WasmPlugins per namespace
    func (ps *PushContext) initWasmPlugins(env *Environment) {
    	wasmplugins := env.List(gvk.WasmPlugin, NamespaceAll)
    
    	sortConfigByCreationTime(wasmplugins)
    	ps.wasmPluginsByNamespace = map[string][]*WasmPluginWrapper{}
    	for _, plugin := range wasmplugins {
    		if pluginWrapper := convertToWasmPluginWrapper(plugin); pluginWrapper != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
  10. pilot/pkg/config/kube/crdclient/types.gen.go

    			ObjectMeta: objMeta,
    			Spec:       *(cfg.Spec.(*istioioapinetworkingv1alpha3.VirtualService)),
    		}, metav1.CreateOptions{})
    	case gvk.WasmPlugin:
    		return c.Istio().ExtensionsV1alpha1().WasmPlugins(cfg.Namespace).Create(context.TODO(), &apiistioioapiextensionsv1alpha1.WasmPlugin{
    			ObjectMeta: objMeta,
    			Spec:       *(cfg.Spec.(*istioioapiextensionsv1alpha1.WasmPlugin)),
    		}, metav1.CreateOptions{})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 17:37:32 UTC 2024
    - 62.2K bytes
    - Viewed (0)
Back to top