johanels/akvorado
1
0
Fork 0
mirror of https://github.com/akvorado/akvorado.git synced 2025-12-11 22:14:02 +01:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

orchestrator: move broker component as orchestrator

Browse Source 
We can have one main subcomponent per component. We don't do that for
the inlet component as there is more configuration.
This commit is contained in:
Vincent Bernat
2022-06-11 08:12:59 +02:00
parent bf0c474726
commit ee26a468b0
5 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
cmd/orchestrator.go
View File

@@ -9,7 +9,7 @@ import (
"akvorado/common/daemon"
"akvorado/common/http"
"akvorado/common/reporter"
"akvorado/orchestrator/broker"
"akvorado/orchestrator"
"akvorado/orchestrator/clickhouse"
"akvorado/orchestrator/kafka"
)
@@ -21,7 +21,7 @@ type OrchestratorConfiguration struct {
ClickHouseDB clickhousedb.Configuration `yaml:"-"`
ClickHouse clickhouse.Configuration
Kafka kafka.Configuration
Broker broker.Configuration
Orchestrator orchestrator.Configuration
// Other service configurations
Inlet InletConfiguration
Console ConsoleConfiguration
@@ -35,7 +35,7 @@ func DefaultOrchestratorConfiguration() OrchestratorConfiguration {
ClickHouseDB: clickhousedb.DefaultConfiguration(),
ClickHouse: clickhouse.DefaultConfiguration(),
Kafka: kafka.DefaultConfiguration(),
Broker: broker.DefaultConfiguration(),
Orchestrator: orchestrator.DefaultConfiguration(),
// Other service configurations
Inlet: DefaultInletConfiguration(),
Console: DefaultConsoleConfiguration(),
@@ -116,14 +116,14 @@ func orchestratorStart(r *reporter.Reporter, config OrchestratorConfiguration, c
if err != nil {
return fmt.Errorf("unable to initialize clickhouse component: %w", err)
}
brokerComponent, err := broker.New(r, config.Broker, broker.Dependencies{
orchestratorComponent, err := orchestrator.New(r, config.Orchestrator, orchestrator.Dependencies{
HTTP: httpComponent,
})
if err != nil {
return fmt.Errorf("unable to initialize broker component: %w", err)
return fmt.Errorf("unable to initialize orchestrator component: %w", err)
}
brokerComponent.RegisterConfiguration(broker.InletService, config.Inlet)
brokerComponent.RegisterConfiguration(broker.ConsoleService, config.Console)
orchestratorComponent.RegisterConfiguration(orchestrator.InletService, config.Inlet)
orchestratorComponent.RegisterConfiguration(orchestrator.ConsoleService, config.Console)
// Expose some informations and metrics
addCommonHTTPHandlers(r, "orchestrator", httpComponent)