Function NewManager

internal/auth/streaming/manager.go:45–53

NewManager creates a new streaming credentials manager. Parameters: - pl: The connection pool to manage - reAuthTimeout: Maximum time to wait for acquiring a connection for re-authentication The manager creates a ReAuthPoolHook sized to match the pool size, ensuring that re-auth operations don't e

(pl pool.Pooler, reAuthTimeout time.Duration)

// The manager creates a ReAuthPoolHook sized to match the pool size, ensuring that
// re-auth operations don't exhaust the connection pool.
func NewManager(pl pool.Pooler, reAuthTimeout time.Duration) *Manager {
	m := &Manager{
		pool:                 pl,
		poolHookRef:          NewReAuthPoolHook(pl.Size(), reAuthTimeout),
		credentialsListeners: NewCredentialsListeners(),
	}
	m.poolHookRef.manager = m
	return m
}

// PoolHook returns the pool hook for re-authentication.
//