- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for WasmPlugins (0.66 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)