Home
last modified time | relevance | path

Searched refs:ReadGroupSpec (Results 1 – 10 of 10) sorted by relevance

/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/flux/stdlib/influxdata/influxdb/
H A Dstorage.go71 type ReadGroupSpec struct { struct
91 ReadGroup(ctx context.Context, spec ReadGroupSpec, alloc *memory.Allocator) (TableIterator, error) argument
H A Dsource.go172 readSpec ReadGroupSpec
175 func ReadGroupSource(id execute.DatasetID, r Reader, readSpec ReadGroupSpec, a execute.Administrati… argument
225 ReadGroupSpec{
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/flux/stdlib/influxdata/influxdb/
H A Dstorage.go72 type ReadGroupSpec struct { struct
112 ReadGroup(ctx context.Context, spec ReadGroupSpec, alloc *memory.Allocator) (TableIterator, error) argument
H A Dsource.go179 readSpec ReadGroupSpec
182 func ReadGroupSource(id execute.DatasetID, r Reader, readSpec ReadGroupSpec, a execute.Administrati… argument
228 ReadGroupSpec{
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/mock/
H A Dflux.go14 …ReadGroupFn func(ctx context.Context, spec influxdb.ReadGroupSpec, alloc *memory.Allocat…
25 func (m Reader) ReadGroup(ctx context.Context, spec influxdb.ReadGroupSpec, alloc *memory.Allocator…
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/storage/reads/
H A Dflux_reader.go44 func (r *storeReader) ReadGroup(ctx context.Context, spec influxdb.ReadGroupSpec, alloc *memory.All…
223 spec influxdb.ReadGroupSpec
476 func groupKeyForGroup(kv [][]byte, spec *influxdb.ReadGroupSpec, bnds execute.Bounds) flux.GroupKey… argument
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/storage/flux/
H A Dreader.go75 func (r *storeReader) ReadGroup(ctx context.Context, spec query.ReadGroupSpec, alloc *memory.Alloca…
237 spec query.ReadGroupSpec
579 func groupKeyForGroup(kv [][]byte, spec *query.ReadGroupSpec, bnds execute.Bounds) flux.GroupKey { argument
H A Dtable_test.go2831 got, err := reader.ReadGroup(context.Background(), influxdb.ReadGroupSpec{
2922 got, err := reader.ReadGroup(context.Background(), influxdb.ReadGroupSpec{
2994 got, err := reader.ReadGroup(context.Background(), influxdb.ReadGroupSpec{
3191 return reader.ReadGroup(context.Background(), influxdb.ReadGroupSpec{
3470 tables, err := r.ReadGroup(context.Background(), influxdb.ReadGroupSpec{
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/influxdata/influxdb/patches/
H A Dflux.patch883 @@ -213,10 +181,6 @@ func ReadGroupSource(id execute.DatasetID, r Reader, readSpec ReadGroupSpec, a…
924 ReadGroupSpec{
1076 -func (mockReader) ReadGroup(ctx context.Context, spec influxdb.ReadGroupSpec, alloc *memory.Alloca…
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/patches/
H A Dflux.patch883 @@ -213,10 +181,6 @@ func ReadGroupSource(id execute.DatasetID, r Reader, readSpec ReadGroupSpec, a…
924 ReadGroupSpec{
1076 -func (mockReader) ReadGroup(ctx context.Context, spec influxdb.ReadGroupSpec, alloc *memory.Alloca…