Function NewSessionManager

pkg/server/session_manager.go:91–111

NewSessionManager creates a new session manager.

(ctx context.Context, sources config.Sources, sessionStore session.Store, refreshInterval time.Duration, runConfig *config.RuntimeConfig)

// NewSessionManager creates a new session manager.
func NewSessionManager(ctx context.Context, sources config.Sources, sessionStore session.Store, refreshInterval time.Duration, runConfig *config.RuntimeConfig) *SessionManager {
	loaders := make(config.Sources)
	for name, source := range sources {
		loaders[name] = newSourceLoader(ctx, source, refreshInterval)
	}

	sm := &SessionManager{
		runtimeSessions:   concurrent.NewMap[string, *activeRuntimes](),
		deletedSessions:   concurrent.NewMap[string, *activeRuntimes](),
		eventLogs:         concurrent.NewMap[string, *pumpedEventLog](),
		followUpInjectors: concurrent.NewMap[string, FollowUpInjector](),
		followUpKeys:      concurrent.NewMap[string, *idempotencyCache](),
		sessionStore:      sessionStore,
		Sources:           loaders,
		refreshInterval:   refreshInterval,
		runConfig:         runConfig,
		sessionReady:      make(chan struct{}),
	}

	return sm
}

func (sm *SessionManager) markReady() {
	sm.sessionReadyOnce.Do(func() { close(sm.sessionReady) })