| 100 | } |
| 101 | |
| 102 | func (v *VisitMarkerManager) MarkWithStatus(ctx context.Context, status VisitStatus) { |
| 103 | v.visitMarker.UpdateStatus(v.ownerIdentifier, status) |
| 104 | if err := v.updateVisitMarker(ctx); err != nil { |
| 105 | level.Error(v.getLogger()).Log("msg", "unable to upsert visit marker file content", "new_status", status, "err", err) |
| 106 | return |
| 107 | } |
| 108 | level.Debug(v.getLogger()).Log("msg", "marked with new status", "new_status", status) |
| 109 | } |
| 110 | |
| 111 | func (v *VisitMarkerManager) DeleteVisitMarker(ctx context.Context) { |
| 112 | if err := v.bkt.Delete(ctx, v.visitMarker.GetVisitMarkerFilePath()); err != nil { |