- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for RequestProgress (0.41 sec)
-
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) -
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) -
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) -
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) -
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) -
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)