WriteableBlock is a trimmed down version of ingester.LocalBlock
| 25 | |
| 26 | // WriteableBlock is a trimmed down version of ingester.LocalBlock |
| 27 | type WriteableBlock struct { |
| 28 | backendBlock common.BackendBlock |
| 29 | |
| 30 | reader backend.Reader |
| 31 | writer backend.Writer |
| 32 | |
| 33 | flushedTime atomic.Int64 // protecting flushedTime b/c it's accessed from the store on flush and from the ingester instance checking flush time |
| 34 | } |
| 35 | |
| 36 | func NewWriteableBlock(backendBlock common.BackendBlock, r backend.Reader, w backend.Writer) tempodb.WriteableBlock { |
| 37 | return &WriteableBlock{ |
nothing calls this directly
no outgoing calls
no test coverage detected