Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for RequestProgress (0.41 sec)

  1. internal/s3select/select_test.go

            </JSON>
        </InputSerialization>
        <OutputSerialization>
            <CSV>
    	   <QuoteCharacter>"</QuoteCharacter>
            </CSV>
        </OutputSerialization>
        <RequestProgress>
            <Enabled>FALSE</Enabled>
        </RequestProgress>
    </SelectObjectContentRequest>`),
    			wantResult: `"[""foo"",""bar"",""whatever""]"`,
    		},
    		{
    			name:  "document",
    			query: "",
    			requestXML: []byte(`
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  2. internal/s3select/select_benchmark_test.go

                <FileHeaderInfo>USE</FileHeaderInfo>
            </CSV>
        </InputSerialization>
        <OutputSerialization>
            <CSV>
            </CSV>
        </OutputSerialization>
        <RequestProgress>
            <Enabled>FALSE</Enabled>
        </RequestProgress>
    </SelectObjectContentRequest>
    `)
    
    	csvData := genSampleCSVData(count)
    
    	b.ResetTimer()
    	b.ReportAllocs()
    	b.SetBytes(int64(count))
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Apr 14 13:54:47 UTC 2022
    - 5K bytes
    - Viewed (0)
  3. internal/s3select/select.go

    	}
    
    	*output = OutputSerialization(parsedOutput)
    	output.unmarshaled = true
    	return nil
    }
    
    // RequestProgress - represents elements inside <RequestProgress/> in request XML.
    type RequestProgress struct {
    	Enabled bool `xml:"Enabled"`
    }
    
    // ScanRange represents the ScanRange parameter.
    type ScanRange struct {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 21K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    	//
    	// TODO: Remove when storage.Interface will be separate from etc3.store.
    	// Deprecated: Added temporarily to simplify exposing RequestProgress for watch cache.
    	RequestWatchProgress(ctx context.Context) error
    }
    
    // GetOptions provides the options that may be provided for storage get operations.
    type GetOptions struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go

    	wc.cancel()
    }
    
    func (wc *watchChan) ResultChan() <-chan watch.Event {
    	return wc.resultChan
    }
    
    func (wc *watchChan) RequestWatchProgress() error {
    	return wc.watcher.client.RequestProgress(wc.ctx)
    }
    
    // sync tries to retrieve existing data and send them to process.
    // The revision to watch will be set to the revision in response.
    // All events sent will have isCreated=true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 10:26:38 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    	// Use watchContext to match ctx metadata provided when creating the watch.
    	// In best case scenario we would use the same context that watch was created, but there is no way access it from watchCache.
    	return s.client.RequestProgress(s.watchContext(ctx))
    }
    
    type objState struct {
    	obj   runtime.Object
    	meta  *storage.ResponseMeta
    	rev   int64
    	data  []byte
    	stale bool
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top