Documentation
¶
Index ¶
- type ConfigFile
- type ConfigManager
- type DependencyManager
- type ServiceDiscovery
- type ServiceManager
- type ServiceRegistry
- func (r *ServiceRegistry) Count() int
- func (r *ServiceRegistry) Get(serviceID string) (*domain.Service, bool)
- func (r *ServiceRegistry) GetByName(name string) (*domain.Service, bool)
- func (r *ServiceRegistry) List() []*domain.Service
- func (r *ServiceRegistry) Register(service *domain.Service)
- func (r *ServiceRegistry) Unregister(serviceID string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConfigManager ¶
type ConfigManager interface {
GetConfigFiles(serviceID string) ([]ConfigFile, error)
UpdateConfigFiles(serviceID string, files []ConfigFile) (map[string]int, error)
}
ConfigManager 配置管理器
func NewConfigManager ¶
func NewConfigManager(registry *ServiceRegistry, logger *zap.Logger) ConfigManager
NewConfigManager 创建配置管理器
type DependencyManager ¶
type DependencyManager struct {
// contains filtered or unexported fields
}
DependencyManager 依赖管理器
func NewDependencyManager ¶
func NewDependencyManager(registry *ServiceRegistry) *DependencyManager
NewDependencyManager 创建依赖管理器
func (*DependencyManager) GetDependents ¶
func (d *DependencyManager) GetDependents(serviceID string) []*domain.Service
GetDependents 获取依赖此服务的其他服务
func (*DependencyManager) ResolveDependencies ¶
func (d *DependencyManager) ResolveDependencies(serviceIDs []string) ([]string, error)
ResolveDependencies 解析依赖关系，返回按依赖顺序排序的服务列表
func (*DependencyManager) ValidateDependencies ¶
func (d *DependencyManager) ValidateDependencies(service *domain.Service) error
ValidateDependencies 验证依赖是否存在
type ServiceDiscovery ¶
type ServiceDiscovery interface {
Discover(ctx context.Context) ([]*domain.Service, error)
Start(ctx context.Context) error
Stop() error
}
ServiceDiscovery 服务发现接口
func NewServiceDiscovery ¶
func NewServiceDiscovery(workspace string, interval time.Duration, registry *ServiceRegistry, logger *zap.Logger) ServiceDiscovery
NewServiceDiscovery 创建服务发现器
type ServiceManager ¶
type ServiceManager interface {
Start(ctx context.Context, serviceID string) error
Stop(ctx context.Context, serviceID string) error
Restart(ctx context.Context, serviceID string) error
GetStatus(ctx context.Context, serviceID string) (*domain.Service, error)
ListServices(ctx context.Context) ([]*domain.Service, error)
RegisterService(service *domain.Service) error
UnregisterService(serviceID string) error
}
ServiceManager 服务管理器接口
func NewServiceManager ¶
func NewServiceManager( registry *ServiceRegistry, systemd *systemd.SystemdAdapter, processManager process.ProcessManager, ) ServiceManager
NewServiceManager 创建服务管理器
type ServiceRegistry ¶
type ServiceRegistry struct {
// contains filtered or unexported fields
}
ServiceRegistry 服务注册表
func (*ServiceRegistry) Get ¶
func (r *ServiceRegistry) Get(serviceID string) (*domain.Service, bool)
Get 获取服务
func (*ServiceRegistry) GetByName ¶
func (r *ServiceRegistry) GetByName(name string) (*domain.Service, bool)
GetByName 根据名称获取服务
func (*ServiceRegistry) Register ¶
func (r *ServiceRegistry) Register(service *domain.Service)
Register 注册服务
func (*ServiceRegistry) Unregister ¶
func (r *ServiceRegistry) Unregister(serviceID string)
Unregister 注销服务
Source Files
Click to show internal directories.
Click to hide internal directories.