mirror of
https://github.com/psviderski/uncloud.git
synced 2026-08-26 19:13:34 +00:00
build corrosion image based on wolfi]
This commit is contained in:
@@ -191,7 +191,7 @@ func (s *Subscription) handleChangeEvents() {
|
||||
}
|
||||
|
||||
slog.Info("Resubscribing to Corrosion query due to an error.",
|
||||
"error", err, "id", s.id, "from_change", s.lastChangeID)
|
||||
"err", err, "id", s.id, "from_change", s.lastChangeID)
|
||||
sub, sErr := s.resubscribe(s.ctx, s.lastChangeID)
|
||||
if sErr != nil {
|
||||
// resubscribe returns a permanent error after unsuccessful retries.
|
||||
|
||||
@@ -35,7 +35,7 @@ func (d *Daemon) Run(ctx context.Context) error {
|
||||
case <-d.machine.Started():
|
||||
_, err := systemd.SdNotify(false, systemd.SdNotifyReady)
|
||||
if err != nil {
|
||||
slog.Error("Failed to notify systemd that the daemon is ready.", "error", err)
|
||||
slog.Error("Failed to notify systemd that the daemon is ready.", "err", err)
|
||||
}
|
||||
case <-ctx.Done():
|
||||
}
|
||||
|
||||
@@ -79,7 +79,7 @@ func (s *Store) ListMachines(ctx context.Context) ([]*pb.MachineInfo, error) {
|
||||
return nil, fmt.Errorf("unmarshal machine info: %w", err)
|
||||
}
|
||||
if err = m.Network.Validate(); err != nil {
|
||||
slog.Error("Invalid network configuration for machine in store", "id", m.Id, "error", err)
|
||||
slog.Error("Invalid network configuration for machine in store", "id", m.Id, "err", err)
|
||||
continue
|
||||
}
|
||||
machines = append(machines, &m)
|
||||
|
||||
Reference in New Issue
Block a user