Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for C2 (0.14 sec)

  1. internal/grid/trace.go

    		Remote:    c.Remote,
    		Subroute:  "",
    	}
    }
    
    // subroute adds a specific subroute to the request.
    func (c *tracer) subroute(subroute string) *tracer {
    	if c == nil {
    		return nil
    	}
    	c2 := *c
    	c2.Subroute = subroute
    	return &c2
    }
    
    type tracer struct {
    	Publisher *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType]
    	TraceType madmin.TraceType
    	Prefix    string
    	Local     string
    	Remote    string
    	Subroute  string
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 22:54:54 GMT 2024
    - 4K bytes
    - Viewed (0)
  2. internal/s3select/select_test.go

    			name: "select-is_not_string",
    			input: []byte(`c1,c2,c3
    1,2,3
    1,,3`),
    			query:      `select * from S3object where _2 IS NOT ''`,
    			wantResult: `{"c1":"1","c2":"2","c3":"3"}`,
    		},
    		{
    			name: "select-is_not_string",
    			input: []byte(`c1,c2,c3
    1,2,3
    1,,3`),
    			query:      `select * from S3object where _2 != '' AND _2 > 1`,
    			wantResult: `{"c1":"1","c2":"2","c3":"3"}`,
    		},
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 76.2K bytes
    - Viewed (0)
  3. internal/s3select/csv/reader_contrib_test.go

    			recordDelimiter: "%!",
    			fieldDelimiter:  ",",
    			sendErr:         nil,
    			header:          false,
    			wantColumns:     []string{"_1", "_2", "_3"},
    			wantFields:      "a,b,c\na2,b2,c2%\n",
    			wantErr:         io.EOF,
    		},
    	}
    
    	for i, c := range cases {
    		t.Run(c.file, func(t *testing.T) {
    			var err error
    			var record sql.Record
    			var result bytes.Buffer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 38.5K bytes
    - Viewed (0)
  4. cmd/data-scanner-metric.go

    	}
    	val := p.actionsLatency[a].total()
    	return val
    }
    
    // setCycle updates the current cycle metrics.
    func (p *scannerMetrics) setCycle(c *currentScannerCycle) {
    	if c != nil {
    		c2 := c.clone()
    		c = &c2
    	}
    	p.cycleInfoMu.Lock()
    	p.cycleInfo = c
    	p.cycleInfoMu.Unlock()
    }
    
    // getCycle returns the current cycle metrics.
    // If not nil, the returned value can safely be modified.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 25 05:15:31 GMT 2023
    - 9.1K bytes
    - Viewed (0)
Back to top