Method starting

modules/livestore/live_store.go:272–355

(ctx context.Context)

}

func (s *LiveStore) starting(ctx context.Context) error {
	// First of all we have to check if the shutdown marker is set. This needs to be done
	// as first thing because, if found, it may change the behaviour of the live-store startup.

	if _, err := os.Stat(s.cfg.ShutdownMarkerDir); os.IsNotExist(err) {
		err := os.MkdirAll(s.cfg.ShutdownMarkerDir, 0o700)
		if err != nil {
			return fmt.Errorf("failed to create shutdown marker directory: %w", err)
		}
	}

	shutdownMarkerPath := shutdownmarker.GetPath(s.cfg.ShutdownMarkerDir)
	if exists, err := shutdownmarker.Exists(shutdownMarkerPath); err != nil {
		return fmt.Errorf("failed to check live-store shutdown marker: %w", err)
	} else if exists {
		level.Info(s.logger).Log("msg", "detected existing shutdown marker, setting prepare for shutdown", "path", shutdownMarkerPath)
		s.setPrepareShutdown()
	}

	var err error
	s.wal, err = wal.New(&s.cfg.WAL)
	if err != nil {
		return fmt.Errorf("failed to create WAL: %w", err)
	}

	err = s.reloadBlocks()
	if err != nil {
		return fmt.Errorf("failed to reload blocks from wal: %w", err)
	}

	level.Info(s.logger).Log("msg", "deleting old blocks")
	for _, inst := range s.getInstances() {
		err = inst.deleteOldBlocks()
		if err != nil {
			level.Warn(s.logger).Log("msg", "failed to delete old blocks", "err", err, "tenant", inst.tenantID)
		}
	}
	level.Info(s.logger).Log("msg", "done deleting old blocks")

	// Set eagerly so the flag is already in place when the lifecycler's stopping()
	// checks it. Setting it in our own stopping() races with context-cancellation
	// that triggers the lifecycler's shutdown first.
	if s.cfg.RemoveOwnerOnShutdown {
		s.ingestPartitionLifecycler.SetRemoveOwnerOnShutdown(true)
	}

	err = services.StartAndAwaitRunning(ctx, s.ingestPartitionLifecycler)
	if err != nil {
		return fmt.Errorf("failed to start partition lifecycler: %w", err)
	}

	err = services.StartAndAwaitRunning(ctx, s.livestoreLifecycler)
	if err != nil {
		return fmt.Errorf("failed to start livestore lifecycler: %w", err)
	}

	if err := s.startIngestPath(ctx); err != nil {
		return err