Struct instance

modules/livestore/instance.go:105–141

)

type instance struct {
	tenantID string
	logger   log.Logger

	// Configuration
	Cfg Config

	// WAL and encoding
	wal                    *wal.WAL
	completeBlockEncoding  encoding.VersionedEncoding
	completeBlockLifecycle completeBlockLifecycle

	// blocksMtx serializes writers. Readers iterate the immutable snapshot
	// via atomic.Load; for the headBlock's mutating BlockMeta they must use
	// WALBlock.MetaSnapshot.
	blocksMtx   sync.Mutex
	blocks      atomic.Pointer[blockSnapshot]
	lastCutTime time.Time

	// reclaim holds blocks removed from the snapshot whose files must
	// outlive in-flight readers; drained after the grace window.
	reclaim *quarantine

	// Live traces
	liveTracesMtx      sync.Mutex
	liveTraces         *livetraces.LiveTraces[*v1.ResourceSpans]
	traceSizes         *tracesizes.Tracker
	maxTraceLogger     *util_log.RateLimitedLogger
	liveTracesIterNext func() (*livetraces.LiveTrace[*v1.ResourceSpans], bool)
	liveTracesIterStop func()

	// Metrics
	tracesCreatedTotal prometheus.Counter
	bytesReceivedTotal *prometheus.CounterVec

	overrides overrides.Interface
}

func newInstance(instanceID string, cfg Config, wal *wal.WAL, completeBlockEncoding encoding.VersionedEncoding, completeBlockLifecycle completeBlockLifecycle, overrides overrides.Interface, logger log.Logger) (*instance, error) {
	logger = log.With(logger, "tenant", instanceID)