Versions in this module Expand all Collapse all v0 v0.0.1 Jan 1, 2026 Changes in this version + type App struct + ConfigReloader config.ConfigReloader + HealthCoordinator *health.Coordinator + MetricsCollector metrics.MetricsCollector + MetricsReporter metrics.MetricsReporter + RegistryManager *RegistryManager + Server *server.Server + ServiceDiscovery service.ServiceDiscovery + StrategySyncer *StrategySyncer + func InitializeApp(cfg *config.Config, configPath string, logger *zap.Logger) (*App, error) + func NewApp(srv *server.Server, regMgr *RegistryManager, ...) *App + type ConfigReloadHandler struct + func NewConfigReloadHandler(registryManager *RegistryManager, serviceDiscovery service.ServiceDiscovery, ...) *ConfigReloadHandler + func (h *ConfigReloadHandler) HandleConfigChange(newConfig *config.Config) error + type RegistryManager struct + func NewRegistryManager(reg registry.Registry, serviceManager service.ServiceManager, ...) *RegistryManager + func (rm *RegistryManager) Start() error + func (rm *RegistryManager) Stop() error + type StrategySyncer struct + func NewStrategySyncer(cfg *config.Config, strategyManager *metrics.StrategyManager, ...) *StrategySyncer + func (ss *StrategySyncer) GetLastSyncTime() time.Time + func (ss *StrategySyncer) GetLastVersion() int64 + func (ss *StrategySyncer) GetStrategyManager() *metrics.StrategyManager + func (ss *StrategySyncer) SetTaskReceiver(receiver *metrics.TaskReceiver) + func (ss *StrategySyncer) Start(ctx context.Context) error + func (ss *StrategySyncer) Stop() + type TaskSyncer struct + func NewTaskSyncer(cfg *config.Config, taskReceiver *metrics.TaskReceiver, ...) *TaskSyncer + func (ts *TaskSyncer) GetLastSyncTime() time.Time + func (ts *TaskSyncer) GetLastVersion() int64 + func (ts *TaskSyncer) Start(ctx context.Context) error + func (ts *TaskSyncer) Stop() + type TelegrafConfigSyncer struct + func NewTelegrafConfigSyncer(cfg *config.Config, metricsCollector metrics.MetricsCollector, ...) *TelegrafConfigSyncer + func (tcs *TelegrafConfigSyncer) GetLastConfig() string + func (tcs *TelegrafConfigSyncer) GetLastConfigHash() string + func (tcs *TelegrafConfigSyncer) GetLastSyncTime() time.Time + func (tcs *TelegrafConfigSyncer) SetOnConfigChange(fn func(config string) error) + func (tcs *TelegrafConfigSyncer) Start(ctx context.Context) error + func (tcs *TelegrafConfigSyncer) Stop()
Go to main page