/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/influxdata/influxdb/flux/stdlib/influxdata/influxdb/ |
H A D | storage.go | 71 type ReadGroupSpec struct { struct 91 ReadGroup(ctx context.Context, spec ReadGroupSpec, alloc *memory.Allocator) (TableIterator, error) argument
|
H A D | source.go | 172 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 D | storage.go | 72 type ReadGroupSpec struct { struct 112 ReadGroup(ctx context.Context, spec ReadGroupSpec, alloc *memory.Allocator) (TableIterator, error) argument
|
H A D | source.go | 179 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 D | flux.go | 14 …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 D | flux_reader.go | 44 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 D | reader.go | 75 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 D | table_test.go | 2831 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 D | flux.patch | 883 @@ -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 D | flux.patch | 883 @@ -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…
|