Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Add very hacky read support

pull/10616/head
Jeff Wendling 2018-09-26 23:06:45 -06:00
parent c659c24f9a
commit 76cb1213f3
3 changed files with 10820 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10806
cmd/influxd/extra.go Normal file
View File

File diff suppressed because it is too large Load Diff

16
cmd/influxd/main.go
View File

@ -211,7 +211,10 @@ func platformF(cmd *cobra.Command, args []string) {
// TODO(jeff): this block is hacky support for a storage engine. it is not intended to
// be a long term solution.
var natsHandler nats.Handler
var (
natsHandler nats.Handler
storageQueryService query.QueryService
)
{
sfile := tsdb.NewSeriesFile(filepath.Join(enginePath, tsdb.SeriesFileDirectory))
if err := sfile.Open(); err != nil {
@ -237,6 +240,15 @@ func platformF(cmd *cobra.Command, args []string) {
engineHandler.Engine = shard
natsHandler = engineHandler
storageQueryService = query.QueryServiceBridge{
AsyncQueryService: &queryAdapter{
Controller: NewController(
&store{shard: shard},
logger.With(zap.String("service", "storage")),
),
},
}
}
var queryService query.QueryService
@ -343,7 +355,7 @@ func platformF(cmd *cobra.Command, args []string) {
MacroService: macroSvc,
BasicAuthService: basicAuthSvc,
OnboardingService: onboardingSvc,
QueryService: queryService,
QueryService: storageQueryService,
TaskService: taskSvc,
ScraperTargetStoreService: scraperTargetSvc,
ChronografService: chronografSvc,

3
go.sum
View File

@ -8,8 +8,6 @@ github.com/NYTimes/gziphandler v1.0.1 h1:iLrQrdwjDd52kHDA5op2UBJFjmOb9g+7scBan4R
github.com/NYTimes/gziphandler v1.0.1/go.mod h1:3wb06e3pkSAbeQ52E9H9iFoQsEEwGN64994WTCIhntQ=
github.com/OneOfOne/xxhash v1.2.2 h1:KMrpdQIwFcEqXDklaen+P1axHaj9BSKzvpUUfnHldSE=
github.com/OneOfOne/xxhash v1.2.2/go.mod h1:HSdplMjZKSmBqAxg5vPj2TmRDmfkzw+cTzAElWljhcU=
github.com/RoaringBitmap/roaring v0.4.15 h1:/xyXGsqgpWaiRZ9OotrfEGP4AHXjuA6/UP0U1VGE6f8=
github.com/RoaringBitmap/roaring v0.4.15/go.mod h1:8khRDP4HmeXns4xIj9oGrKSz7XTQiJx2zgh7AcNke4w=
github.com/RoaringBitmap/roaring v0.4.16 h1:NholfewybRLOwACgfqfzn/N5xa6keKNs4fP00t0cwLo=
github.com/RoaringBitmap/roaring v0.4.16/go.mod h1:8khRDP4HmeXns4xIj9oGrKSz7XTQiJx2zgh7AcNke4w=
github.com/alecthomas/kingpin v2.2.6+incompatible h1:5svnBTFgJjZvGKyYBtMB0+m5wvrbUHiqye8wRJMlnYI=
@ -125,7 +123,6 @@ github.com/inconshreveable/mousetrap v1.0.0 h1:Z8tu5sraLXCXIcARxBp/8cbvlwVa7Z1NH
github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8=
github.com/influxdata/flux v0.0.0-20180919192308-1335e4da35f6 h1:p2puINFb2Hy6YfMZOd+BHhPFsbWDD/5uapXF9iEJfqE=
github.com/influxdata/flux v0.0.0-20180919192308-1335e4da35f6/go.mod h1:INqOzJeMwzRrdqUu9bjMov4brs4ctB/d8Ev8XhPxHYg=
github.com/influxdata/goreleaser v0.86.2-0.20180917235036-c23174192b3a h1:+nfKZu1x23ciW8vrOP8Zx4KO+t6UzDglE2H7Y3tYCSc=
github.com/influxdata/goreleaser v0.86.2-0.20180917235036-c23174192b3a/go.mod h1:aVuBpDAT5VtjtUxzvBt8HOd0buzvvk7OX3H2iaviixg=
github.com/influxdata/influxdb v0.0.0-20180904211643-ab81104697f6 h1:4lXKZjCh1+rd5MIauBsJ4FcwrqZFaErnkVWyrxoJpvQ=
github.com/influxdata/influxdb v0.0.0-20180904211643-ab81104697f6/go.mod h1:qZna6X/4elxqT3yI9iZYdZrWWdeFOOprn86kgg4+IzY=