- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for encode (8.08 sec)
-
operator/cmd/mesh/profile-dump.go
// Convert the generated YAML to pretty JSON. func yamlToPrettyJSON(yml string) (string, error) { // YAML objects are not completely compatible with JSON // objects. Let yaml.YAMLToJSON handle the edge cases and // we'll re-encode the result to pretty JSON. uglyJSON, err := yaml.YAMLToJSON([]byte(yml)) if err != nil { return "", err } var decoded any if uglyJSON[0] == '[' { decoded = make([]any, 0) } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K 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/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) -
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/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/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/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/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) -
cni/pkg/plugin/cnieventclient.go
"istio.io/istio/cni/pkg/nodeagent" ) // newCNIClient is a unit test override variable for mocking. var newCNIClient = buildClient // An udsCore write entries to an UDS server with HTTP Post. Log messages will be encoded into a JSON array. type CNIEventClient struct { client *http.Client url string } func buildClient(address, path string) CNIEventClient { c := &http.Client{ Transport: &http.Transport{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0)