app

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 1, 2026 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type App 

type App struct {
	Server            *server.Server
	RegistryManager   *RegistryManager
	ServiceDiscovery  service.ServiceDiscovery
	HealthCoordinator *health.Coordinator
	MetricsCollector  metrics.MetricsCollector
	MetricsReporter   metrics.MetricsReporter
	ConfigReloader    config.ConfigReloader
	StrategySyncer    *StrategySyncer
}

App 应用结构

func InitializeApp 

func InitializeApp(cfg *config.Config, configPath string, logger *zap.Logger) (*App, error)

InitializeApp 初始化应用

func NewApp 

func NewApp(
	srv *server.Server,
	regMgr *RegistryManager,
	discovery service.ServiceDiscovery,
	healthCoord *health.Coordinator,
	metricsCollector metrics.MetricsCollector,
	metricsReporter metrics.MetricsReporter,
	configReloader config.ConfigReloader,
	strategySyncer *StrategySyncer,
) *App

NewApp 创建应用

type ConfigReloadHandler 

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

ConfigReloadHandler 配置重载处理器

func NewConfigReloadHandler 

func NewConfigReloadHandler(
	registryManager *RegistryManager,
	serviceDiscovery service.ServiceDiscovery,
	metricsCollector metrics.MetricsCollector,
	metricsReporter metrics.MetricsReporter,
	logManager logs.LogManager,
	logger *zap.Logger,
) *ConfigReloadHandler

NewConfigReloadHandler 创建配置重载处理器

func (*ConfigReloadHandler) HandleConfigChange 

func (h *ConfigReloadHandler) HandleConfigChange(newConfig *config.Config) error

HandleConfigChange 处理配置变更

type RegistryManager 

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

RegistryManager 注册管理器

func NewRegistryManager 

func NewRegistryManager(
	reg registry.Registry,
	serviceManager service.ServiceManager,
	logger *zap.Logger,
	agentCode string,
	grpcPort int,
	interval time.Duration,
) *RegistryManager

NewRegistryManager 创建注册管理器

func (*RegistryManager) Start 

func (rm *RegistryManager) Start() error

Start 启动注册管理器

func (*RegistryManager) Stop 

func (rm *RegistryManager) Stop() error

Stop 停止注册管理器

type StrategySyncer 

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

StrategySyncer 策略同步器 从Controller的gRPC服务接收任务并执行

func NewStrategySyncer 

func NewStrategySyncer(
	cfg *config.Config,
	strategyManager *metrics.StrategyManager,
	metricsCollector metrics.MetricsCollector,
	taskRegistry *metrics.TaskExecutorRegistry,
	logger *zap.Logger,
) *StrategySyncer

NewStrategySyncer 创建策略同步器

func (*StrategySyncer) GetLastSyncTime 

func (ss *StrategySyncer) GetLastSyncTime() time.Time

GetLastSyncTime 获取最后同步时间

func (*StrategySyncer) GetLastVersion 

func (ss *StrategySyncer) GetLastVersion() int64

GetLastVersion 获取最后同步的版本号

func (*StrategySyncer) GetStrategyManager 

func (ss *StrategySyncer) GetStrategyManager() *metrics.StrategyManager

GetStrategyManager 获取策略管理器

func (*StrategySyncer) SetTaskReceiver 

func (ss *StrategySyncer) SetTaskReceiver(receiver *metrics.TaskReceiver)

SetTaskReceiver 设置任务接收器

func (*StrategySyncer) Start 

func (ss *StrategySyncer) Start(ctx context.Context) error

Start 启动策略同步器

func (*StrategySyncer) Stop 

func (ss *StrategySyncer) Stop()

Stop 停止策略同步器

type TaskSyncer 

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

TaskSyncer 任务同步器 负责从Controller通过gRPC接收任务并执行 替代原来的StrategySyncer（策略同步器）

func NewTaskSyncer 

func NewTaskSyncer(
	cfg *config.Config,
	taskReceiver *metrics.TaskReceiver,
	taskRegistry *metrics.TaskExecutorRegistry,
	logger *zap.Logger,
) *TaskSyncer

NewTaskSyncer 创建任务同步器

func (*TaskSyncer) GetLastSyncTime 

func (ts *TaskSyncer) GetLastSyncTime() time.Time

GetLastSyncTime 获取最后同步时间

func (*TaskSyncer) GetLastVersion 

func (ts *TaskSyncer) GetLastVersion() int64

GetLastVersion 获取最后版本号

func (*TaskSyncer) Start 

func (ts *TaskSyncer) Start(ctx context.Context) error

Start 启动任务同步器

func (*TaskSyncer) Stop 

func (ts *TaskSyncer) Stop()

Stop 停止任务同步器

type TelegrafConfigSyncer 

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

TelegrafConfigSyncer Telegraf配置同步器

func NewTelegrafConfigSyncer 

func NewTelegrafConfigSyncer(
	cfg *config.Config,
	metricsCollector metrics.MetricsCollector,
	logger *zap.Logger,
) *TelegrafConfigSyncer

NewTelegrafConfigSyncer 创建Telegraf配置同步器

func (*TelegrafConfigSyncer) GetLastConfig 

func (tcs *TelegrafConfigSyncer) GetLastConfig() string

GetLastConfig 获取最后配置内容

func (*TelegrafConfigSyncer) GetLastConfigHash 

func (tcs *TelegrafConfigSyncer) GetLastConfigHash() string

GetLastConfigHash 获取最后配置hash

func (*TelegrafConfigSyncer) GetLastSyncTime 

func (tcs *TelegrafConfigSyncer) GetLastSyncTime() time.Time

GetLastSyncTime 获取最后同步时间

func (*TelegrafConfigSyncer) SetOnConfigChange 

func (tcs *TelegrafConfigSyncer) SetOnConfigChange(fn func(config string) error)

SetOnConfigChange 设置配置变更回调

func (*TelegrafConfigSyncer) Start 

func (tcs *TelegrafConfigSyncer) Start(ctx context.Context) error

Start 启动配置同步器

func (*TelegrafConfigSyncer) Stop 

func (tcs *TelegrafConfigSyncer) Stop()

Stop 停止配置同步器

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.