Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 466 for ndjson (0.04 seconds)

  1. cmd/iam-object-store.go

    	return iamOS.usersSysType
    }
    
    func (iamOS *IAMObjectStore) saveIAMConfig(ctx context.Context, item any, objPath string, opts ...options) error {
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	data, err := json.Marshal(item)
    	if err != nil {
    		return err
    	}
    	if GlobalKMS != nil {
    		data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  2. cmd/metacache-set.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/gob"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"io"
    	"maps"
    	"math/rand"
    	"strconv"
    	"strings"
    	"sync"
    	"sync/atomic"
    	"time"
    
    	jsoniter "github.com/json-iterator/go"
    	"github.com/minio/minio/internal/bucket/lifecycle"
    	"github.com/minio/minio/internal/bucket/object/lock"
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
  3. cmd/bucket-lifecycle.go

    	}
    	return objectAPI.TransitionObject(ctx, oi.Bucket, oi.Name, opts)
    }
    
    type auditTierOp struct {
    	Tier             string `json:"tier"`
    	TimeToResponseNS int64  `json:"timeToResponseNS"`
    	OutputBytes      int64  `json:"tx,omitempty"`
    	Error            string `json:"error,omitempty"`
    }
    
    func (op auditTierOp) String() string {
    	// flattening the auditTierOp{} for audit
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
  4. cmd/utils_test.go

    	req.Header.Set("content-md5", "====test")
    	jsonReq := dumpRequest(req)
    	type jsonResult struct {
    		Method     string      `json:"method"`
    		RequestURI string      `json:"reqURI"`
    		Header     http.Header `json:"header"`
    	}
    	res := jsonResult{}
    	if err = json.Unmarshal([]byte(strings.ReplaceAll(jsonReq, "%%", "%")), &res); err != nil {
    		t.Fatal(err)
    	}
    
    	// Look for expected method.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  5. docs/site-replication/run-replication-with-checksum-header.sh

    	fi
    done
    
    echo "{\"Parts\":[${PARTS}]}" >fileparts.json
    jq <fileparts.json
    aws s3api --endpoint-url=https://localhost:9001 complete-multipart-upload --multipart-upload file://fileparts.json --bucket test-bucket --key mpartobj --upload-id "${UPLOAD_ID}" --no-verify-ssl --profile enterprise
    sleep 120
    
    # List the objects from replicated site
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  6. internal/config/etcd/etcd.go

    			Value: "",
    		},
    		config.KV{
    			Key:   ClientCertKey,
    			Value: "",
    		},
    	}
    )
    
    // Config - server etcd config.
    type Config struct {
    	Enabled     bool   `json:"enabled"`
    	PathPrefix  string `json:"pathPrefix"`
    	CoreDNSPath string `json:"coreDNSPath"`
    	clientv3.Config
    }
    
    // New - initialize new etcd client.
    func New(cfg Config) (*clientv3.Client, error) {
    	if !cfg.Enabled {
    		return nil, nil
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  7. cmd/listen-notification-handlers.go

    	localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    
    	// Convert local messages to JSON and send to mergeCh
    	go func() {
    		buf := bytes.NewBuffer(grid.GetByteBuffer()[:0])
    		enc := json.NewEncoder(buf)
    		tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}}
    		for {
    			select {
    			case ev := <-localCh:
    				buf.Reset()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (0)
  8. cmd/xl-storage-format_test.go

    // The result will be compared with the result obtained from json.unMarshal of the byte data.
    func TestGetXLMetaV1Jsoniter1(t *testing.T) {
    	xlMetaJSON := getXLMetaBytes(1)
    
    	var unMarshalXLMeta xlMetaV1Object
    	if err := json.Unmarshal(xlMetaJSON, &unMarshalXLMeta); err != nil {
    		t.Errorf("Unmarshalling failed: %v", err)
    	}
    
    	var jsoniterXLMeta xlMetaV1Object
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  9. api/go1.8.txt

    pkg debug/pe, type Section struct, Relocs []Reloc
    pkg debug/pe, type StringTable []uint8
    pkg encoding/base64, method (Encoding) Strict() *Encoding
    pkg encoding/json, method (RawMessage) MarshalJSON() ([]uint8, error)
    pkg encoding/json, type UnmarshalTypeError struct, Field string
    pkg encoding/json, type UnmarshalTypeError struct, Struct string
    pkg expvar, func Handler() http.Handler
    pkg expvar, method (*Float) Value() float64
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Dec 21 05:25:57 GMT 2016
    - 16.3K bytes
    - Click Count (0)
  10. internal/s3select/sql/record.go

    const (
    	// SelectFmtUnknown - unknown format (default value)
    	SelectFmtUnknown SelectObjectFormat = iota
    	// SelectFmtCSV - CSV format
    	SelectFmtCSV
    	// SelectFmtJSON - JSON format
    	SelectFmtJSON
    	// SelectFmtSIMDJSON - SIMD JSON format
    	SelectFmtSIMDJSON
    	// SelectFmtParquet - Parquet format
    	SelectFmtParquet
    )
    
    // WriteCSVOpts - encapsulates options for Select CSV output
    type WriteCSVOpts struct {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3.4K bytes
    - Click Count (0)
Back to Top