treewide: delete cloud/ except cloud/agent
bmdb is no longer used in production and would be hard to maintain. The only non-stub provider is Equinix Metal, which is shutting down in 2026, and we are moving away from CockroachDB. Keep the agent, which we'll need for Monogon Cloud.
Change-Id: If8b35c3ac8cdeed96a2b1814c0de7607e8acec63
Reviewed-on: https://review.monogon.dev/c/monogon/+/4235
Tested-by: Jenkins CI
Reviewed-by: Leopold Schabel <leo@monogon.tech>
diff --git a/cloud/agent/agent.go b/cloud/agent/agent.go
index 05b2daf..665351a 100644
--- a/cloud/agent/agent.go
+++ b/cloud/agent/agent.go
@@ -22,7 +22,6 @@
"google.golang.org/protobuf/proto"
apb "source.monogon.dev/cloud/agent/api"
- bpb "source.monogon.dev/cloud/bmaas/server/api"
"source.monogon.dev/metropolis/node/core/devmgr"
"source.monogon.dev/metropolis/node/core/network"
@@ -103,32 +102,32 @@
if err != nil {
return fmt.Errorf("error creating BMaaS gRPC client: %w", err)
}
- c := bpb.NewAgentCallbackClient(conn)
+ c := apb.NewAgentCallbackClient(conn)
supervisor.Signal(ctx, supervisor.SignalHealthy)
- assembleHWReport := func() *bpb.AgentHardwareReport {
+ assembleHWReport := func() *apb.AgentHardwareReport {
report, warnings := gatherHWReport()
var warningStrings []string
for _, w := range warnings {
l.Warningf("Hardware Report Warning: %v", w)
warningStrings = append(warningStrings, w.Error())
}
- return &bpb.AgentHardwareReport{
+ return &apb.AgentHardwareReport{
Report: report,
Warning: warningStrings,
}
}
var sentFirstHeartBeat, hwReportSent bool
- var installationReport *bpb.OSInstallationReport
+ var installationReport *apb.OSInstallationReport
var installationGeneration int64
b := backoff.NewExponentialBackOff()
// Never stop retrying, there is nothing else to do
b.MaxElapsedTime = 0
// Main heartbeat loop
for {
- req := bpb.HeartbeatRequest{
+ req := apb.HeartbeatRequest{
MachineId: agentInit.TakeoverInit.MachineId,
}
if sentFirstHeartBeat && !hwReportSent {
@@ -167,21 +166,21 @@
// This installation request has already been attempted
continue
}
- installationReport = &bpb.OSInstallationReport{
+ installationReport = &apb.OSInstallationReport{
Generation: res.InstallationRequest.Generation,
}
installCtx, cancel := context.WithTimeout(ctx, 15*time.Minute)
if err := install(installCtx, res.InstallationRequest, agentInit.NetworkConfig); err != nil {
l.Errorf("Installation failed: %v", err)
- installationReport.Result = &bpb.OSInstallationReport_Error_{
- Error: &bpb.OSInstallationReport_Error{
+ installationReport.Result = &apb.OSInstallationReport_Error_{
+ Error: &apb.OSInstallationReport_Error{
Error: err.Error(),
},
}
} else {
l.Info("Installation succeeded")
- installationReport.Result = &bpb.OSInstallationReport_Success_{
- Success: &bpb.OSInstallationReport_Success{},
+ installationReport.Result = &apb.OSInstallationReport_Success_{
+ Success: &apb.OSInstallationReport_Success{},
}
}
cancel()