mirror of
https://github.com/chrislusf/seaweedfs
synced 2025-07-26 05:22:46 +02:00
aa66852304
* add ui for maintenance * valid config loading. fix workers page. * refactor * grpc between admin and workers * add a long-running bidirectional grpc call between admin and worker * use the grpc call to heartbeat * use the grpc call to communicate * worker can remove the http client * admin uses http port + 10000 as its default grpc port * one task one package * handles connection failures gracefully with exponential backoff * grpc with insecure tls * grpc with optional tls * fix detecting tls * change time config from nano seconds to seconds * add tasks with 3 interfaces * compiles reducing hard coded * remove a couple of tasks * remove hard coded references * reduce hard coded values * remove hard coded values * remove hard coded from templ * refactor maintenance package * fix import cycle * simplify * simplify * auto register * auto register factory * auto register task types * self register types * refactor * simplify * remove one task * register ui * lazy init executor factories * use registered task types * DefaultWorkerConfig remove hard coded task types * remove more hard coded * implement get maintenance task * dynamic task configuration * "System Settings" should only have system level settings * adjust menu for tasks * ensure menu not collapsed * render job configuration well * use templ for ui of task configuration * fix ordering * fix bugs * saving duration in seconds * use value and unit for duration * Delete WORKER_REFACTORING_PLAN.md * Delete maintenance.json * Delete custom_worker_example.go * remove address from workers * remove old code from ec task * remove creating collection button * reconnect with exponential backoff * worker use security.toml * start admin server with tls info from security.toml * fix "weed admin" cli description
47 lines
1.3 KiB
Go
47 lines
1.3 KiB
Go
package layout
|
|
|
|
import (
|
|
"github.com/seaweedfs/seaweedfs/weed/admin/maintenance"
|
|
|
|
// Import task packages to trigger their auto-registration
|
|
_ "github.com/seaweedfs/seaweedfs/weed/worker/tasks/balance"
|
|
_ "github.com/seaweedfs/seaweedfs/weed/worker/tasks/erasure_coding"
|
|
_ "github.com/seaweedfs/seaweedfs/weed/worker/tasks/vacuum"
|
|
)
|
|
|
|
// MenuItemData represents a menu item
|
|
type MenuItemData struct {
|
|
Name string
|
|
URL string
|
|
Icon string
|
|
Description string
|
|
}
|
|
|
|
// GetConfigurationMenuItems returns the dynamic configuration menu items
|
|
func GetConfigurationMenuItems() []*MenuItemData {
|
|
var menuItems []*MenuItemData
|
|
|
|
// Add system configuration item
|
|
menuItems = append(menuItems, &MenuItemData{
|
|
Name: "System",
|
|
URL: "/maintenance/config",
|
|
Icon: "fas fa-cogs",
|
|
Description: "System-level configuration",
|
|
})
|
|
|
|
// Get all registered task types and add them as submenu items
|
|
registeredTypes := maintenance.GetRegisteredMaintenanceTaskTypes()
|
|
|
|
for _, taskType := range registeredTypes {
|
|
menuItem := &MenuItemData{
|
|
Name: maintenance.GetTaskDisplayName(taskType),
|
|
URL: "/maintenance/config/" + string(taskType),
|
|
Icon: maintenance.GetTaskIcon(taskType),
|
|
Description: maintenance.GetTaskDescription(taskType),
|
|
}
|
|
|
|
menuItems = append(menuItems, menuItem)
|
|
}
|
|
|
|
return menuItems
|
|
}
|