mirror of
https://github.com/hanzoai/o11y-foundry.git
synced 2026-10-30 18:26:45 +00:00
NageshbansalandGitHub
abbf0af044
#### Summary Introduces a per-Kind `Planner` contract so Foundry can drive multiple casting Kinds through a single pipeline. `Foundry.Forge` / `Cast` / `Gauge` become Kind-agnostic; per-Kind state (registry, moldings, casting strategy, enricher) lives in the Kind's own Planner. #### Changes - New `internal/planner` package defining the `Planner` contract. - `Foundry` holds a `Planners` dispatch map; each casting package implements the contract (`installation.Planner`, `collectionagent.Planner`). - Installation registry moves from `internal/foundry/registry.go` to `internal/casting/installation/registry.go`. - CollectionAgent Kind scaffolded: Planner + collector molding wired end-to-end. No deployment castings yet. - `MoldingKindCollector` added to `api/v1alpha1/molding_kind.go`. Related: https://github.com/SigNoz/platform-pod/issues/1971, https://github.com/SigNoz/platform-pod/issues/1972
107 lines
2.6 KiB
Go
107 lines
2.6 KiB
Go
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"log/slog"
|
|
"os"
|
|
"sort"
|
|
|
|
"github.com/olekukonko/tablewriter"
|
|
"github.com/signoz/foundry/api/v1alpha1"
|
|
installationcasting "github.com/signoz/foundry/internal/casting/installation"
|
|
"github.com/signoz/foundry/internal/domain"
|
|
"github.com/spf13/cobra"
|
|
)
|
|
|
|
func registerCatalogCmd(rootCmd *cobra.Command) {
|
|
catalogCmd := &cobra.Command{
|
|
Use: "catalog",
|
|
Short: "Show available castings",
|
|
RunE: recoverRunE(domain.EventCatalog, func(cmd *cobra.Command, args []string) (domain.Properties, error) {
|
|
return runCatalog(rootLogger)
|
|
}),
|
|
}
|
|
|
|
catalogCfg.RegisterFlags(catalogCmd)
|
|
rootCmd.AddCommand(catalogCmd)
|
|
}
|
|
|
|
type castingEntry struct {
|
|
Platform string `json:"platform"`
|
|
Mode string `json:"mode"`
|
|
Flavor string `json:"flavor"`
|
|
Example string `json:"example"`
|
|
}
|
|
|
|
func castingExample(d v1alpha1.TypeDeployment) string {
|
|
platform, mode, flavor := d.Platform.String(), d.Mode.String(), d.Flavor.String()
|
|
switch {
|
|
case platform != "" && mode != "":
|
|
return platform + "/" + mode + "/" + flavor
|
|
case platform != "":
|
|
return platform + "/" + flavor
|
|
default:
|
|
return mode + "/" + flavor
|
|
}
|
|
}
|
|
|
|
// catalogGroup returns a sort key that groups entries:
|
|
// 0 = mode + flavor (self-hosted: docker, systemd, kubernetes).
|
|
// 1 = mode + flavor + platform (cloud infra: ecs).
|
|
// 2 = platform + flavor (managed platforms: coolify, render, railway).
|
|
func catalogGroup(e castingEntry) int {
|
|
switch {
|
|
case e.Platform != "" && e.Mode != "":
|
|
return 1
|
|
case e.Platform != "":
|
|
return 2
|
|
default:
|
|
return 0
|
|
}
|
|
}
|
|
|
|
func runCatalog(logger *slog.Logger) (domain.Properties, error) {
|
|
registry := installationcasting.NewRegistry(logger)
|
|
|
|
var entries []castingEntry
|
|
for d := range registry.CastingItems() {
|
|
entries = append(entries, castingEntry{
|
|
Platform: d.Platform.String(),
|
|
Mode: d.Mode.String(),
|
|
Flavor: d.Flavor.String(),
|
|
Example: castingExample(d),
|
|
})
|
|
}
|
|
|
|
sort.Slice(entries, func(i, j int) bool {
|
|
gi, gj := catalogGroup(entries[i]), catalogGroup(entries[j])
|
|
if gi != gj {
|
|
return gi < gj
|
|
}
|
|
return entries[i].Example < entries[j].Example
|
|
})
|
|
|
|
props := domain.NewProperties()
|
|
|
|
if commonCfg.Format == "text" {
|
|
table := tablewriter.NewWriter(os.Stdout)
|
|
table.Header("Mode", "Flavor", "Platform", "Example")
|
|
for _, e := range entries {
|
|
_ = table.Append(e.Mode, e.Flavor, e.Platform, e.Example)
|
|
}
|
|
|
|
return props, table.Render()
|
|
}
|
|
|
|
data, err := json.MarshalIndent(map[string]any{"Castings": entries}, "", " ")
|
|
if err != nil {
|
|
return props, err
|
|
}
|
|
if catalogCfg.OutPath != "" {
|
|
err = os.WriteFile(catalogCfg.OutPath, data, 0644)
|
|
return props, err
|
|
}
|
|
_, err = os.Stdout.Write(data)
|
|
return props, err
|
|
}
|