(ctx context.Context)
| 138 | } |
| 139 | |
| 140 | func (v *VisitMarkerManager) updateVisitMarker(ctx context.Context) error { |
| 141 | visitMarkerFileContent, err := json.Marshal(v.visitMarker) |
| 142 | if err != nil { |
| 143 | return err |
| 144 | } |
| 145 | |
| 146 | reader := bytes.NewReader(visitMarkerFileContent) |
| 147 | if err := v.bkt.Upload(ctx, v.visitMarker.GetVisitMarkerFilePath(), reader); err != nil { |
| 148 | return err |
| 149 | } |
| 150 | return nil |
| 151 | } |
| 152 | |
| 153 | func (v *VisitMarkerManager) getLogger() log.Logger { |
| 154 | return log.With(v.logger, "visit_marker", v.visitMarker.String()) |