- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Encode (0.14 sec)
-
architecture/ambient/ztunnel.md
Because Ztunnel can have Istio semantics baked in, we do not need to encode all this information on the wire. Instead, an Istio specific field like `ExpectedTLSIdentity: spiffe://foo.bar` can encode the same information, at a fraction of the cost.
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 22:35:16 GMT 2024 - 16.6K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
} err = json.NewDecoder(resp.Body).Decode(&scopeInfos) if err != nil { return nil, fmt.Errorf("cannot deserialize response %s", err) } return scopeInfos, nil } func (c *ControlzClient) PutScope(scope *ScopeInfo) error { var jsonScopeInfo bytes.Buffer err := json.NewEncoder(&jsonScopeInfo).Encode(scope) if err != nil { return fmt.Errorf("cannot serialize scope %+v", *scope)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
} webhookYAML, err := generateValidatingWebhook(webhookConfig, opts) if err != nil { t.Fatalf("tag webhook YAML generation failed with error: %v", err) } vwhObject, _, err := deserializer.Decode([]byte(webhookYAML), nil, &admitv1.ValidatingWebhookConfiguration{}) if err != nil { t.Fatalf("could not parse webhook from generated YAML: %s", vwhObject) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
return nil, err } var obj runtime.Object var ar *kube.AdmissionReview out, _, err := deserializer.Decode(body, nil, obj) if err != nil { return nil, fmt.Errorf("could not decode body: %v", err) } ar, err = kube.AdmissionReviewKubeToAdapter(out) if err != nil { return nil, fmt.Errorf("could not decode object: %v", err) } return ar.Response.Patch, nil } var (
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
Yaml: true, Pretty: true, Strict: true, }) whObject, _, err := deserializer.Decode([]byte(validatingWebhookYAML), nil, &admitv1.ValidatingWebhookConfiguration{}) if err != nil { return "", fmt.Errorf("could not decode generated webhook: %w", err) } decodedWh := whObject.(*admitv1.ValidatingWebhookConfiguration) for i := range decodedWh.Webhooks {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 13.2K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
return c } func createRemoteServiceAccountSecret(kubeconfig *api.Config, clusterName, secName string) (*v1.Secret, error) { // nolint:interfacer var data bytes.Buffer if err := latest.Codec.Encode(kubeconfig, &data); err != nil { return nil, err } key := clusterName if secName == configSecretName { key = configSecretKey } out := &v1.Secret{ ObjectMeta: metav1.ObjectMeta{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Oct 11 01:43:17 GMT 2023 - 24K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
for { // YAML allows non-string keys and the produces generic keys for nested fields raw := make(map[any]any) err := decoder.Decode(&raw) if err == io.EOF { return warnings, errs } if err != nil { errs = multierror.Append(errs, multierror.Prefix(err, fmt.Sprintf("failed to decode file %s: ", path))) return warnings, errs } if len(raw) == 0 { continue } out := transformInterfaceMap(raw)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret_test.go
wantErrStr: `no "token" data found`, }, { testName: "fail to encode secret", objs: []runtime.Object{kubeSystemNamespace, sa, saSecret}, outputWriterError: errors.New("injected encode error"), wantErrStr: "injected encode error", }, { testName: "success", objs: []runtime.Object{kubeSystemNamespace, sa, saSecret},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 20.6K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
for _, response := range responses { retval[CpInfo(response).ID] = response } return retval, nil } // CpInfo returns the Istio control plane info from JSON-encoded XDS ControlPlane Identifier func CpInfo(xdsResponse *discovery.DiscoveryResponse) pilotxds.IstioControlPlaneInstance { if xdsResponse.ControlPlane == nil { return pilotxds.IstioControlPlaneInstance{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
common-protos/k8s.io/api/admissionregistration/v1beta1/generated.proto
// // If the webhook is running within the cluster, then you should use `service`. // // +optional optional ServiceReference service = 1; // `caBundle` is a PEM encoded CA bundle which will be used to validate the webhook's server certificate. // If unspecified, system trust roots on the apiserver are used. // +optional optional bytes caBundle = 2;
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 22.6K bytes - Viewed (0)