storage

type BucketLookup interface {
	Lookup(orgID platform.ID, name string) (platform.ID, bool)
}

type Dependencies struct {
	Reader             Reader
	BucketLookup       BucketLookup
	OrganizationLookup OrganizationLookup
}

type GroupMode int

type HostLookup interface {
	Hosts() []string
	Watch() <-chan struct{}
}

type OrganizationLookup interface {
	Lookup(ctx context.Context, name string) (platform.ID, bool)
}

type ReadSpec struct {
	OrganizationID platform.ID
	BucketID       platform.ID

	RAMLimit     uint64
	Hosts        []string
	Predicate    *semantic.FunctionExpression
	PointsLimit  int64
	SeriesLimit  int64
	SeriesOffset int64
	Descending   bool

	AggregateMethod string

	// OrderByTime indicates that series reads should produce all
	// series for a time before producing any series for a larger time.
	// By default this is false meaning all values of time are produced for a given series,
	// before any values are produced from the next series.
	OrderByTime bool
	// GroupMode instructs
	GroupMode GroupMode
	// GroupKeys is the list of dimensions along which to group.
	//
	// When GroupMode is GroupModeBy, the results will be grouped by the specified keys.
	// When GroupMode is GroupModeExcept, the results will be grouped by all keys, except those specified.
	GroupKeys []string

	Database        string // required by InfluxDB OSS
	RetentionPolicy string // required by InfluxDB OSS
}

type Reader interface {
	Read(ctx context.Context, rs ReadSpec, start, stop execute.Time) (flux.TableIterator, error)
	Close()
}

type StaticLookup struct {
	// contains filtered or unexported fields
}