Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 148 for Marshal (0.08 sec)

  1. internal/config/lambda/target/webhook.go

    	defer func() {
    		if err != nil {
    			atomic.AddInt64(&target.failedRequests, 1)
    		}
    	}()
    
    	if err = target.init(); err != nil {
    		return nil, err
    	}
    
    	data, err := json.Marshal(eventData)
    	if err != nil {
    		return nil, err
    	}
    
    	req, err := http.NewRequest(http.MethodPost, target.args.Endpoint.String(), bytes.NewReader(data))
    	if err != nil {
    		return nil, err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  2. tests/soft_delete_test.go

    		t.Errorf("Can't find permanently deleted record")
    	}
    }
    
    func TestDeletedAtUnMarshal(t *testing.T) {
    	expected := &gorm.Model{}
    	b, _ := json.Marshal(expected)
    
    	result := &gorm.Model{}
    	_ = json.Unmarshal(b, result)
    	if result.DeletedAt != expected.DeletedAt {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  3. internal/event/target/nsq.go

    	objectName, err := url.QueryUnescape(eventData.S3.Object.Key)
    	if err != nil {
    		return err
    	}
    	key := eventData.S3.Bucket.Name + "/" + objectName
    
    	data, err := json.Marshal(event.Log{EventName: eventData.EventName, Key: key, Records: []event.Event{eventData}})
    	if err != nil {
    		return err
    	}
    
    	return target.producer.Publish(target.args.Topic, data)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  4. internal/store/queuestore.go

    	return
    }
    
    // write - writes an item to the directory.
    func (store *QueueStore[I]) write(key Key, item I) error {
    	// Marshalls the item.
    	eventData, err := json.Marshal(item)
    	if err != nil {
    		return err
    	}
    	return store.writeBytes(key, eventData)
    }
    
    // writeBytes - writes bytes to the directory.
    func (store *QueueStore[I]) writeBytes(key Key, b []byte) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  5. tests/embedded_struct_test.go

    	Content interface{} `gorm:"type:String"`
    }
    
    func (c Content) Value() (driver.Value, error) {
    	// mssql driver with issue on handling null bytes https://github.com/denisenkom/go-mssqldb/issues/530,
    	b, err := json.Marshal(c)
    	return string(b[:]), err
    }
    
    func (c *Content) Scan(src interface{}) error {
    	var value Content
    	str, ok := src.(string)
    	if !ok {
    		byt, ok := src.([]byte)
    		if !ok {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  6. internal/event/name.go

    	if err != nil {
    		return err
    	}
    
    	*name = eventName
    	return nil
    }
    
    // MarshalJSON - encodes to JSON data.
    func (name Name) MarshalJSON() ([]byte, error) {
    	return json.Marshal(name.String())
    }
    
    // UnmarshalJSON - decodes JSON data.
    func (name *Name) UnmarshalJSON(data []byte) error {
    	var s string
    	if err := json.Unmarshal(data, &s); err != nil {
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v1.go

    	Hash      string `json:"hash,omitempty"`
    }
    
    // MarshalJSON marshals the ChecksumInfo struct
    func (c ChecksumInfo) MarshalJSON() ([]byte, error) {
    	info := checksumInfoJSON{
    		Name:      fmt.Sprintf("part.%d", c.PartNumber),
    		Algorithm: c.Algorithm.String(),
    		Hash:      hex.EncodeToString(c.Hash),
    	}
    	return json.Marshal(info)
    }
    
    // UnmarshalJSON - custom checksum info unmarshaller
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  8. internal/s3select/select.go

    		s3Select.recordReader, err = parquet.NewParquetReader(rsc, &s3Select.Input.ParquetArgs)
    		return err
    	}
    
    	return fmt.Errorf("unknown input format '%v'", s3Select.Input.format)
    }
    
    func (s3Select *S3Select) marshal(buf *bytes.Buffer, record sql.Record) error {
    	switch s3Select.Output.format {
    	case csvFormat:
    		// Use bufio Writer to prevent csv.Writer from allocating a new buffer.
    		bufioWriter := bufioWriterPool.Get().(*bufio.Writer)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  9. istioctl/pkg/waypoint/waypoint.go

    		RunE: func(cmd *cobra.Command, args []string) error {
    			gw, err := makeGateway(false)
    			if err != nil {
    				return fmt.Errorf("failed to create gateway: %v", err)
    			}
    			b, err := yaml.Marshal(gw)
    			if err != nil {
    				return err
    			}
    			// strip junk
    			res := strings.ReplaceAll(string(b), `  creationTimestamp: null
    `, "")
    			res = strings.ReplaceAll(res, `status: {}
    `, "")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  10. logger/sql_test.go

    		return nil, nil
    	}
    	return json.RawMessage(j).MarshalJSON()
    }
    
    type ExampleStruct struct {
    	Name string
    	Val  string
    }
    
    func (s ExampleStruct) Value() (driver.Value, error) {
    	return json.Marshal(s)
    }
    
    func format(v []byte, escaper string) string {
    	return escaper + strings.ReplaceAll(string(v), escaper, escaper+escaper) + escaper
    }
    
    func TestExplainSQL(t *testing.T) {
    	type role string
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Mar 21 08:00:02 UTC 2024
    - 8.4K bytes
    - Viewed (0)
Back to top