Method committedState

internal/epoch/epoch_manager.go:774–792

(ctx context.Context, ensureMinTime time.Duration)

}

func (e *Manager) committedState(ctx context.Context, ensureMinTime time.Duration) (CurrentSnapshot, error) {
	e.mu.Lock()
	defer e.mu.Unlock()

	if now := e.timeFunc().Add(ensureMinTime); now.After(e.lastKnownState.ValidUntil) {
		contentlog.Log2(
			ctx, e.log,
			"refreshing committed state because it's no longer valid",
			logparam.Time("now", now),
			logparam.Time("validUntil", e.lastKnownState.ValidUntil),
		)

		if err := e.refreshLocked(ctx); err != nil {
			return CurrentSnapshot{}, err
		}
	}

	return e.lastKnownState, nil
}

// GetCompleteIndexSet returns the set of blobs forming a complete index set up to the provided epoch number.
func (e *Manager) GetCompleteIndexSet(ctx context.Context, maxEpoch int) ([]blob.Metadata, time.Time, error) {