Fix issue with rebasing
parent
831833dcab
commit
5fa10786a2
|
@ -213,7 +213,7 @@ func platformF(cmd *cobra.Command, args []string) {
|
|||
// be a long term solution.
|
||||
var (
|
||||
natsHandler nats.Handler
|
||||
storageQueryService query.QueryService
|
||||
storageQueryService query.ProxyQueryService
|
||||
)
|
||||
{
|
||||
sfile := tsdb.NewSeriesFile(filepath.Join(enginePath, tsdb.SeriesFileDirectory))
|
||||
|
@ -241,14 +241,16 @@ func platformF(cmd *cobra.Command, args []string) {
|
|||
|
||||
natsHandler = engineHandler
|
||||
|
||||
storageQueryService = query.QueryServiceBridge{
|
||||
AsyncQueryService: &queryAdapter{
|
||||
Controller: NewController(
|
||||
&store{shard: shard},
|
||||
&bucketLookup{bolt: c},
|
||||
&orgLookup{bolt: c},
|
||||
logger.With(zap.String("service", "storage")),
|
||||
),
|
||||
storageQueryService = query.ProxyQueryServiceBridge{
|
||||
QueryService: query.QueryServiceBridge{
|
||||
AsyncQueryService: &queryAdapter{
|
||||
Controller: NewController(
|
||||
&store{shard: shard},
|
||||
&bucketLookup{bolt: c},
|
||||
&orgLookup{bolt: c},
|
||||
logger.With(zap.String("service", "storage")),
|
||||
),
|
||||
},
|
||||
},
|
||||
}
|
||||
}
|
||||
|
@ -357,7 +359,7 @@ func platformF(cmd *cobra.Command, args []string) {
|
|||
MacroService: macroSvc,
|
||||
BasicAuthService: basicAuthSvc,
|
||||
OnboardingService: onboardingSvc,
|
||||
QueryService: storageQueryService,
|
||||
ProxyQueryService: storageQueryService,
|
||||
TaskService: taskSvc,
|
||||
ScraperTargetStoreService: scraperTargetSvc,
|
||||
ChronografService: chronografSvc,
|
||||
|
|
|
@ -8,7 +8,6 @@ import (
|
|||
"github.com/influxdata/platform"
|
||||
"github.com/influxdata/platform/chronograf/server"
|
||||
"github.com/influxdata/platform/query"
|
||||
pzap "github.com/influxdata/platform/zap"
|
||||
"go.uber.org/zap"
|
||||
)
|
||||
|
||||
|
@ -54,7 +53,7 @@ type APIBackend struct {
|
|||
MacroService platform.MacroService
|
||||
BasicAuthService platform.BasicAuthService
|
||||
OnboardingService platform.OnboardingService
|
||||
QueryService query.QueryService
|
||||
ProxyQueryService query.ProxyQueryService
|
||||
TaskService platform.TaskService
|
||||
ScraperTargetStoreService platform.ScraperTargetStoreService
|
||||
ChronografService *server.Service
|
||||
|
@ -116,7 +115,7 @@ func NewAPIHandler(b *APIBackend) *APIHandler {
|
|||
h.QueryHandler.AuthorizationService = b.AuthorizationService
|
||||
h.QueryHandler.OrganizationService = b.OrganizationService
|
||||
h.QueryHandler.Logger = b.Logger.With(zap.String("handler", "query"))
|
||||
h.QueryHandler.ProxyQueryService = pzap.NewProxyQueryService(h.QueryHandler.Logger)
|
||||
h.QueryHandler.ProxyQueryService = b.ProxyQueryService
|
||||
|
||||
h.ChronografHandler = NewChronografHandler(b.ChronografService)
|
||||
|
||||
|
|
Loading…
Reference in New Issue