Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for RawMessage (0.19 sec)

  1. pilot/pkg/config/kube/crd/config.go

    	metav1.TypeMeta
    	metav1.ObjectMeta `json:"metadata"`
    	Spec              json.RawMessage  `json:"spec"`
    	Status            *json.RawMessage `json:"status,omitempty"`
    }
    
    // GetSpec from a wrapper
    func (in *IstioKind) GetSpec() json.RawMessage {
    	return in.Spec
    }
    
    // GetStatus from a wrapper
    func (in *IstioKind) GetStatus() *json.RawMessage {
    	return in.Status
    }
    
    // GetObjectMeta from a wrapper
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 18:26:16 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  2. istioctl/pkg/writer/ztunnel/configdump/configdump.go

    	Stdout      io.Writer
    	ztunnelDump *ZtunnelDump
    	FullDump    []byte
    }
    
    type rawDump struct {
    	Services      json.RawMessage          `json:"services"`
    	Workloads     json.RawMessage          `json:"workloads"`
    	Policies      json.RawMessage          `json:"policies"`
    	Certificates  json.RawMessage          `json:"certificates"`
    	WorkloadState map[string]WorkloadState `json:"workloadstate"`
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 20:18:34 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. src/net/rpc/jsonrpc/server.go

    	Params *json.RawMessage `json:"params"`
    	Id     *json.RawMessage `json:"id"`
    }
    
    func (r *serverRequest) reset() {
    	r.Method = ""
    	r.Params = nil
    	r.Id = nil
    }
    
    type serverResponse struct {
    	Id     *json.RawMessage `json:"id"`
    	Result any              `json:"result"`
    	Error  any              `json:"error"`
    }
    
    func (c *serverCodec) ReadRequestHeader(r *rpc.Request) error {
    	c.req.reset()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  4. src/encoding/json/encode_test.go

    }
    
    func TestMarshalRawMessageValue(t *testing.T) {
    	type (
    		T1 struct {
    			M RawMessage `json:",omitempty"`
    		}
    		T2 struct {
    			M *RawMessage `json:",omitempty"`
    		}
    	)
    
    	var (
    		rawNil   = RawMessage(nil)
    		rawEmpty = RawMessage([]byte{})
    		rawText  = RawMessage([]byte(`"foo"`))
    	)
    
    	tests := []struct {
    		CaseName
    		in   any
    		want string
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  5. pilot/pkg/config/kube/crd/config_test.go

    	"istio.io/istio/pkg/ptr"
    )
    
    func TestKind(t *testing.T) {
    	obj := crd.IstioKind{}
    
    	spec := json.RawMessage(`{"a":"b"}`)
    	obj.Spec = spec
    	if got := obj.GetSpec(); !reflect.DeepEqual(spec, got) {
    		t.Errorf("GetSpec() => got %v, want %v", got, spec)
    	}
    
    	status := ptr.Of(json.RawMessage(`{"c":"d"}`))
    	obj.Status = status
    	if got := obj.GetStatus(); !reflect.DeepEqual(status, got) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 18:26:16 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/util/framer/framer.go

    		data = append(data[0:0], r.remaining[:n]...)
    		r.remaining = r.remaining[n:]
    		return n, io.ErrShortBuffer
    	}
    
    	// RawMessage#Unmarshal appends to data - we reset the slice down to 0 and will either see
    	// data written to data, or be larger than data and a different array.
    	m := json.RawMessage(data[:0])
    	if err := r.decoder.Decode(&m); err != nil {
    		return 0, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 13:33:12 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  7. pkg/istio-agent/grpcxds/grpc_bootstrap.go

    type CertificateProvider struct {
    	PluginName string `json:"plugin_name,omitempty"`
    	Config     any    `json:"config,omitempty"`
    }
    
    func (cp *CertificateProvider) UnmarshalJSON(data []byte) error {
    	var dat map[string]*json.RawMessage
    	if err := json.Unmarshal(data, &dat); err != nil {
    		return err
    	}
    	*cp = CertificateProvider{}
    
    	if pluginNameVal, ok := dat["plugin_name"]; ok {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Mar 30 00:31:03 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  8. pilot/pkg/config/kube/crd/conversion.go

    	if err != nil {
    		return nil, err
    	}
    	if err = config.ApplyJSON(c, js); err != nil {
    		return nil, err
    	}
    	return c, nil
    }
    
    func StatusJSONFromMap(schema resource.Schema, jsonMap *json.RawMessage) (config.Status, error) {
    	if jsonMap == nil {
    		return nil, nil
    	}
    	js, err := json.Marshal(jsonMap)
    	if err != nil {
    		return nil, err
    	}
    	status, err := schema.Status()
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 18:26:16 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  9. logger/sql_test.go

    	"encoding/json"
    	"fmt"
    	"regexp"
    	"strings"
    	"testing"
    
    	"github.com/jinzhu/now"
    	"gorm.io/gorm/logger"
    )
    
    type JSON json.RawMessage
    
    func (j JSON) Value() (driver.Value, error) {
    	if len(j) == 0 {
    		return nil, nil
    	}
    	return json.RawMessage(j).MarshalJSON()
    }
    
    type ExampleStruct struct {
    	Name string
    	Val  string
    }
    
    func (s ExampleStruct) Value() (driver.Value, error) {
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Thu Mar 21 08:00:02 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. src/net/rpc/jsonrpc/client.go

    	c.mutex.Unlock()
    	c.req.Method = r.ServiceMethod
    	c.req.Params[0] = param
    	c.req.Id = r.Seq
    	return c.enc.Encode(&c.req)
    }
    
    type clientResponse struct {
    	Id     uint64           `json:"id"`
    	Result *json.RawMessage `json:"result"`
    	Error  any              `json:"error"`
    }
    
    func (r *clientResponse) reset() {
    	r.Id = 0
    	r.Result = nil
    	r.Error = nil
    }
    
    func (c *clientCodec) ReadResponseHeader(r *rpc.Response) error {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 3K bytes
    - Viewed (0)
Back to top