| 146 | var _ Reader = (*readerWriter)(nil) |
| 147 | |
| 148 | type readerWriter struct { |
| 149 | r backend.Reader |
| 150 | w backend.Writer |
| 151 | c backend.Compactor |
| 152 | |
| 153 | wal *wal.WAL |
| 154 | pool *pool.Pool |
| 155 | |
| 156 | logger gkLog.Logger |
| 157 | cfg *Config |
| 158 | |
| 159 | blocklistPoller *blocklist.Poller |
| 160 | blocklist *blocklist.List |
| 161 | |
| 162 | compactorCfg *CompactorConfig |
| 163 | compactorSharder CompactorSharder |
| 164 | compactorOverrides CompactorOverrides |
| 165 | compactorTenantOffset uint |
| 166 | |
| 167 | pollerShutdownCh chan struct{} |
| 168 | |
| 169 | pollerNotificationLock sync.Mutex |
| 170 | pollerNotificationFuncs []func() |
| 171 | } |
| 172 | |
| 173 | // New creates a new tempodb |
| 174 | func New(cfg *Config, cacheProvider cache.Provider, logger gkLog.Logger) (Reader, Writer, Compactor, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected