Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 203 for marshal (0.04 sec)

  1. internal/s3select/simdj/record.go

    			b, err := tmp.MarshalJSON()
    			if err != nil {
    				return err
    			}
    			columnValue = string(b)
    		case simdjson.TypeNone:
    			break allElems
    		default:
    			return fmt.Errorf("cannot marshal unhandled type: %s", typ.String())
    		}
    		csvRecord = append(csvRecord, columnValue)
    	}
    	w := csv.NewWriter(writer)
    	w.Comma = opts.FieldDelimiter
    	w.Quote = opts.Quote
    	w.QuoteEscape = opts.QuoteEscape
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  2. internal/kms/conn.go

    func (d DEK) MarshalText() ([]byte, error) {
    	type JSON struct {
    		KeyID      string `json:"keyid"`
    		Version    uint32 `json:"version,omitempty"`
    		Ciphertext []byte `json:"ciphertext"`
    	}
    	return json.Marshal(JSON{
    		KeyID:      d.KeyID,
    		Version:    uint32(d.Version),
    		Ciphertext: d.Ciphertext,
    	})
    }
    
    // UnmarshalText tries to decode text as JSON representation
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. internal/store/queuestore.go

    	store.entries[key.String()] = time.Now().UnixNano()
    
    	return err
    }
    
    // write - writes an item to the directory.
    func (store *QueueStore[I]) write(key Key, item I) error {
    	// Marshals the item.
    	eventData, err := json.Marshal(item)
    	if err != nil {
    		return err
    	}
    	return store.writeBytes(key, eventData)
    }
    
    // writeBytes - writes bytes to the directory.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    		for !he.hasEnded() {
    			time.Sleep(1 * time.Second)
    		}
    		ahs.Lock()
    		defer ahs.Unlock()
    		// Heal sequence explicitly stopped, remove it.
    		delete(ahs.healSeqMap, path)
    	}
    
    	b, err := json.Marshal(&hsp)
    	return b, toAdminAPIErr(GlobalContext, err)
    }
    
    // LaunchNewHealSequence - launches a background routine that performs
    // healing according to the healSequence argument. For each heal
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. cmd/config-migrate.go

    	for _, cfgFile := range configFiles {
    		if _, err = Load(cfgFile, cfg); err != nil {
    			if !osIsNotExist(err) && !osIsPermission(err) {
    				return nil, err
    			}
    			continue
    		}
    		data, _ = json.Marshal(cfg)
    		break
    	}
    	if osIsPermission(err) {
    		logger.Info("Older config found but is not readable %s, proceeding to read config from other places", err)
    	}
    	if osIsNotExist(err) || osIsPermission(err) || len(data) == 0 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    						if err != nil {
    							return err
    						}
    						// Quote string...
    						b, _ := json.Marshal(file.Name)
    						b2, err := decode(r, file.Name)
    						if err != nil {
    							return err
    						}
    						var tmp map[string]any
    						if err := json.Unmarshal(b2, &tmp); err == nil {
    							if b3, err := json.Marshal(tmp); err == nil {
    								b2 = b3
    							}
    						}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 40.4K bytes
    - Viewed (0)
  7. internal/config/policy/plugin/config.go

    	if o == nil {
    		return false, nil
    	}
    
    	// Access Management Plugin Input
    	body := make(map[string]any)
    	body["input"] = args
    
    	inputBytes, err := json.Marshal(body)
    	if err != nil {
    		return false, err
    	}
    
    	req, err := http.NewRequest(http.MethodPost, o.args.URL.String(), bytes.NewReader(inputBytes))
    	if err != nil {
    		return false, err
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  8. tests/embedded_struct_test.go

    	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 {
    			return errors.New("Embedded.Scan byte assertion failed")
    		}
    		if err := json.Unmarshal(byt, &value); err != nil {
    			return err
    		}
    	} else {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  9. cmd/data-usage_test.go

    		}
    	}
    }
    
    // equalAsJSON returns whether the values are equal when encoded as JSON.
    func equalAsJSON(a, b any) bool {
    	aj, err := json.Marshal(a)
    	if err != nil {
    		panic(err)
    	}
    	bj, err := json.Marshal(b)
    	if err != nil {
    		panic(err)
    	}
    	return bytes.Equal(aj, bj)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  10. 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 {
    		t.Errorf("Failed, result.DeletedAt: %v is not same as expected.DeletedAt: %v", result.DeletedAt, expected.DeletedAt)
    	}
    }
    
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Wed Feb 01 06:40:55 UTC 2023
    - 5.7K bytes
    - Viewed (0)
Back to top