| 116 | } |
| 117 | |
| 118 | func (c *LocalBlock) SetFlushed(ctx context.Context) error { |
| 119 | flushedTime := time.Now() |
| 120 | flushedBytes, err := flushedTime.MarshalText() |
| 121 | if err != nil { |
| 122 | return fmt.Errorf("error marshalling flush time to text: %w", err) |
| 123 | } |
| 124 | |
| 125 | err = c.writer.Write(ctx, nameFlushed, (uuid.UUID)(c.BlockMeta().BlockID), c.BlockMeta().TenantID, flushedBytes, nil) |
| 126 | if err != nil { |
| 127 | return fmt.Errorf("error writing local block flushed file: %w", err) |
| 128 | } |
| 129 | |
| 130 | c.flushedTime.Store(flushedTime.Unix()) |
| 131 | return nil |
| 132 | } |
| 133 | |
| 134 | func (c *LocalBlock) Write(ctx context.Context, w backend.Writer) error { |
| 135 | if err := encoding.CopyBlock(ctx, c.BlockMeta(), c.reader, w); err != nil { |