- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 41 for Translator (0.19 sec)
-
operator/pkg/translate/translate_test.go
if err := util.UnmarshalWithJSONPB(tt.iopString, iop, true); err != nil { t.Fatal(err) } } translator := NewTranslator() serviceObj, err := object.ParseYAMLToK8sObject([]byte(serviceString)) assert.NoError(t, err) obj, err := translator.fixMergedObjectWithCustomServicePortOverlay(serviceObj, iop.Components.IngressGateways[0].GetK8S().GetService(), serviceObj) assert.NoError(t, err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 12 19:43:09 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/controller/volume/expand/expand_controller.go
queue workqueue.TypedRateLimitingInterface[string] translator CSINameTranslator csiMigratedPluginManager csimigration.PluginManager } // NewExpandController expands the pvs func NewExpandController( ctx context.Context, kubeClient clientset.Interface, pvcInformer coreinformers.PersistentVolumeClaimInformer, plugins []volume.VolumePlugin, translator CSINameTranslator,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/configuration/BeanConfigurationPathTranslator.java
* specific language governing permissions and limitations * under the License. */ package org.apache.maven.configuration; import java.io.File; /** * Postprocesses filesystem paths. For instance, a path translator might want to resolve relative paths given in the * bean configuration against some base directory. * */ public interface BeanConfigurationPathTranslator { /** * Translates the specified path.
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 1.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/doc.go
// stream proxies: streamtranslator.go and streamtunnel.go. Both of // these proxies allow the inter-connection of WebSocket and SPDY // streaming connections. // // The stream translator proxy is used for the RemoteCommand // subprotocol (e.g. kubectl exec, cp, and attach), and it connects // the output streams of a WebSocket connection (e.g. STDIN, STDOUT,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 17:56:46 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
if err := common.AddPodPVCIndexerIfNotPresent(controller.podIndexer); err != nil { return nil, fmt.Errorf("could not initialize attach detach controller: %w", err) } csiTranslator := csitrans.New() controller.translator = csiTranslator controller.csiMigratedPluginManager = csimigration.NewPluginManager(csiTranslator, utilfeature.DefaultFeatureGate) return controller, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_test.go
}, } translator := csitrans.New() cmpm := csimigration.NewPluginManager(translator, utilfeature.DefaultFeatureGate) logger, _ := ktesting.NewTestContext(t) for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { if tc.volumeAnnotations != nil { ann := tc.volumeAnnotations updateMigrationAnnotations(logger, cmpm, translator, ann, false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 43.4K bytes - Viewed (0) -
tests/fuzz/misc_fuzzers.go
f := fuzz.NewConsumer(data) f.AllowUnexportedFields() inInstallSpec := &v1alpha1.IstioOperatorSpec{} err := f.GenerateStruct(inInstallSpec) if err != nil { return 0 } inTranslator := &translate.Translator{} err = f.GenerateStruct(inTranslator) if err != nil { return 0 } if inTranslator.APIMapping == nil { return 0 } if inTranslator.KubernetesMapping == nil { return 0 }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 23 02:26:59 UTC 2022 - 5.1K bytes - Viewed (0) -
architecture/environments/operator.md
field of the [Translator](https://github.com/istio/operator/blob/e9097258cb4fbe59648e7da663cdad6f16927b8f/pkg/translate/translate.go#L52) struct. 1. The K8s settings are applied to resources in the output manifest using the [KubernetesMapping](https://github.com/istio/operator/blob/e9097258cb4fbe59648e7da663cdad6f16927b8f/pkg/translate/translate.go#L132)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 22:09:18 UTC 2023 - 13.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator.go
} else if exitErr, ok := err.(exec.CodeExitError); ok && exitErr.Exited() { websocketStreams.writeStatus(codeExitToStatusError(exitErr)) // Returned an exit code from the container, so not an error in // stream translator--add StatusOK to metrics. metrics.IncStreamTranslatorRequest(req.Context(), strconv.Itoa(http.StatusOK)) } else { websocketStreams.writeStatus(apierrors.NewInternalError(err))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder.go
func (b *volumeBinder) tryTranslatePVToCSI(pv *v1.PersistentVolume, csiNode *storagev1.CSINode) (*v1.PersistentVolume, error) { if !b.translator.IsPVMigratable(pv) { return pv, nil } pluginName, err := b.translator.GetInTreePluginNameFromSpec(pv, nil) if err != nil { return nil, fmt.Errorf("could not get plugin name from pv: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 14:55:34 UTC 2024 - 42.6K bytes - Viewed (0)