session

package

v0.6.0 Latest Latest Go to latest Published: Jan 23, 2026 License: AGPL-3.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Manager struct {
	// contains filtered or unexported fields
}

Manager orchestrates session access, ensuring safe concurrent operations. It uses Reference Counting to garbage collect unused locks.

func NewManager(store ports.StateStore) *Manager

NewManager creates a new Session Manager with the given persistence store.

func (m *Manager) Delete(ctx context.Context, sessionID string) error

Delete removes the session from the store.

func (m *Manager) List(ctx context.Context) ([]string, error)

List delegates to the store.

func (m *Manager) Load(ctx context.Context, sessionID string) (*domain.State, error)

Load retrieves an existing session from the store.

func (m *Manager) LoadOrStart(ctx context.Context, sessionID string, startNode string) (*domain.State, error)

LoadOrStart tries to load a session. If not found, it initializes a new one.

func (m *Manager) Save(ctx context.Context, sessionID string, state *domain.State) error

Save persists the session state.

func (m *Manager) WithLock(ctx context.Context, sessionID string, fn func(context.Context) error) error

WithLock executes a function while holding the lock for the session.